Versions Compared

Old Version 19

changes.mady.by.user luoyuxia

Saved on

compared with

New Version 20

changes.mady.by.user luoyuxia

Saved on

Key

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

...

3:Check the atomicity is enabled, it requires both the option table.rtas-ctas.atomicity-enabled is set to true and the corresponding table sink implementement implements SupportsStaging.

   a: if atomic is enabled, it expects the atomicity to be guaranteed by external connector implementation. The Flink will generate an insert job according to the table subquery in REPLACE TABLE AS statment, and call method StagedTable#begain  before the insert job start, call method StagedTable#commit  after the job finish, call method StagedTable#abort  if the job fail or canceled.

...