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)