fix 任务失败重试

lijiangbo · lijiangbo · commit 78878c3dc308 · 2020-04-24T13:34:16.000+08:00
diff --git a/flinkx-core/src/main/java/com/dtstack/flinkx/Main.java b/flinkx-core/src/main/java/com/dtstack/flinkx/Main.java
@@ -145,6 +145,8 @@ private static void configRestartStrategy(StreamExecutionEnvironment env, DataTr
             } else {
                 env.setRestartStrategy(RestartStrategies.noRestart());
             }
+        } else {
+            env.setRestartStrategy(RestartStrategies.noRestart());
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -145,6 +145,8 @@ private static void configRestartStrategy(StreamExecutionEnvironment env, DataTr`
`145`	`145`	`} else {`
`146`	`146`	`env.setRestartStrategy(RestartStrategies.noRestart());`
`147`	`147`	`}`
	`148`	`+ } else {`
	`149`	`+ env.setRestartStrategy(RestartStrategies.noRestart());`
`148`	`150`	`}`
`149`	`151`	`}`
`150`	`152`