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.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 uses one of the following parameters?
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
