Skip to content

Commit b5fa8ce

Browse files
committed
fix
1 parent 16e2a45 commit b5fa8ce

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MigrateTableProcedure.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,10 @@ public String identifier() {
4747
argument = {
4848
@ArgumentHint(name = "connector", type = @DataTypeHint("STRING")),
4949
@ArgumentHint(name = "source_table", type = @DataTypeHint("STRING")),
50-
@ArgumentHint(name = "target_table", type = @DataTypeHint("STRING")),
50+
@ArgumentHint(
51+
name = "target_table",
52+
type = @DataTypeHint("STRING"),
53+
isOptional = true),
5154
@ArgumentHint(name = "options", type = @DataTypeHint("STRING"), isOptional = true),
5255
@ArgumentHint(
5356
name = "parallelism",

0 commit comments

Comments
 (0)