logging location of the file being read zinggAI#83

navinrathore · Dec 29, 2021 · 6d0fbd9 · 6d0fbd9
1 parent 614349f
commit 6d0fbd9
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
@@ -70,6 +70,7 @@ private static DataFrameReader getReader(SparkSession spark, Pipe p) {
 	private static Dataset<Row> read(DataFrameReader reader, Pipe p, boolean addSource) {
 		Dataset<Row> input = null;
 		if (p.getProps().containsKey(FilePipe.LOCATION)) {
+			LOG.warn("Reading location: " + p.get(FilePipe.LOCATION));
 			input = reader.load(p.get(FilePipe.LOCATION));
 		}
 		else {