diff --git a/core/src/main/java/zingg/util/PipeUtil.java b/core/src/main/java/zingg/util/PipeUtil.java index 78a10d766..4ed4a28ca 100644 --- 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 read(DataFrameReader reader, Pipe p, boolean addSource) { Dataset input = null; if (p.getProps().containsKey(FilePipe.LOCATION)) { + LOG.warn("Reading location: " + p.get(FilePipe.LOCATION)); input = reader.load(p.get(FilePipe.LOCATION)); } else {