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

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.15.2
• Fix Version/s: 1.16.0, 1.15.3
• Component/s: Connectors / Pulsar
• Labels: pull-request-available
• Assignee: Wenbing Shen
• Reporter: Wenbing Shen
• Created: 06/Sep/22 09:26
• Updated: 09/Sep/22 10:53
• Resolved: 09/Sep/22 10:52

Description

We'd better judge that the timestamp is greater than 0, we should skip setting eventTime when timestamp less than or equal to 0, otherwise the pulsar client will throw an exception.

Issue Links

• duplicates: FLINK-27736 Pulsar sink catch watermark error
• is duplicated by: FLINK-28506 Pulsar sink don't support zero timestamp which may be provided by flink
• links to: GitHub Pull Request #20765
• links to: GitHub Pull Request #20798
• links to: GitHub Pull Request #20799