[hotfix] Remove unused method JobEdge#connectDataSet

silenceland · Aug 11, 2021 · dbfe2c6 · dbfe2c6
1 parent 8e2a085
commit dbfe2c6
Showing 1 changed file with 0 additions and 17 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobEdge.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobEdge.java
@@ -145,23 +145,6 @@ public boolean isIdReference() {
 
     // --------------------------------------------------------------------------------------------
 
-    public void connectDataSet(IntermediateDataSet dataSet) {
-        if (dataSet == null) {
-            throw new NullPointerException();
-        }
-        if (this.source != null) {
-            throw new IllegalStateException("The edge is already connected.");
-        }
-        if (!dataSet.getId().equals(sourceId)) {
-            throw new IllegalArgumentException(
-                    "The data set to connect does not match the sourceId.");
-        }
-
-        this.source = dataSet;
-    }
-
-    // --------------------------------------------------------------------------------------------
-
     /**
      * Gets the name of the ship strategy for the represented input, like "forward", "partition
      * hash", "rebalance", "broadcast", ...