Repository: samza Updated Branches: refs/heads/master 25d943f1c -> 4394b89ef
SAMZA-1825: Fix for the test failure Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/4394b89e Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/4394b89e Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/4394b89e Branch: refs/heads/master Commit: 4394b89ef71a8311fa3a955ec55e3c3e5fd2dcfd Parents: 25d943f Author: Srinivasulu Punuru <[email protected]> Authored: Fri Aug 24 11:27:19 2018 -0700 Committer: Srinivasulu Punuru <[email protected]> Committed: Fri Aug 24 11:44:06 2018 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/samza/sql/planner/QueryPlanner.java | 8 -------- 1 file changed, 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/4394b89e/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java ---------------------------------------------------------------------- diff --git a/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java b/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java index 8ebb885..7b0dd51 100644 --- a/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java +++ b/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java @@ -137,8 +137,6 @@ public class QueryPlanner { SqlNode validatedSql = planner.validate(sql); RelRoot relRoot = planner.rel(validatedSql); LOG.info("query plan:\n" + sql.toString()); - LOG.info("relational graph:"); - printRelGraph(relRoot.project()); return relRoot; } catch (Exception e) { LOG.error("Query planner failed with exception.", e); @@ -157,10 +155,4 @@ public class QueryPlanner { } }; } - - private static void printRelGraph(RelNode node) { - RelJsonWriter jsonWriter = new RelJsonWriter(); - node.explain(jsonWriter); - LOG.info(jsonWriter.asString()); - } }
