diff --git a/docs/content/flink/procedures.md b/docs/content/flink/procedures.md index a270b1cd6519..3fae9b40512f 100644 --- a/docs/content/flink/procedures.md +++ b/docs/content/flink/procedures.md @@ -263,7 +263,7 @@ All available procedures are listed below. -- for Flink 1.18

- CALL sys.expire_partitions('default.T', '1 d', 'yyyy-MM-dd', 'values-time')

+ CALL sys.expire_partitions('default.T', '1 d', 'yyyy-MM-dd', '$dt', 'values-time')

-- for Flink 1.19 and later

CALL sys.expire_partitions(`table` => 'default.T', expiration_time => '1 d', timestamp_formatter => 'yyyy-MM-dd', expire_strategy => 'values-time')
CALL sys.expire_partitions(`table` => 'default.T', expiration_time => '1 d', timestamp_formatter => 'yyyy-MM-dd HH:mm', timestamp_pattern => '$dt $hm', expire_strategy => 'values-time')

diff --git a/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java b/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java index 5e1acca3ada6..1db04aa1d392 100644 --- a/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java +++ b/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java @@ -74,7 +74,7 @@ public void testExpirePartitionsProcedure() throws Exception { sql("INSERT INTO T VALUES ('1', '2024-06-01')"); sql("INSERT INTO T VALUES ('2', '9024-06-01')"); assertThat(read(table)).containsExactlyInAnyOrder("1:2024-06-01", "2:9024-06-01"); - sql("CALL sys.expire_partitions('default.T', '1 d', 'yyyy-MM-dd', 'values-time')"); + sql("CALL sys.expire_partitions('default.T', '1 d', 'yyyy-MM-dd', '$dt', 'values-time')"); assertThat(read(table)).containsExactlyInAnyOrder("2:9024-06-01"); }