[ 
https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322660#comment-17322660
 ] 

Paul Lin commented on FLINK-22300:
----------------------------------

There's a workaround for this problem: extract timestamps and watermarks right 
before the processing time window, but it may affect accuracy if there's some 
latency. To fully solve the problem, we may need to attach processing 
timestamps to the records in the window assigner.

> Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of 
> TimeCharacteristic
> --------------------------------------------------------------------------------------------
>
>                 Key: FLINK-22300
>                 URL: https://issues.apache.org/jira/browse/FLINK-22300
>             Project: Flink
>          Issue Type: Improvement
>          Components: API / DataStream
>    Affects Versions: 1.11.3
>            Reporter: Bo Huang
>            Priority: Major
>
> StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime).
> The data after Windows process can not be evicted by TimeEvictor of Keyed 
> Windows Beause TimestampedValue have no timestamp value.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to