From 44905b147315ec1f4abe9d4a72c7402fb8a7408d Mon Sep 17 00:00:00 2001
From: "yunhua@dtstack.com" <123456Lq>
Date: Fri, 16 Apr 2021 23:28:47 +0800
Subject: [PATCH] fix typos

---
 .../main/java/org/apache/flink/runtime/jobgraph/JobEdge.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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();
         }