;>
> >> --------------
> >> *From:* Till Rohrmann
> >> *Sent:* 06 November 2020 17:56
> >> *To:* Simone Cavallarin
> >> *Cc:* user@flink.apache.org ; Aljoscha Krettek <
> >> aljos...@apache.org>
> >> *Subject:* Re: How t
6
>> *To:* Simone Cavallarin
>> *Cc:* user@flink.apache.org ; Aljoscha Krettek <
>> aljos...@apache.org>
>> *Subject:* Re: How to use properly the function:
>> withTimestampAssigner((event, timestamp) ->..
>>
>> Hi
* Till Rohrmann
> *Sent:* 06 November 2020 17:56
> *To:* Simone Cavallarin
> *Cc:* user@flink.apache.org ; Aljoscha Krettek <
> aljos...@apache.org>
> *Subject:* Re: How to use properly the function:
> withTimestampAssigner((event, timestamp) ->..
>
> Hi Simo
Hi Till,
That's great! thank you so much!!! I have spent one week on this. I'm so
relieved!
Cheers
s
From: Till Rohrmann
Sent: 06 November 2020 17:56
To: Simone Cavallarin
Cc: user@flink.apache.org ; Aljoscha Krettek
Subject: Re: How to use pr
Hi Simone,
The problem is that the Java 1.8 compiler cannot do type inference when
chaining methods [1].
The solution would be
WatermarkStrategy wmStrategy =
WatermarkStrategy
.forMonotonousTimestamps()
.withTimestampAssigner((event
Hi,
I'm taking the timestamp from the event payload that I'm receiving from Kafka.
I'm struggling to get the time and I'm confused on how I should use the
function ".withTimestampAssigner()". I'm receiving an error on event.getTime()
that is telling me: "cannot resolve method "Get Time" in "Obj
