This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new b15a226cc [FLINK-35391][cdc-connector][paimon] Bump dependency of
Paimon Pipeline connector to 0.8.2
b15a226cc is described below
commit b15a226ccdb485822a604c3bd441e6bb0a72a62a
Author: Junbo wang <[email protected]>
AuthorDate: Mon Jul 29 16:44:42 2024 +0800
[FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline
connector to 0.8.2
This closes #3335
Co-authored-by: wangjunbo <[email protected]>
---
.../flink-cdc-pipeline-connector-paimon/pom.xml | 2 +-
.../apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java | 1 +
.../apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java | 2 ++
pom.xml | 1 +
4 files changed, 5 insertions(+), 1 deletion(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml
index 2c80c8aa9..1bd7fe19c 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml
@@ -29,7 +29,7 @@ limitations under the License.
<artifactId>flink-cdc-pipeline-connector-paimon</artifactId>
<properties>
- <paimon.version>0.7.0-incubating</paimon.version>
+ <paimon.version>0.8.2</paimon.version>
<hadoop.version>2.8.5</hadoop.version>
<hive.version>2.3.9</hive.version>
<mockito.version>3.4.6</mockito.version>
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java
index f71e9da1a..b75950f5b 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java
@@ -124,6 +124,7 @@ public class PaimonMetadataApplier implements
MetadataApplier {
builder.partitionKeys(schema.partitionKeys());
}
builder.options(tableOptions);
+ builder.options(schema.options());
catalog.createTable(
new Identifier(event.tableId().getSchemaName(),
event.tableId().getTableName()),
builder.build(),
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java
index edc785e89..300fdc91a 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java
@@ -137,6 +137,7 @@ public class PaimonSinkITCase {
.physicalColumn("col1", DataTypes.STRING())
.physicalColumn("col2", DataTypes.STRING())
.primaryKey("col1")
+ .option("bucket", "1")
.build();
CreateTableEvent createTableEvent = new CreateTableEvent(table1,
schema);
testEvents.add(createTableEvent);
@@ -407,6 +408,7 @@ public class PaimonSinkITCase {
.physicalColumn("col1", DataTypes.STRING())
.physicalColumn("col2", DataTypes.STRING())
.primaryKey("col1")
+ .option("bucket", "1")
.build();
CreateTableEvent createTableEvent = new CreateTableEvent(table2,
schema);
testEvents.add(createTableEvent);
diff --git a/pom.xml b/pom.xml
index 6bec45bf7..4b01c18c6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -430,6 +430,7 @@ limitations under the License.
<exclude>**/.*/**</exclude>
<!-- Generated content -->
<exclude>**/target/**</exclude>
+ <exclude>**/*.log</exclude>
<!-- Build files -->
<exclude>**/*.iml</exclude>
<!-- Docs -->
