The watermark display in the UI is bugged in 1.5.0.
It is fixed on master and the release-1.5 branch, and will be included
in 1.5.1 that is slated to be released next week.
On 04.07.2018 10:22, Jungtaek Lim wrote:
Sorry I forgot to mention the version: Flink 1.5.0, and I ran the app
in IntelliJ, not tried from cluster.
2018년 7월 4일 (수) 오후 5:15, Jungtaek Lim <kabh...@gmail.com
<mailto:kabh...@gmail.com>>님이 작성:
Hi Flink users,
I'm new to Flink and trying to evaluate couple of streaming
frameworks via implementing same apps.
While implementing apps with both Table API and SQL, I found
there's 'no watermark' presented in Flink UI, whereas I had been
struggling to apply row time attribute.
For example, below is one of TableSource implementation which
wraps DataStream reading from Kafka.
https://github.com/HeartSaVioR/iot-trucking-app-flink/blob/master/src/main/scala/net/heartsavior/flink/datasource/TruckSpeedSource.scala
(Actually I ended up implementing TableSource to address adding
rowtime attribute as well as reading and parsing JSON. I'd be
really happy if someone can guide a way to get rid of needed of
custom implementation of TableSource.)
and below is one of app I implemented:
https://github.com/HeartSaVioR/iot-trucking-app-flink/blob/master/src/main/scala/net/heartsavior/flink/app/sql/IotTruckingAppMovingAggregationsOnSpeedSql.scala
Btw, I'm about to experiment side-output with late events, but is
it possible to leverage side-output with Table API / SQL? Looks
like DataStream exposes late events only when it's converted to
AllWindowedStream.
Thanks in advance!
Best Regards,
Jungtaek Lim (HeartSaVioR)
