Hey, I just wanted to ask about one thing about timestamps. So, currently If I have a KeyedBroadcastProcess function followed by Temporal Table Join, it works like a charm. But, say I want to delay emitting some of the results due to any reason. So If I *registerProcessingTimeTimer* and any elements are emitted in *onTimer* call then the timestamps are erased, meaning that I will simply get : *Caused by: java.lang.RuntimeException: Rowtime timestamp is null. Please make sure that a proper TimestampAssigner is defined and the stream environment uses the EventTime time characteristic.* * at DataStreamSourceConversion$10.processElement(Unknown Source)* * at org.apache.flink.table.runtime.CRowOutputProcessRunner.processElement(CRowOutputProcessRunner.scala:70)* * at org.apache.flink.streaming.api.operators.ProcessOperator.processElement(ProcessOperator.java:66)* * at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:579)* * ... 23 more*
Is that the expected behavior? I haven't seen it described anywhere before and I wasn't able to find any docs specifying this. Thanks in advance, Best Regards, Dom.
