We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 613b697 commit 53d6928Copy full SHA for 53d6928
chunjun-core/src/main/java/com/dtstack/chunjun/Main.java
@@ -211,6 +211,7 @@ private static void exeSyncJob(
211
if (transformer) {
212
dataStream = syncStreamToTable(tableEnv, config, dataStreamSource);
213
} else {
214
+ env.disableOperatorChaining();
215
dataStream = dataStreamSource;
216
}
217
@@ -223,7 +224,7 @@ private static void exeSyncJob(
223
224
if (speed.getWriterChannel() > 0) {
225
dataStreamSink.setParallelism(speed.getWriterChannel());
226
- // env.disableOperatorChaining();
227
+
228
JobExecutionResult result = env.execute(options.getJobName());
229
if (env instanceof MyLocalStreamEnvironment) {
230
PrintUtil.printResult(result.getAllAccumulatorResults());
0 commit comments