Hy guys. Following Flink Joining documentation, I ended up creating my joined_stream on two streams but I get this error:

Caused by: org.apache.flink.util.FlinkException: Long.MIN_VALUE timestamp: Elements used in interval stream joins need to have timestamps meaningful timestamps.

at <http://org.apache.flink.streaming.api.operators.co|org.apache.flink.streaming.api.operators.co>.IntervalJoinOperator.processElement(IntervalJoinOperator.java:227)

at <http://org.apache.flink.streaming.api.operators.co|org.apache.flink.streaming.api.operators.co>.IntervalJoinOperator.processElement1(IntervalJoinOperator.java:196)

at <http://org.apache.flink.streaming.runtime.io|org.apache.flink.streaming.runtime.io>.RecordProcessorUtils.lambda$getRecordProcessor1$1(RecordProcessorUtils.java:88)

at <http://org.apache.flink.streaming.runtime.io|org.apache.flink.streaming.runtime.io>.StreamTwoInputProcessorFactory$StreamTaskNetworkOutput.emitRecord(StreamTwoInputProcessorFactory.java:254)

at <http://org.apache.flink.streaming.runtime.io|org.apache.flink.streaming.runtime.io>.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:146)

at <http://org.apache.flink.streaming.runtime.io|org.apache.flink.streaming.runtime.io>.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:110)

at <http://org.apache.flink.streaming.runtime.io|org.apache.flink.streaming.runtime.io>.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)

at <http://org.apache.flink.streaming.runtime.io|org.apache.flink.streaming.runtime.io>.StreamMultipleInputProcessor.processInput(StreamMultipleInputProcessor.java:85)

at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:550)

at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)

at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:839)

at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:788)

at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952)

at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:931)

at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745)