You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by sr...@apache.org on 2018/10/25 21:32:43 UTC
samza git commit: Print the logical plan during query planning
Repository: samza
Updated Branches:
refs/heads/master 5a31be92e -> 1c2d6effb
Print the logical plan during query planning
Minor fix to print the logical plan.
Author: Srinivasulu Punuru <sp...@linkedin.com>
Reviewers: Aditya Toomula <at...@linkedin.com>
Closes #763 from srinipunuru/print.1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1c2d6eff
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/1c2d6eff
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/1c2d6eff
Branch: refs/heads/master
Commit: 1c2d6effba097202e4ab9bddf9dc060683f0110c
Parents: 5a31be9
Author: Srinivasulu Punuru <sp...@linkedin.com>
Authored: Thu Oct 25 14:32:38 2018 -0700
Committer: Srinivasulu Punuru <sp...@linkedin.com>
Committed: Thu Oct 25 14:32:38 2018 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/samza/sql/planner/QueryPlanner.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/1c2d6eff/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 7b0dd51..f36d990 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
@@ -30,6 +30,7 @@ import org.apache.calcite.config.Lex;
import org.apache.calcite.jdbc.CalciteConnection;
import org.apache.calcite.plan.Contexts;
import org.apache.calcite.plan.ConventionTraitDef;
+import org.apache.calcite.plan.RelOptUtil;
import org.apache.calcite.plan.RelTraitDef;
import org.apache.calcite.rel.RelCollationTraitDef;
import org.apache.calcite.rel.RelNode;
@@ -136,7 +137,7 @@ public class QueryPlanner {
SqlNode sql = planner.parse(query);
SqlNode validatedSql = planner.validate(sql);
RelRoot relRoot = planner.rel(validatedSql);
- LOG.info("query plan:\n" + sql.toString());
+ LOG.info("query plan:\n" + RelOptUtil.toString(relRoot.rel));
return relRoot;
} catch (Exception e) {
LOG.error("Query planner failed with exception.", e);