[FLINK-29207][pulsar][BP-1.16] Fix Pulsar message eventTime may be in…

…correctly set to a negative number (#20798)
apache · Sep 9, 2022 · 7750058 · 7750058
1 parent 1c65409
commit 7750058
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ctor-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java b/...ctor-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java
@@ -212,7 +212,7 @@ private TypedMessageBuilder<?> createMessageBuilder(
         } else {
             // Set default message timestamp if flink has provided one.
             Long timestamp = context.timestamp();
-            if (timestamp != null) {
+            if (timestamp != null && timestamp > 0L) {
                 builder.eventTime(timestamp);
             }
         }