From 53d6928f835a605ff15348bdd1054ff0918dfece Mon Sep 17 00:00:00 2001
From: Paddy <liuliu@dtstack.com>
Date: Fri, 16 Sep 2022 17:12:22 +0800
Subject: [PATCH] [hotfix][main]Sync jobs disable operator chains (#1263)

---
 chunjun-core/src/main/java/com/dtstack/chunjun/Main.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/Main.java b/chunjun-core/src/main/java/com/dtstack/chunjun/Main.java
index 32e6bc1178..eb12b76aa8 100644
--- a/chunjun-core/src/main/java/com/dtstack/chunjun/Main.java
+++ b/chunjun-core/src/main/java/com/dtstack/chunjun/Main.java
@@ -211,6 +211,7 @@ private static void exeSyncJob(
         if (transformer) {
             dataStream = syncStreamToTable(tableEnv, config, dataStreamSource);
         } else {
+            env.disableOperatorChaining();
             dataStream = dataStreamSource;
         }
 
@@ -223,7 +224,7 @@ private static void exeSyncJob(
         if (speed.getWriterChannel() > 0) {
             dataStreamSink.setParallelism(speed.getWriterChannel());
         }
-        // env.disableOperatorChaining();
+
         JobExecutionResult result = env.execute(options.getJobName());
         if (env instanceof MyLocalStreamEnvironment) {
             PrintUtil.printResult(result.getAllAccumulatorResults());