WencongLiu commented on code in PR #23905:
URL: https://github.com/apache/flink/pull/23905#discussion_r1440108007
##########
flink-core/src/main/java/org/apache/flink/api/connector/sink2/InitContext.java:
##########
@@ -35,16 +40,37 @@ public interface InitContext {
*/
long INITIAL_CHECKPOINT_ID = 1;
- /** @return The id of task where the committer is running. */
+ /**
+ * Get the id of task where the committer is running.
+ *
+ * @deprecated This method is deprecated since Flink 1.19. All metadata
about the task should be
+ * provided uniformly by {@link #getTaskInfo()}.
+ * @see <a
+ *
href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-382%3A+Unify+the+Provision+of+Diverse+Metadata+for+Context-like+APIs";>
+ * FLIP-382: Unify the Provision of Diverse Metadata for Context-like
APIs </a>
+ */
int getSubtaskId();
Review Comment:
I have annotated these deprecated methods by `@Deprecated` in the
`InitContext`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
