pulsar-flink icon indicating copy to clipboard operation
pulsar-flink copied to clipboard

[BUG] Set pulsar event time when it exceed zero.

Open syhily opened this issue 3 years ago • 1 comments

Describe the bug

A clear and concise description of what the bug is. DynamicPulsarSerializationSchema.java wrongly add even time when it was zero.

if (eventTime != null && eventTime >= 0) {

This is not allowed in Pulsar's TypedMessageBuilderImpl.java.

checkArgument(timestamp > 0, "Invalid timestamp : '%s'", timestamp);

syhily avatar Apr 16 '22 01:04 syhily

How to workaround this? Its fixed in latest snapshot, but not in stable release https://issues.apache.org/jira/browse/FLINK-28506

nikolasten avatar Sep 16 '22 15:09 nikolasten