You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2020/09/07 15:02:15 UTC
[flink] 01/02: [hotfix][datastream] Fix the formatting of
StreamEdge class
This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1f2d26fab78fc9f3512a54237cc3b7a072af6358
Author: Zhijiang <wa...@aliyun.com>
AuthorDate: Thu Aug 20 09:28:52 2020 +0200
[hotfix][datastream] Fix the formatting of StreamEdge class
---
.../flink/streaming/api/graph/StreamEdge.java | 41 ++++++++++++++--------
1 file changed, 26 insertions(+), 15 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java
index 2ee4a7c..fa26dc5 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java
@@ -76,20 +76,33 @@ public class StreamEdge implements Serializable {
private final ShuffleMode shuffleMode;
- public StreamEdge(StreamNode sourceVertex, StreamNode targetVertex, int typeNumber,
- List<String> selectedNames, StreamPartitioner<?> outputPartitioner, OutputTag outputTag) {
- this(sourceVertex,
- targetVertex,
- typeNumber,
- selectedNames,
- outputPartitioner,
- outputTag,
- ShuffleMode.UNDEFINED);
+ public StreamEdge(
+ StreamNode sourceVertex,
+ StreamNode targetVertex,
+ int typeNumber,
+ List<String> selectedNames,
+ StreamPartitioner<?> outputPartitioner,
+ OutputTag outputTag) {
+
+ this(
+ sourceVertex,
+ targetVertex,
+ typeNumber,
+ selectedNames,
+ outputPartitioner,
+ outputTag,
+ ShuffleMode.UNDEFINED);
}
- public StreamEdge(StreamNode sourceVertex, StreamNode targetVertex, int typeNumber,
- List<String> selectedNames, StreamPartitioner<?> outputPartitioner, OutputTag outputTag,
- ShuffleMode shuffleMode) {
+ public StreamEdge(
+ StreamNode sourceVertex,
+ StreamNode targetVertex,
+ int typeNumber,
+ List<String> selectedNames,
+ StreamPartitioner<?> outputPartitioner,
+ OutputTag outputTag,
+ ShuffleMode shuffleMode) {
+
this.sourceId = sourceVertex.getId();
this.targetId = targetVertex.getId();
this.typeNumber = typeNumber;
@@ -99,9 +112,7 @@ public class StreamEdge implements Serializable {
this.sourceOperatorName = sourceVertex.getOperatorName();
this.targetOperatorName = targetVertex.getOperatorName();
this.shuffleMode = checkNotNull(shuffleMode);
-
- this.edgeId = sourceVertex + "_" + targetVertex + "_" + typeNumber + "_" + selectedNames
- + "_" + outputPartitioner;
+ this.edgeId = sourceVertex + "_" + targetVertex + "_" + typeNumber + "_" + selectedNames + "_" + outputPartitioner;
}
public int getSourceId() {