From 545b7a2b72b7e7b4be64ef0c73792f9aaf580618 Mon Sep 17 00:00:00 2001 From: xuyu <11161569@vivo.com> Date: Tue, 29 Oct 2024 12:01:30 +0800 Subject: [PATCH] fix ut --- docs/content/spark/sql-alter.md | 2 +- .../apache/paimon/flink/procedure/ResetConsumerProcedure.java | 2 +- .../org/apache/paimon/flink/action/ResetConsumerAction.java | 2 +- .../apache/paimon/flink/procedure/ResetConsumerProcedure.java | 2 +- .../apache/paimon/spark/procedure/ResetConsumerProcedure.java | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/docs/content/spark/sql-alter.md b/docs/content/spark/sql-alter.md index b0d2646516064..712de74459af9 100644 --- a/docs/content/spark/sql-alter.md +++ b/docs/content/spark/sql-alter.md @@ -54,7 +54,7 @@ ALTER TABLE my_table SET TBLPROPERTIES ( ); ``` -## Removing Table Comment +## Removing Table Comment The following SQL removes table comment. diff --git a/paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java b/paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java index 18e4717650e45..3153e4f803254 100644 --- a/paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java +++ b/paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java @@ -57,7 +57,7 @@ public String[] call( throw new SnapshotNotExistException( String.format( "The specified snapshot id %s should be smaller than the latest snapshot id %s.", - latestSnapshotId)); + nextSnapshotId, latestSnapshotId)); } ConsumerManager consumerManager = diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ResetConsumerAction.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ResetConsumerAction.java index 397707936db96..4153b3b0c5f8c 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ResetConsumerAction.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ResetConsumerAction.java @@ -59,7 +59,7 @@ public void run() throws Exception { throw new SnapshotNotExistException( String.format( "The specified snapshot id %s should be smaller than the latest snapshot id %s.", - latestSnapshotId)); + nextSnapshotId, latestSnapshotId)); } ConsumerManager consumerManager = diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java index dd22ef9c46fe9..893a36703bc61 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java @@ -71,7 +71,7 @@ public String[] call( throw new SnapshotNotExistException( String.format( "The specified snapshot id %s should be smaller than the latest snapshot id %s.", - latestSnapshotId)); + nextSnapshotId, latestSnapshotId)); } ConsumerManager consumerManager = diff --git a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/ResetConsumerProcedure.java b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/ResetConsumerProcedure.java index 8ea2348aecd25..5cad4822d4b39 100644 --- a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/ResetConsumerProcedure.java +++ b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/ResetConsumerProcedure.java @@ -92,7 +92,7 @@ public InternalRow[] call(InternalRow args) { throw new SnapshotNotExistException( String.format( "The specified snapshot id %s should be smaller than the latest snapshot id %s.", - latestSnapshotId)); + nextSnapshotId, latestSnapshotId)); } ConsumerManager consumerManager =