logging location of the file being read zinggAI#83

navinrathore · Dec 30, 2021 · b0376e2 · b0376e2
1 parent 30ababa
commit b0376e2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/java/zingg/util/PipeUtil.java b/core/src/main/java/zingg/util/PipeUtil.java
@@ -69,6 +69,7 @@ private static DataFrameReader getReader(SparkSession spark, Pipe p) {
 
 	private static Dataset<Row> read(DataFrameReader reader, Pipe p, boolean addSource) {
 		Dataset<Row> input = null;
+		LOG.warn("Reading " + p);
 		if (p.getProps().containsKey(FilePipe.LOCATION)) {
 			input = reader.load(p.get(FilePipe.LOCATION));
 		}