Github user WangCHX commented on a diff in the pull request:
https://github.com/apache/flink/pull/1223#discussion_r41349100
--- Diff: docs/apis/programming_guide.md ---
@@ -1992,6 +1992,8 @@ With the closure cleaner disabled, it might happen
that an anonymous user functi
Github user WangCHX commented on a diff in the pull request:
https://github.com/apache/flink/pull/1223#discussion_r41349717
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -199,6 +199,31 @@ public int getNumberOfExecutionRetries
Github user WangCHX commented on a diff in the pull request:
https://github.com/apache/flink/pull/1223#discussion_r41349716
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -199,6 +199,31 @@ public int getNumberOfExecutionRetries
Github user WangCHX commented on a diff in the pull request:
https://github.com/apache/flink/pull/1223#discussion_r41349706
--- Diff: flink-core/src/main/java/org/apache/flink/api/common/Plan.java ---
@@ -303,6 +303,13 @@ public int getNumberOfExecutionRetries
Github user WangCHX commented on the pull request:
https://github.com/apache/flink/pull/1223#issuecomment-145740461
Thank you very much.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user WangCHX commented on the pull request:
https://github.com/apache/flink/pull/1223#issuecomment-145733727
Thank you. Sure. I will do it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
GitHub user WangCHX opened a pull request:
https://github.com/apache/flink/pull/1223
[FLINK-2066][core] Add delay between execution retires configuration â¦
â¦at job level
want to solve FLINK-2066. Based on when there has number of retries, there
must has retry delay
