[
https://issues.apache.org/jira/browse/FLINK-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199614#comment-17199614
]
Stephan Ewen commented on FLINK-18044:
--------------------------------------
[~becket_qin] It migh be desirable to expose as little as possible information
about this.
In the presence of changing parallelism (maybe in the future even locally
without full checkpoints) these values can be a problem.
So going with "minimal necessary knowledge" is often a good approach.
> Add the subtask index information to the SourceReaderContext.
> -------------------------------------------------------------
>
> Key: FLINK-18044
> URL: https://issues.apache.org/jira/browse/FLINK-18044
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Common
> Reporter: Jiangjie Qin
> Priority: Major
> Labels: pull-request-available
>
> It is useful for the `SourceReader` to retrieve its subtask id. For example,
> Kafka readers can create a consumer with proper client id.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
