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 10:09:00 UTC

[jira] [Created] (BEAM-6533) UnboundedSourceWrapper

Maximilian Michels created BEAM-6533:
----------------------------------------

             Summary: UnboundedSourceWrapper 
                 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
             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)