This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


    from fefbaf60c7 [core] support format table for json (#5306)
     add caa2730b4c [flink] make tableConf valid for database compaction job 
(#5287)

No new revisions were added by this update.

Summary of changes:
 .../paimon/flink/action/CompactDatabaseAction.java |  1 +
 .../flink/compact/MultiAwareBucketTableScan.java   | 11 +++++--
 .../paimon/flink/compact/MultiTableScanBase.java   |  9 ++++--
 .../flink/compact/MultiUnawareBucketTableScan.java | 11 +++++--
 ...pendOnlyMultiTableCompactionWorkerOperator.java |  2 +-
 .../sink/MultiTablesStoreCompactOperator.java      |  1 +
 .../paimon/flink/sink/PrepareCommitOperator.java   |  2 +-
 .../CombinedTableCompactorSourceBuilder.java       | 12 ++++++++
 .../source/operator/CombinedAwareBatchSource.java  | 16 ++++++++--
 .../operator/CombinedAwareStreamingSource.java     |  9 +++++-
 .../operator/CombinedUnawareBatchSource.java       | 15 ++++++++--
 .../operator/CombinedUnawareStreamingSource.java   |  9 +++++-
 .../flink/action/CompactDatabaseActionITCase.java  | 35 ++++++++++++++++------
 13 files changed, 108 insertions(+), 25 deletions(-)

Reply via email to