Yufan Sheng created FLINK-27399:
-----------------------------------
Summary: Pulsar connector didn't set start consuming position
correctly
Key: FLINK-27399
URL: https://issues.apache.org/jira/browse/FLINK-27399
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: 1.14.4, 1.15.0, 1.16.0
Reporter: Yufan Sheng
Fix For: 1.16.0, 1.14.5, 1.15.1
Pulsar connector didn't use the consuming position for the checkpoint. They
just commit the position to Pulsar after the checkpoint and start consuming
from it directly.
This causes the test could be failed in some situations. The start cursor would
be reset to the wrong position which causes the results didn't match the
desired records.
This issue blocks
# FLINK-23944
# FLINK-25884
# FLINK-26177
# FLINK-26237
# FLINK-26721
Although the test failure message could be various. They are truly sharing the
same cause.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
