chenxinwei commented on code in PR #4893:
URL: https://github.com/apache/paimon/pull/4893#discussion_r1928080693
##########
docs/content/flink/procedures.md:
##########
@@ -388,6 +388,31 @@ All available procedures are listed below.
</td>
<td>CALL sys.reset_consumer(`table` => 'default.T', consumer_id =>
'myid', next_snapshot_id => cast(10 as bigint))</td>
</tr>
+ <tr>
+ <td>clear_consumers</td>
+ <td>
+ -- Use named argument<br/>
+ CALL [catalog.]sys.clear_consumers(`table` => 'identifier',
including_consumers => 'includingConsumers', excluding_consumers =>
'excludingConsumers') <br/><br/>
Review Comment:
@xuzifu666
Thanks for your suggestion.But I have no idea how to extend reset_consumer,
It seems that reset_consumer itself is not intended for bulk scenarios. Should
an exception be thrown when the user passes parameters in this way?
CALL sys.reset_consumer(
`table` => 'test_table',
next_snapshot_id => 'cast(10 as bigint)',
includingConsumers=> 'myid.+',
excludingConsumers=> '',
);
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@paimon.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
