Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Note source connectors have to implement watermark alignment of source split in order to use the watermark alignment feature since 1.17 according flip-217 [2]. If source connector does not implement flip-217, the task will run with an error, user could set `pipeline'pipeline.watermark-alignment.allow-unaligned-source-splits` to true splits'= 'true' to disable watermark alignment of source split, and watermark alignment will be working properly only when your number of splits equals to the parallelism of the source operator.

...