fix ut

apache · Oct 29, 2024 · 545b7a2 · 545b7a2
1 parent e9adf4a
commit 545b7a2
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git 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/...on-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java b/...on-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-common/src/main/java/org/apache/paimon/flink/action/ResetConsumerAction.java b/...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/...-flink-common/src/main/java/org/apache/paimon/flink/procedure/ResetConsumerProcedure.java b/...-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/...-spark-common/src/main/java/org/apache/paimon/spark/procedure/ResetConsumerProcedure.java b/...-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 =
-Original file line number
+Diff line change
@@ Expand Up / @@ -54,7 +54,7 @@ ALTER TABLE my_table SET TBLPROPERTIES ( @@
         );
     ```
-    ## Removing Table Comment
+    ## Removing Table Comment
     The following SQL removes table comment.
@@ Expand Down @@