This is an automated email from the ASF dual-hosted git repository.
biyan pushed a change to branch release-0.6
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
from 73fc2cc79 Revert "[hive] Improve hive database is exists yet
create/drop database (#2595)"
new 0db173f51 [core] Remove ConfigOptions toList (#2578)
new 454fd9e75 [core] Fix nested-update to nested_update
new e589ddd6a [test] Fix unstable test of parallelism set error. (#2626)
new 7d0e05055 [flink] throws exception if there is a SinkMaterializer
before Paimon sink (#2592)
new 69663432e [hotfix] Fix paimon-spark-3.2 pom (#2603)
new 5c04b45a8 [spark] Supports CTAS for different versions (#2591)
new 5534b45bf [spark] Fix call procedure compatibility with spark3.2
(#2707)
The 7 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:
docs/content/concepts/primary-key-table.md | 126 +++++++++-
.../org/apache/paimon/options/ConfigOption.java | 19 +-
.../org/apache/paimon/options/ConfigOptions.java | 54 +---
.../java/org/apache/paimon/options/Options.java | 6 +-
.../org/apache/paimon/options/OptionsUtils.java | 14 +-
.../compact/aggregate/FieldNestedUpdateAgg.java | 91 +++++++
.../configuration/ConfigOptionsDocGenerator.java | 39 +--
.../ConfigOptionsDocGeneratorTest.java | 28 ---
.../org/apache/paimon/flink/sink/FlinkSink.java | 33 +++
.../apache/paimon/flink/PartialUpdateITCase.java | 20 ++
.../apache/paimon/flink/PreAggregationITCase.java | 274 +++++++++++++++++++++
.../flink/PrimaryKeyFileStoreTableITCase.java | 6 +-
.../paimon/flink/sink/CompactorSinkITCase.java | 2 +-
paimon-spark/paimon-spark-3.2/pom.xml | 66 ++++-
.../shim/PaimonCreateTableAsSelectStrategy.scala | 30 +--
.../paimon/spark/sql/CompactProcedureTest.scala | 7 +-
.../org/apache/paimon/spark/sql/DDLTest.scala | 7 +-
paimon-spark/paimon-spark-3.3/pom.xml | 7 +
.../org/apache/paimon/spark/sql/DDLTest.scala | 41 +--
paimon-spark/paimon-spark-3.4/pom.xml | 41 +--
.../shim/PaimonCreateTableAsSelectStrategy.scala | 12 +-
.../org/apache/paimon/spark/sql/DDLTest.scala | 7 +-
.../org/apache/paimon/spark/sql/DDLTest.scala | 7 +-
paimon-spark/paimon-spark-common/pom.xml | 14 ++
.../extensions/PaimonSqlExtensionsAstBuilder.scala | 23 +-
...reTest.scala => CompactProcedureTestBase.scala} | 2 +-
.../org/apache/paimon/spark/sql/DDLTest.scala | 59 -----
.../org/apache/paimon/spark/sql/DDLTestBase.scala | 61 +++++
28 files changed, 770 insertions(+), 326 deletions(-)
create mode 100644
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java
copy paimon-spark/{paimon-spark-3.3 =>
paimon-spark-3.2}/src/main/scala/org/apache/spark/sql/execution/shim/PaimonCreateTableAsSelectStrategy.scala
(70%)
copy paimon-common/src/test/resources/codesplit/groups/expected/IfInWhile.txt
=>
paimon-spark/paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/CompactProcedureTest.scala
(83%)
copy paimon-common/src/test/resources/codesplit/groups/expected/IfInWhile.txt
=>
paimon-spark/paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
(91%)
copy paimon-spark/{paimon-spark-3.3 =>
paimon-spark-3.4}/src/main/scala/org/apache/spark/sql/execution/shim/PaimonCreateTableAsSelectStrategy.scala
(90%)
copy paimon-common/src/test/resources/codesplit/groups/expected/IfInWhile.txt
=>
paimon-spark/paimon-spark-3.4/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
(91%)
copy paimon-common/src/test/resources/codesplit/groups/expected/IfInWhile.txt
=>
paimon-spark/paimon-spark-3.5/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
(91%)
rename
paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/procedure/{CompactProcedureTest.scala
=> CompactProcedureTestBase.scala} (99%)
delete mode 100644
paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
create mode 100644
paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
