[
https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450847#comment-17450847
]
Paul Lin commented on FLINK-22300:
----------------------------------
[~arvid] Please let me clarify a bit more. The problem is that TimeEvictor
would not be effective with processing time, because instead of getting the
current system timestamp (as `now()` you mentioned), it would extract
timestamps from TimestampedValue(backed by StreamRecord), see
[code|https://github.com/apache/flink/blob/6f05e6fdadd5cd8f27983bc8140d05f1c3557bb6/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/evictors/TimeEvictor.java#L70].
However, with processing time, TimestampedValue has no timestamp, so `evict()`
would always return directly.
> 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: Minor
> Labels: auto-deprioritized-major, stale-minor
>
> 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.20.1#820001)
