This is an automated email from the ASF dual-hosted git repository.
roman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new c60a31f [FLINK-21581][runtime] Mark RuntimeContext.getJobId
@PublicEvolving
c60a31f is described below
commit c60a31fd70dc985ab943c105f24b941ff42ab082
Author: Roman Khachatryan <[email protected]>
AuthorDate: Wed Mar 3 10:52:15 2021 +0100
[FLINK-21581][runtime] Mark RuntimeContext.getJobId @PublicEvolving
The JobID added in FLINK-21570 is
1) a breaking change
2) may be changed after removing DataSet API
---
.../main/java/org/apache/flink/api/common/functions/RuntimeContext.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
b/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
index 11c9198..89debd0 100644
---
a/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
+++
b/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
@@ -63,6 +63,7 @@ public interface RuntimeContext {
* standalone collection executor). Note that Job ID can change in
particular upon manual
* restart. The returned ID should NOT be used for any job management
tasks.
*/
+ @PublicEvolving
Optional<JobID> getJobId();
/**
