Hi,
I assume that
withTimestampsAndWatermarks1.print();
withTimestampsAndWatermarks2.print();
Actually prints what you have expected?
If so, the problem might be that:
a) time/watermarks are not progressing (watermarks are triggering the output of
your `Tumbli
DataStream> withTimestampsAndWatermarks1 = formatStream1
.assignTimestampsAndWatermarks(
new
BoundedOutOfOrdernessTimestampExtractor>(
Time.seconds(Integ
Looks like you need to assign time stamps and emit watermarks to both the
streams viz. formatStream1 and formatStream2 as described at
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/event_timestamp_extractors.html
On Thu, Nov 22, 2018 at 10:55 PM Abhijeet Kumar
wrote:
> Hello Te
Hello Team,
I'm new to Flink and coming from Spark background. I need help in completing
this stream job. I'm reading data from two different Kafka topics and I want to
join them.
My code:
formatStream1.join(formatStream2)
.where(new KeySelector, String>() {
