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)

Reply via email to