Versions Compared

Key

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

...

For CatalogBaseTable, we use CatalogPropertiesUtil to serialize/deserialize it , it's the tools that Flink already provides.

The complexity of serialization Catalog is high, and we need to introduce a new serialization mechanism to achieve this, which is described in a separate section.For Catalog:



Runtime

Provide JM side, job status change hook mechanism.

...