This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch release-0.5
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
from 8e0c85305 [flink][mysql-cdc] Introduce TypeMapping to specify data
type mapping rules (#1838)
add 936cb022b [flink] Introduce FlinkGenericCatalog (#1857)
add c5febed8d [hotfix] Reject table without connector key for
FlinkGenericCatalog
add b51da2707 [flink] auto create new tag for flink savepoint. (#1741)
add e06c3429d [doc] Minor document optimization (#1864)
No new revisions were added by this update.
Summary of changes:
docs/content/concepts/primary-key-table.md | 2 +
docs/content/engines/flink.md | 35 ++
docs/content/engines/spark3.md | 3 +
docs/content/how-to/creating-catalogs.md | 4 +
docs/content/maintenance/manage-tags.md | 34 +-
.../generated/flink_connector_configuration.html | 6 +
.../shortcodes/generated/mysql_sync_database.html | 2 +-
.../shortcodes/generated/mysql_sync_table.html | 2 +-
.../paimon/table/AbstractFileStoreTable.java | 3 +-
.../java/org/apache/paimon/table/DataTable.java | 3 +
.../apache/paimon/table/system/AuditLogTable.java | 6 +
.../apache/paimon/table/system/BucketsTable.java | 6 +
.../org/apache/paimon/utils/SnapshotManager.java | 39 ++
.../java/org/apache/paimon/flink/FlinkCatalog.java | 15 +-
.../apache/paimon/flink/FlinkConnectorOptions.java | 7 +
.../apache/paimon/flink/FlinkGenericCatalog.java | 401 +++++++++++++++++++++
.../paimon/flink/FlinkGenericCatalogFactory.java | 105 ++++++
.../paimon/flink/FlinkGenericTableFactory.java | 79 ++++
.../sink/AutoTagForSavepointCommitterOperator.java | 247 +++++++++++++
.../paimon/flink/sink/CommitterOperator.java | 8 +-
.../org/apache/paimon/flink/sink/FlinkSink.java | 20 +-
.../org.apache.flink.table.factories.Factory | 1 +
.../org/apache/paimon/flink/FlinkCatalogTest.java | 7 +-
.../AutoTagForSavepointCommitterOperatorTest.java | 180 +++++++++
.../paimon/flink/sink/CommitterOperatorTest.java | 97 ++---
paimon-hive/paimon-hive-connector-common/pom.xml | 14 +
.../paimon/hive/FlinkGenericCatalogITCase.java | 120 ++++++
27 files changed, 1381 insertions(+), 65 deletions(-)
create mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkGenericCatalog.java
create mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkGenericCatalogFactory.java
create mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkGenericTableFactory.java
create mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AutoTagForSavepointCommitterOperator.java
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/AutoTagForSavepointCommitterOperatorTest.java
create mode 100644
paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/FlinkGenericCatalogITCase.java
