This is an automated email from the ASF dual-hosted git repository.
junhao pushed a change to branch release-0.8
in repository https://gitbox.apache.org/repos/asf/paimon.git
from cfcc72d7d [hive] Fix flink not synchronizing to hive metastore when
deleting table partitions using hive catalog (#3411)
new 948310d54 [core] Fix null Partition values to Predicate conversion
(#3421)
new c16cf29e5 [core] Unify Partition Predicate generation in
PartitionPredicate (#3427)
new b45b01cd3 [core] [bug] Fix Partition Predicate null values process.
(#3431)
new 947e93f68 [parquet] Pass conf to parquet writer (#3435)
new 69c895e9b [core] close files in CompactRewriter to avoid file leaks.
(#3409)
new fbfde859b [core] Fix raw convert fail for old storage ro table (#3438)
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/paimon/predicate/PredicateBuilder.java | 44 +--
.../paimon/utils/InternalRowPartitionComputer.java | 21 +-
.../utils/RowDataToObjectArrayConverter.java | 16 -
.../java/org/apache/paimon/AbstractFileStore.java | 1 +
.../apache/paimon/manifest/ManifestFileMeta.java | 4 +-
.../compact/ChangelogMergeTreeRewriter.java | 23 +-
.../compact/MergeTreeCompactRewriter.java | 32 +-
.../paimon/operation/FileStoreCommitImpl.java | 14 +-
.../paimon/partition/PartitionPredicate.java | 73 ++++-
.../table/source/MergeTreeSplitGenerator.java | 3 +-
.../table/source/snapshot/SnapshotReaderImpl.java | 27 +-
.../apache/paimon/utils/FileStorePathFactory.java | 6 +-
.../org/apache/paimon/io/DataFileTestUtils.java | 2 +-
.../mergetree/ChangelogMergeTreeRewriterTest.java | 336 +++++++++++++++++++++
.../operation/AppendOnlyFileStoreWriteTest.java | 97 ++++++
.../paimon/operation/FileStoreCommitTest.java | 7 +-
.../paimon/table/source/SplitGeneratorTest.java | 7 +
.../java/org/apache/paimon/flink/FlinkCatalog.java | 4 +-
.../paimon/flink/action/SortCompactAction.java | 11 +-
.../paimon/flink/action/TableActionBase.java | 3 +-
.../UnawareBucketCompactionTopoBuilder.java | 8 +-
.../flink/lookup/FileStoreLookupFunction.java | 24 +-
.../flink/source/CompactorSourceBuilder.java | 10 +-
.../parquet/writer/RowDataParquetBuilder.java | 22 +-
.../apache/paimon/hive/HiveMetastoreClient.java | 6 +-
.../paimon/hive/utils/HiveSplitGenerator.java | 14 +-
.../paimon/spark/PaimonPartitionManagement.scala | 4 +-
.../commands/DeleteFromPaimonTableCommand.scala | 4 +-
.../apache/paimon/spark/sources/StreamHelper.scala | 13 +-
29 files changed, 694 insertions(+), 142 deletions(-)
rename
paimon-core/src/main/java/org/apache/paimon/utils/RowDataPartitionComputer.java
=>
paimon-common/src/main/java/org/apache/paimon/utils/InternalRowPartitionComputer.java
(75%)
create mode 100644
paimon-core/src/test/java/org/apache/paimon/mergetree/ChangelogMergeTreeRewriterTest.java
