Versions Compared

Old Version 13

changes.mady.by.user Mang Zhang

Saved on

compared with

New Version 14

changes.mady.by.user Mang Zhang

Saved on

Key

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

...

Atomicity & Data Visibility

Atomicity

CTAS does not provide strict atomicity, we will create the table first, the final atomicity is determined by the cleanUp implementation of TableSink.

This requires runtime module support, like the description in the implementation of batch mode.

Data Visibility

Regarding data visibility, it is determined by the TableSink and runtime-mode:

Stream mode:

If the external storage system supports transactions or two-phase commit, then data visibility is related to the Checkpoint cycle,

otherwise, data is visible in real time, which is consistent with the current flink behavior.

Batch mode:








Public API Changes

Table Environment

...