You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2019/01/29 15:11:00 UTC
[jira] [Closed] (BEAM-6533) UnboundedSourceWrapper source log
output should not be zero-based
[ https://issues.apache.org/jira/browse/BEAM-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Maximilian Michels closed BEAM-6533.
------------------------------------
Resolution: Fixed
Fixed with {{beb7abf09dc80406848dfc81e242ec25b7e6780e}}.
> 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)