Skip to content

Commit 13a6827

Browse files
committed
fix test
1 parent 4e2e7b1 commit 13a6827

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full-with-repsym.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ transform:
4949
partition-keys: product_name
5050
table-options: comment=app order
5151
description: project fields from source table
52-
converter-after-transform: SOFT_DELETE
52+
post-transform-converter: SOFT_DELETE
5353
- source-table: mydb.web_order_.*
5454
projection: CONCAT(id, order_id) as uniq_id, *
5555
filter: uniq_id > 10

flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ transform:
4747
partition-keys: product_name
4848
table-options: comment=app order
4949
description: project fields from source table
50-
converter-after-transform: SOFT_DELETE
50+
post-transform-converter: SOFT_DELETE
5151
- source-table: mydb.web_order_.*
5252
projection: CONCAT(id, order_id) as uniq_id, *
5353
filter: uniq_id > 10

0 commit comments

Comments
 (0)