Correct incorrect code comments

Change-Id: I9e6abe5e52c5c35b263e0a709ceb7c00bf3f8a30
apache · Jan 13, 2025 · a275241 · a275241
1 parent 721f723
commit a275241
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...n-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/ClearConsumersProcedure.java b/...n-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/ClearConsumersProcedure.java
@@ -41,7 +41,7 @@
  *  CALL sys.clear_consumers('tableId', 'consumerIds') or CALL sys.clear_consumers('tableId', 'consumerIds', false)
  *
  *  -- clear all consumers in the table
- *  CALL sys.clear_unspecified_consumers('tableId')
+ *  CALL sys.clear_consumers('tableId')
  * </code></pre>
  */
 public class ClearConsumersProcedure extends ProcedureBase {

diff --git a/...flink-common/src/main/java/org/apache/paimon/flink/procedure/ClearConsumersProcedure.java b/...flink-common/src/main/java/org/apache/paimon/flink/procedure/ClearConsumersProcedure.java
@@ -44,7 +44,7 @@
  *  CALL sys.clear_consumers('tableId', 'consumerIds') or CALL sys.clear_consumers('tableId', 'consumerIds', false)
  *
  *  -- clear all consumers in the table
- *  CALL sys.clear_unspecified_consumers('tableId')
+ *  CALL sys.clear_consumers('tableId')
  * </code></pre>
  */
 public class ClearConsumersProcedure extends ProcedureBase {

diff --git a/...spark-common/src/main/java/org/apache/paimon/spark/procedure/ClearConsumersProcedure.java b/...spark-common/src/main/java/org/apache/paimon/spark/procedure/ClearConsumersProcedure.java
@@ -48,7 +48,7 @@
  *  CALL sys.clear_consumers('tableId', 'consumerIds') or CALL sys.clear_consumers('tableId', 'consumerIds', false)
  *
  *  -- clear all consumers in the table
- *  CALL sys.clear_unspecified_consumers('tableId')
+ *  CALL sys.clear_consumers('tableId')
  * </code></pre>
  */
 public class ClearConsumersProcedure extends BaseProcedure {