This is an automated email from the ASF dual-hosted git repository.
yuzelin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 617b8b35b0 [core] Introduce creation methods to Blob (#6320)
add b5f2d0dade [flink] Support starting Flink job for all actions (#6201)
No new revisions were added by this update.
Summary of changes:
docs/content/flink/action-jars.md | 18 +++
paimon-flink/paimon-flink-common/pom.xml | 14 ++
.../org/apache/paimon/flink/action/ActionBase.java | 90 ++++++++++-
.../apache/paimon/flink/action/ActionFactory.java | 34 +++-
.../paimon/flink/action/ClearConsumerAction.java | 4 +-
.../apache/paimon/flink/action/CompactAction.java | 10 +-
.../paimon/flink/action/CreateBranchAction.java | 4 +-
.../paimon/flink/action/CreateTagAction.java | 4 +-
.../flink/action/CreateTagFromTimestampAction.java | 4 +-
.../flink/action/CreateTagFromWatermarkAction.java | 12 +-
.../paimon/flink/action/DeleteBranchAction.java | 4 +-
.../paimon/flink/action/DeleteTagAction.java | 4 +-
.../paimon/flink/action/DropPartitionAction.java | 7 +-
.../flink/action/ExpireChangelogsAction.java | 8 +-
.../flink/action/ExpirePartitionsAction.java | 21 +--
.../paimon/flink/action/ExpireSnapshotsAction.java | 14 +-
.../paimon/flink/action/ExpireTagsAction.java | 9 +-
.../paimon/flink/action/FastForwardAction.java | 4 +-
.../apache/paimon/flink/action/LocalAction.java} | 11 +-
.../flink/action/MarkPartitionDoneAction.java | 4 +-
.../paimon/flink/action/MigrateDatabaseAction.java | 12 +-
.../flink/action/MigrateIcebergTableAction.java | 12 +-
.../paimon/flink/action/MigrateTableAction.java | 14 +-
.../paimon/flink/action/RenameTagAction.java | 4 +-
.../apache/paimon/flink/action/RepairAction.java | 8 +-
.../paimon/flink/action/ReplaceTagAction.java | 4 +-
.../paimon/flink/action/ResetConsumerAction.java | 4 +-
.../paimon/flink/action/RollbackToAction.java | 4 +-
.../flink/action/RollbackToTimestampAction.java | 4 +-
.../paimon/flink/action/ActionJobCoverageTest.java | 180 +++++++++++++++++++++
.../paimon/flink/action/BranchActionITCase.java | 19 ++-
.../paimon/flink/action/ConsumerActionITCase.java | 39 ++++-
.../action/CreateTagFromTimestampActionITTest.java | 12 +-
.../action/CreateTagFromWatermarkActionITTest.java | 29 ++--
.../flink/action/DropPartitionActionITCase.java | 8 +-
.../flink/action/ExpirePartitionsActionITCase.java | 11 +-
.../paimon/flink/action/ExpireTagsActionTest.java | 26 ++-
.../action/MarkPartitionDoneActionITCase.java | 22 ++-
.../paimon/flink/action/ReplaceTagActionTest.java | 16 +-
.../flink/action/RollbackToActionITCase.java | 21 ++-
.../paimon/flink/action/TagActionITCase.java | 51 ++++--
.../procedure/ExpireChangelogsProcedureITCase.java | 15 +-
.../procedure/ExpireSnapshotsProcedureITCase.java | 23 ++-
.../procedure/MigrateDatabaseProcedureITCase.java | 7 +-
.../MigrateIcebergTableProcedureITCase.java | 22 ++-
.../procedure/MigrateTableProcedureITCase.java | 20 ++-
.../paimon/hive/procedure/RepairActionITCase.java | 9 +-
47 files changed, 667 insertions(+), 209 deletions(-)
copy
paimon-flink/paimon-flink-common/src/{test/java/org/apache/paimon/flink/action/RemoveOrphanFilesActionITCase.java
=> main/java/org/apache/paimon/flink/action/LocalAction.java} (76%)
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ActionJobCoverageTest.java
