The best I can do is point you to the thread[1].
I am also cc'ing Yuan who is the release manager for 1.12.2.
Best,
Dawid
[1]
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Releasing-Apache-Flink-1-12-2-td48603.html
On 15/02/2021 08:51, Yuval Itzchakov wrote:
> Hi Dawid
Hi Dawid,
Yes, looks like it. Thanks!
Is there an ETA on 1.12.2 yet?
On Mon, Feb 15, 2021 at 9:48 AM Dawid Wysakowicz
wrote:
> Hey Yuval,
>
> Could it be that you are hitting this bug[1], which has been fixed
> recently?
>
> Best,
>
> Dawid
>
> [1] https://issues.apache.org/jira/browse/FLINK-21
Hey Yuval,
Could it be that you are hitting this bug[1], which has been fixed recently?
Best,
Dawid
[1] https://issues.apache.org/jira/browse/FLINK-21013
On 15/02/2021 08:20, Yuval Itzchakov wrote:
> Hi,
>
> I have a source that generates events with timestamps. These flow
> nicely, until enco
Hi,
I have a source that generates events with timestamps. These flow nicely,
until encountering a conversion from Table -> DataStream[Row]:
def toRowRetractStream(implicit ev: TypeInformation[Row]):
DataStream[Row] =
table
.toRetractStream[Row]
.flatMap { (row, collecto
