lamber-ken opened a new pull request #7362: [FLINK-11218][runtime] fix the default restart stragegy delay value URL: https://github.com/apache/flink/pull/7362 ## What is the purpose of the change *fix the default restart stragegy delay value* ## Brief change log from 1.6.x, the default restart stragegy delay value is 0, this pr modify the value to 10000L. it will endless loop when a operator always throw error, it exhausts the CPU limit and MEM limit. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no) - The serializers: (no) - The runtime per-record code paths (performance sensitive): (no) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (yes) - The S3 file system connector: (no) ## Documentation - Does this pull request introduce a new feature? (no) - If yes, how is the feature documented? (no) ## reproducible example ``` public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.enableCheckpointing(5000); DataStreamSource<String> source = env.addSource(new SourceFunction<String>() { @Override public void run(SourceContext<String> ctx) throws Exception { for (int i = 0; i < 100000000; i++) { Thread.sleep(100); ctx.collect("data " + i); } } @Override public void cancel() { } }); source.addSink(new RichSinkFunction<String>() { @Override public void open(Configuration parameters) throws Exception { System.out.println(1 / 0); } @Override public void invoke(String value, Context context) throws Exception { } }); env.execute(); } ```
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
