You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/09/21 19:22:00 UTC

[jira] [Commented] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

    [ 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)