-
Type:
Improvement
-
Status: Closed
-
Priority:
Trivial
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 2.11.0
-
Component/s: runner-flink
-
Labels:None
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.
- links to