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
index d94b3931bb99a..ec3741fbf8762 100644
--- 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,7 +145,7 @@ public boolean isIdReference() {
 
     // --------------------------------------------------------------------------------------------
 
-    public void connecDataSet(IntermediateDataSet dataSet) {
+    public void connectDataSet(IntermediateDataSet dataSet) {
         if (dataSet == null) {
             throw new NullPointerException();
         }