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.

For Catalog, we need Catalog to implement Serializable so that it can be serialized directly. 

The purpose of doing so is:





Runtime

Provide JM side, job status change hook mechanism.

...