[
https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450532#comment-17450532
]
Arvid Heise commented on FLINK-22300:
-------------------------------------
Sorry for not following it up. I have a hard time to understand what you
exactly expect. The timestamp of a record in processing time is always `now()`
by definition and from your description it sounds like indeed returns it (I may
be wrong here).
I think what you are looking at is to use [ingestion
time|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/learn-flink/streaming_analytics/].
Then a record gets a proper timestamp assigned on first arrival in the system
and windowing and eviction are deterministic tasks.
However, I might have misunderstood your needs, so please reiterate them if
ingestion time is not working for you and why.
> 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)
