并行度 1

src/main/java/com/qucheng/game/data/oldsystem/ods/PitcherAgentCDC.java

@@ -66,7 +66,7 @@ public class PitcherAgentCDC {
         props.load(PitcherAgentCDC.class.getResourceAsStream(Env.isTest ? "/application.test.properties" : "/application.properties"));
 
         // 设置默认并行度
-        env.setParallelism(16);
+        env.setParallelism(1);
 
         // 任务失败后的重启策略
         // env.setRestartStrategy(RestartStrategies.noRestart());// 失败不重启