Skip to content

Commit 96bc396

Browse files
committed
Fix comments
Change-Id: Id3912c1c2c90a7beaf41fba1d9c35f162ad6d605
1 parent 727ba2c commit 96bc396

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

docs/content/flink/procedures.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -399,7 +399,7 @@ All available procedures are listed below.
399399
-- clear some consumers in the table (accept regular expression)<br/>
400400
CALL [catalog.]sys.clear_consumers('tableId', 'includingConsumers')<br/><br/>
401401
-- exclude some consumers (accept regular expression)<br/>
402-
CALL [catalog.]sys.clear_consumers('tableId', 'consumerIds', 'includingConsumers', 'excludingConsumers')
402+
CALL [catalog.]sys.clear_consumers('tableId', 'includingConsumers', 'excludingConsumers')
403403
</td>
404404
<td>
405405
To reset or delete consumer. Arguments:

paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/ClearConsumersProcedure.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@
4040
* CALL sys.clear_consumers('tableId', 'includingConsumers')
4141
*
4242
* -- exclude some consumers (accept regular expression)
43-
* CALL sys.clear_consumers('tableId', 'consumerIds', 'includingConsumers', 'excludingConsumers')
43+
* CALL sys.clear_consumers('tableId', 'includingConsumers', 'excludingConsumers')
4444
* </code></pre>
4545
*/
4646
public class ClearConsumersProcedure extends ProcedureBase {

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ClearConsumersProcedure.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@
4343
* CALL sys.clear_consumers('tableId', 'includingConsumers')
4444
*
4545
* -- exclude some consumers (accept regular expression)
46-
* CALL sys.clear_consumers('tableId', 'consumerIds', 'includingConsumers', 'excludingConsumers')
46+
* CALL sys.clear_consumers('tableId', 'includingConsumers', 'excludingConsumers')
4747
* </code></pre>
4848
*/
4949
public class ClearConsumersProcedure extends ProcedureBase {

paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/ClearConsumersProcedure.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@
4747
* CALL sys.clear_consumers('tableId', 'includingConsumers')
4848
*
4949
* -- exclude some consumers (accept regular expression)
50-
* CALL sys.clear_consumers('tableId', 'consumerIds', 'includingConsumers', 'excludingConsumers')
50+
* CALL sys.clear_consumers('tableId', 'includingConsumers', 'excludingConsumers')
5151
* </code></pre>
5252
*/
5353
public class ClearConsumersProcedure extends BaseProcedure {

0 commit comments

Comments
 (0)