Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3487#discussion_r104896041
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
---
@@ -97,10 +97,16 @@ public int
Github user ifndef-SleePy commented on a diff in the pull request:
https://github.com/apache/flink/pull/3487#discussion_r104825967
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -85,6 +85,13 @@
int
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3487#discussion_r104703639
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
---
@@ -100,7 +100,12 @@ public int
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3487#discussion_r104703596
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -85,6 +85,13 @@
int getIndexOfThisSubtask();
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3487#discussion_r104703690
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java
---
@@ -125,6 +125,10 @@ public int
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3487#discussion_r104703506
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -85,6 +85,13 @@
int getIndexOfThisSubtask();
GitHub user ifndef-SleePy opened a pull request:
https://github.com/apache/flink/pull/3487
[FLINK-5980] Expose max-parallelism value in RuntimeContext.
Add new method named getMaxParallelismOfSubtasks in RuntimeContext.
You can merge this pull request into a Git repository by
