diff --git a/processing/src/main/java/io/druid/query/UnionQueryRunner.java b/processing/src/main/java/io/druid/query/UnionQueryRunner.java index fc1534ebc92..0e3088c4847 100644 --- a/processing/src/main/java/io/druid/query/UnionQueryRunner.java +++ b/processing/src/main/java/io/druid/query/UnionQueryRunner.java @@ -40,7 +40,6 @@ public class UnionQueryRunner implements QueryRunner { DataSource dataSource = query.getDataSource(); if (dataSource instanceof UnionDataSource) { - System.out.println("Breaking into Single Source" + dataSource.getMetricName()); return Sequences.concat( Iterables.transform( ((UnionDataSource) dataSource).getDataSources(), @@ -49,7 +48,6 @@ public class UnionQueryRunner implements QueryRunner @Override public Sequence apply(DataSource singleSource) { - System.out.println("Running with Single Source" + singleSource.getNames()); return baseRunner.run( query.withDataSource(singleSource) );