[
https://issues.apache.org/jira/browse/BEAM-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated BEAM-6533:
-------------------------------------
Summary: UnboundedSourceWrapper source log output should not be zero-based
(was: UnboundedSourceWrapper )
> UnboundedSourceWrapper source log output should not be zero-based
> -----------------------------------------------------------------
>
> Key: BEAM-6533
> URL: https://issues.apache.org/jira/browse/BEAM-6533
> Project: Beam
> Issue Type: Improvement
> Components: runner-flink
> Reporter: Maximilian Michels
> Assignee: Maximilian Michels
> Priority: Trivial
> Fix For: 2.11.0
>
>
> The INFO output in {{UnboundedSourceWrapper}} for the parallel instances of
> the sources is zero-based which is misleading:
> {noformat}
> 18:54:04 INFO: Unbounded Flink Source 15/16 is reading from sources
> {noformat}
> The first number is the subtask index which starts with zero. This should be
> changed to start with 1 and go up till N.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
