Versions Compared

Old Version 23

changes.mady.by.user Dong Lin

Saved on

compared with

New Version 24

changes.mady.by.user Dong Lin

Saved on

Key

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

...

The proposed change might be negative impact user experience in the following scenario:

If a user writes a Flink SQL program with a temporal join in processing time that does not use the TemporalFunctionJoin syntax, and the source on the Build Side employs a bounded or unbounded phase (e.g., HybridSource, MySQL CDC) but has not been updated to overwrite SourceReader#delegateWatermarkPeriodicEmit as specified in this FLIP, it may lead to compatibility issues. In such cases, the user may prefer the job to fail fast rather than producing results where the probe-side records fail to join with the records from the bounded phase of the build-side source.

  • User writes a Flink SQL program with a temporal join in processing time that does not use the TemporalFunctionJoin syntax,
  • The source on the Build Side employs a bounded + unbounded phase internally (e.g., HybridSource, MySQL CDC) but has not been updated to overwrite SourceReader#delegateWatermarkPeriodicEmit as specified in this FLIP
  • User prefers to have the job fail fast rather than producing results where the probe-side records fail to join with the records from the bounded phase of the build-side source.

...