flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stefano Bortoli <stefano.bort...@huawei.com>
Subject StreamSQL procTime granularity
Date Tue, 04 Apr 2017 08:23:31 GMT
Hi guys,

Based on the discussion about time management in https://github.com/apache/flink/pull/3641
, does it make sense to use nanoTime for procTime semantic aggregation processing? This way
we will not have the possibility of events falling in the same "millisecond" processing bucket
and keep a consistent aggregation sorting (also in the state). I understand that event-time
cannot be managed in nanosecond as java does not give wall-clock time in nanoseconds, but
for the procTime within the JVM we should be safe.

Please let me know what you think.


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message