Skip to content

Commit b15a226

Browse files
Junbo wangwangjunbo
Junbo wang
and
wangjunbo
authored
[FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.2
This closes #3335 Co-authored-by: wangjunbo <wangjunbo@qiyi.com>
1 parent 241eb03 commit b15a226

File tree

4 files changed

+5
-1
lines changed

4 files changed

+5
-1
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ limitations under the License.
2929
<artifactId>flink-cdc-pipeline-connector-paimon</artifactId>
3030

3131
<properties>
32-
<paimon.version>0.7.0-incubating</paimon.version>
32+
<paimon.version>0.8.2</paimon.version>
3333
<hadoop.version>2.8.5</hadoop.version>
3434
<hive.version>2.3.9</hive.version>
3535
<mockito.version>3.4.6</mockito.version>

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java

+1
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,7 @@ private void applyCreateTable(CreateTableEvent event)
124124
builder.partitionKeys(schema.partitionKeys());
125125
}
126126
builder.options(tableOptions);
127+
builder.options(schema.options());
127128
catalog.createTable(
128129
new Identifier(event.tableId().getSchemaName(), event.tableId().getTableName()),
129130
builder.build(),

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

+2
Original file line numberDiff line numberDiff line change
@@ -137,6 +137,7 @@ private List<Event> createTestEvents() {
137137
.physicalColumn("col1", DataTypes.STRING())
138138
.physicalColumn("col2", DataTypes.STRING())
139139
.primaryKey("col1")
140+
.option("bucket", "1")
140141
.build();
141142
CreateTableEvent createTableEvent = new CreateTableEvent(table1, schema);
142143
testEvents.add(createTableEvent);
@@ -407,6 +408,7 @@ public void testSinkWithMultiTables(String metastore)
407408
.physicalColumn("col1", DataTypes.STRING())
408409
.physicalColumn("col2", DataTypes.STRING())
409410
.primaryKey("col1")
411+
.option("bucket", "1")
410412
.build();
411413
CreateTableEvent createTableEvent = new CreateTableEvent(table2, schema);
412414
testEvents.add(createTableEvent);

pom.xml

+1
Original file line numberDiff line numberDiff line change
@@ -430,6 +430,7 @@ limitations under the License.
430430
<exclude>**/.*/**</exclude>
431431
<!-- Generated content -->
432432
<exclude>**/target/**</exclude>
433+
<exclude>**/*.log</exclude>
433434
<!-- Build files -->
434435
<exclude>**/*.iml</exclude>
435436
<!-- Docs -->

0 commit comments

Comments
 (0)