cannot commit cursor where implement key_shared mode.

[gaozhangmin]

it was caused by wrong sub name. In key_shared mode. the subName will plus keyRange like 'flink_test[0, 32767]'

[syhily]

Could you please provide more detailed information on this issue. Such as the error stack or other information.

[gaozhangmin]

linked issue: #230 #248
2021-04-14 13:43:23,673 INFO org.apache.flink.streaming.connectors.pulsar.internal.PulsarMetadataReader [] - Cannot commit cursor since the topic TopicRange{topic=persistent://public/default/16p, key-range=SerializableRange{range=[32768, 65535]}} has been deleted during execution

[syhily]

OK, I'll dig into this issue.

linked issue: #230 #248
2021-04-14 13:43:23,673 INFO org.apache.flink.streaming.connectors.pulsar.internal.PulsarMetadataReader [] - Cannot commit cursor since the topic TopicRange{topic=persistent://public/default/16p, key-range=SerializableRange{range=[32768, 65535]}} has been deleted during execution