Versions Compared

Old Version 10

changes.mady.by.user luoyuxia

Saved on

compared with

New Version 11

changes.mady.by.user luoyuxia

Saved on

Key

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

...

    b: Otherwise, it expects the guarantee will be ensured to exteran connector implemteratomicity to be guaranteed by external connector implementation. The Flink will generate a insert job according to the table subquery in REPLACE TABLE AS statment, and call method #begainTransanction before TwoPhaseCommitCatalogTable#begainTransanction  before the insert job start, call method #commit after TwoPhaseCommitCatalogTable#commit  after the job finish, call method #abort if TwoPhaseCommitCatalogTable#abort  if the job fail or canceled.

...