shuttle: When closing the flow control request, the connection of bui…

…ld conn is not created
cubefs · Jul 18, 2022 · 78fd61e · 78fd61e
1 parent 0c6fecb
commit 78fd61e
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/java/com/oppo/shuttle/rss/clients/NettyClient.java b/src/main/java/com/oppo/shuttle/rss/clients/NettyClient.java
@@ -220,7 +220,10 @@ public Tuple2<ShuffleClient, ShuffleClient> getClient(int workerId, int retry, O
         Ors2WorkerDetail useServer = serverGroup.getServer(workerId, retry, errorServer);
         for (int i = 0; i < loopTimes; i++) {
             try {
-                ShuffleClient buildClient = getBuildClient(useServer);
+                ShuffleClient buildClient = null;
+                if (flowControlEnable) {
+                    buildClient = getBuildClient(useServer);
+                }
                 ShuffleClient dataClient = getDataClient(useServer);
                 return Tuple2.apply(buildClient, dataClient);
             } catch (RuntimeException e) {