Repository: flink Updated Branches: refs/heads/master ebba20dfa -> 49f5a0179
[FLINK-2686] Show exchange mode in JSON plan This closes #1378 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/49f5a017 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/49f5a017 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/49f5a017 Branch: refs/heads/master Commit: 49f5a0179459fbe2d205df2b17196afe3e2bf506 Parents: ebba20d Author: zentol <ches...@apache.org> Authored: Wed Nov 18 14:52:48 2015 +0100 Committer: zentol <ches...@apache.org> Committed: Tue Nov 24 21:39:20 2015 +0100 ---------------------------------------------------------------------- .../apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/49f5a017/flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java ---------------------------------------------------------------------- diff --git a/flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java b/flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java index e248b0b..aaabac5 100644 --- a/flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java +++ b/flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java @@ -382,6 +382,11 @@ public class PlanJSONDumpGenerator { String tempMode = channel.getTempMode().toString(); writer.print(", \"temp_mode\": \"" + tempMode + "\""); } + + if (channel != null) { + String exchangeMode = channel.getDataExchangeMode().toString(); + writer.print(", \"exchange_mode\": \"" + exchangeMode + "\""); + } } writer.print('}');
