[jira] [Created] (FLINK-36180) Flink pulsar connector when restoring from the state, the unconsumed messages of the first batch will be lost

Wenbing Shen created FLINK-36180: Summary: Flink pulsar connector when restoring from the state, the unconsumed messages of the first batch will be lost Key: FLINK-36180 URL: https://issues.apache.org/jira/browse/

[jira] [Updated] (FLINK-35328) AutoScale supports setting the maximum floating parallelism by the number of Pulsar partitions

[ https://issues.apache.org/jira/browse/FLINK-35328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenbing Shen updated FLINK-35328: - Description: AutoScale supports setting the maximum floating parallelism by the number of Pulsar

[jira] [Created] (FLINK-35328) AutoScale supports setting the maximum floating parallelism by the number of Pulsar partitions

Wenbing Shen created FLINK-35328: Summary: AutoScale supports setting the maximum floating parallelism by the number of Pulsar partitions Key: FLINK-35328 URL: https://issues.apache.org/jira/browse/FLINK-35328

[jira] [Closed] (FLINK-35196) bouncycastle class not found for flink pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-35196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenbing Shen closed FLINK-35196. Resolution: Not A Problem > bouncycastle class not found for flink pulsar connector >

[jira] [Created] (FLINK-35196) bouncycastle class not found for flink pulsar connector

Wenbing Shen created FLINK-35196: Summary: bouncycastle class not found for flink pulsar connector Key: FLINK-35196 URL: https://issues.apache.org/jira/browse/FLINK-35196 Project: Flink Issue

[jira] [Created] (FLINK-29207) Pulsar message eventTime may be incorrectly set to a negative number

Wenbing Shen created FLINK-29207: Summary: Pulsar message eventTime may be incorrectly set to a negative number Key: FLINK-29207 URL: https://issues.apache.org/jira/browse/FLINK-29207 Project: Flink