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 Issue Type: Bug Components: Connectors / Pulsar Affects Versions: 1.15.2 Reporter: Wenbing Shen Attachments: image-2022-09-06-17-20-27-220.png, image-2022-09-06-17-21-46-923.png
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. !image-2022-09-06-17-21-46-923.png! !image-2022-09-06-17-20-27-220.png! -- This message was sent by Atlassian Jira (v8.20.10#820010)