Details
-
Improvement
-
Status: Resolved
-
P4
-
Resolution: Fixed
-
None
-
None
Description
The INFO output in UnboundedSourceWrapper for the parallel instances of the sources is zero-based which is misleading:
18:54:04 INFO: Unbounded Flink Source 15/16 is reading from sources
The first number is the subtask index which starts with zero. This should be changed to start with 1 and go up till N.
Attachments
Issue Links
- links to