This is an automated email from the ASF dual-hosted git repository.
tison pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 713b0b170bf [FLINK-28085][Connector/Pulsar] Close the pending Pulsar
transactions before closing pipeline (#21075)
add 8cb0297c2f0 [FLINK-29613][Connector/Pulsar] Fix wrong batch size
assertion. (#21069)
No new revisions were added by this update.
Summary of changes:
.../source/enumerator/cursor/MessageIdUtils.java | 24 ++++++++++++----------
.../cursor/start/MessageIdStartCursor.java | 10 ++++-----
.../cursor/stop/MessageIdStopCursor.java | 10 +++------
3 files changed, 21 insertions(+), 23 deletions(-)
