[
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)
