Versions Compared

Old Version 21

changes.mady.by.user Mang Zhang

Saved on

compared with

New Version 22

changes.mady.by.user Mang Zhang

Saved on

Key

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

...

Identification of atomic CTAS

Normally, in stream mode, we consider the job to be LONG RUNNING, and even if it fails, it needs to resume afterwards, so atomic CTAS semantics are usually not needed.

In addition, there are probably many flink jobs that already use At present, there may be a large number of flink jobs using non-atomic CTAS functions, especially Stream jobs, in order to ensure the consistency of flink behavior, and to give the user maximum flexibility, in time DynamicTableSink implements the SupportsStaging interface, users can still choose non-atomic implementation according to business needs.

...