From 6bcf65722690dc5fc0ea914315497d37d8e9d894 Mon Sep 17 00:00:00 2001 From: LsomeYeah Date: Wed, 19 Feb 2025 11:20:48 +0800 Subject: [PATCH] [iceberg][fix] make 'iceberg_options' required in procedure --- .../paimon/flink/procedure/MigrateIcebergTableProcedure.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MigrateIcebergTableProcedure.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MigrateIcebergTableProcedure.java index f43d29ed4f17..c422d8640eb1 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MigrateIcebergTableProcedure.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MigrateIcebergTableProcedure.java @@ -44,10 +44,7 @@ public String identifier() { @ProcedureHint( argument = { @ArgumentHint(name = "source_table", type = @DataTypeHint("STRING")), - @ArgumentHint( - name = "iceberg_options", - type = @DataTypeHint("STRING"), - isOptional = true), + @ArgumentHint(name = "iceberg_options", type = @DataTypeHint("STRING")), @ArgumentHint(name = "options", type = @DataTypeHint("STRING"), isOptional = true), @ArgumentHint( name = "parallelism",