You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2015/11/24 21:41:34 UTC
flink git commit: [FLINK-2686] Show exchange mode in JSON plan
Repository: flink
Updated Branches:
refs/heads/2686_json_exchange [created] 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/2686_json_exchange
Commit: 49f5a0179459fbe2d205df2b17196afe3e2bf506
Parents: ebba20d
Author: zentol <ch...@apache.org>
Authored: Wed Nov 18 14:52:48 2015 +0100
Committer: zentol <ch...@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('}');