Skip to content

Commit

Permalink
fixed
Browse files Browse the repository at this point in the history
  • Loading branch information
@sunxiaojian
sunxiaojian committed Apr 19, 2024
1 parent ed82705 commit 0534ff4
Show file tree
Hide file tree
Showing 7 changed files with 610 additions and 610 deletions.
2 changes: 1 addition & 1 deletion ...aimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/CdcActionITCaseBase.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -451,4 +451,4 @@ public T build() {
return createAction(clazz, args);
}
}
}
}
2 changes: 1 addition & 1 deletion ...est/java/org/apache/paimon/flink/action/cdc/kafka/KafkaDebeziumSyncTableActionITCase.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -147,4 +147,4 @@ public void testMessageWithNullValue() throws Exception {
rowType,
Collections.singletonList("id"));
}
}
}
98 changes: 49 additions & 49 deletions ...src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionITCase.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -108,10 +108,10 @@ private void testSchemaEvolutionImpl(
RowType rowType1 =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight"});

Expand All @@ -124,10 +124,10 @@ private void testSchemaEvolutionImpl(
RowType rowType2 =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight"});

Expand All @@ -149,11 +149,11 @@ private void testSchemaEvolutionImpl(
rowType1 =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight", "age"});
expected =
Expand All @@ -167,11 +167,11 @@ private void testSchemaEvolutionImpl(
rowType2 =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight", "address"});

Expand Down Expand Up @@ -211,10 +211,10 @@ protected void testTableAffixMultiTopic(String format) throws Exception {
"test_prefix_t1_test_suffix",
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight"}),
Collections.emptyList(),
Expand Down Expand Up @@ -260,10 +260,10 @@ protected void testTableAffixOneTopic(String format) throws Exception {
"test_prefix_t1_test_suffix",
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight"}),
Collections.emptyList(),
Expand Down Expand Up @@ -311,10 +311,10 @@ private void testTableAffixImpl(
RowType rowType1 =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight"});

Expand All @@ -327,10 +327,10 @@ private void testTableAffixImpl(
RowType rowType2 =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight"});

Expand All @@ -351,11 +351,11 @@ private void testTableAffixImpl(
rowType1 =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight", "address"});
if (format.equals("debezium")) {
Expand All @@ -376,11 +376,11 @@ private void testTableAffixImpl(
rowType2 =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight", "age"});
if (format.equals("debezium")) {
Expand Down Expand Up @@ -482,10 +482,10 @@ protected void testCaseInsensitive(String format) throws Exception {
RowType rowType =
RowType.of(
new DataType[] {
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
getDataType(format),
DataTypes.STRING(),
DataTypes.STRING(),
DataTypes.STRING()
},
new String[] {"id", "name", "description", "weight"});

Expand All @@ -505,4 +505,4 @@ private List<String> getPrimaryKey(String format) {
? Collections.emptyList()
: Collections.singletonList("id");
}
}
}
Loading

0 comments on commit 0534ff4

Please sign in to comment.