Hi Soheil,
You can monitor the watermarks in the web dashboard as Fabian said. There
are some documents here[1].
[1]
https://ci.apache.org/projects/flink/flink-docs-master/monitoring/debugging_event_time.html#monitoring-current-event-time
On Thu, Jul 19, 2018 at 3:53 PM, Fabian Hueske wrote:
>
Hi Soheil,
Hequn is right. This might be an issue with advancing event-time.
You can monitor that by checking the watermarks in the web dashboard or
print-debug it with a ProcessFunction which can lookup the current
watermark.
Best, Fabian
2018-07-19 3:30 GMT+02:00 Hequn Cheng :
> Hi Soheil,
>
Hi Soheil,
> wait 8 milliseconds (according to my code) to see if any other data with
the same key received or not and after 8 millisecond it will be triggered.
Yes, but the time is event time, so if there is no data from source the
time won't be advanced.
There are some reasons why the event
Hi,
In a datastream processing problem, the source generated data every 8
millisecond and timestamp is a field of the data. In default Flink time
behavior data enter the time window but when I set Flink time to EventTime
it will output nothing! Here is the code:
