Thanks, Seth. That did the trick!
On Fri, Jan 29, 2021 at 10:51 AM Seth Wiesman wrote:
> You need to use TUMBLE_ROWTIME to extract a time attribute from a window,
> TUMBLE_END is just a timestamp.
>
>
>
You need to use TUMBLE_ROWTIME to extract a time attribute from a window,
TUMBLE_END is just a timestamp.
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/queries.html#selecting-group-window-start-and-end-timestamps
Seth
On Fri, Jan 29, 2021 at 9:14 AM Patrick Angeles
Forgot to mention, I am using Flink 1.12.
On Fri, Jan 29, 2021 at 10:11 AM Patrick Angeles
wrote:
> Fairly new to Flink here so this might be a newbie mistake, but here's the
> problem. I created the following table and view:
>
>
>> CREATE TABLE test (
>>
>> event_time TIMESTAMP(3),
>>
Fairly new to Flink here so this might be a newbie mistake, but here's the
problem. I created the following table and view:
> CREATE TABLE test (
>
> event_time TIMESTAMP(3),
>
> symbol STRING,
>
> price DOUBLE,
>
> WATERMARK FOR event_time AS event_time -
-
> *From:* Yan Zhou [FDS Science]
> *Sent:* Monday, June 4, 2018 4:05 PM
> *To:* Fabian Hueske
>
> *Cc:* Dawid Wysakowicz; user
> *Subject:* Re: NPE in flink sql over-window
>
>
> Hi Fabian,
>
>
> Yes, the NPE cause the job f
, 2018 4:05 PM
To: Fabian Hueske
Cc: Dawid Wysakowicz; user
Subject: Re: NPE in flink sql over-window
Hi Fabian,
Yes, the NPE cause the job failure and recovery( instead of being the result of
a recovery).
And yet, during the recovery, the same exceptions are thrown from same line.
Best
Yan
To: Yan Zhou [FDS Science]
Cc: Dawid Wysakowicz; user
Subject: Re: NPE in flink sql over-window
Hi Yan,
Thanks for the details and for digging into the issue.
If I got it right, the NPE caused the job failure and recovery (instead of
being the result of a recovery), correct?
Best, Fabian
2018-05-31
or ProcTimeBoundedRangeOver. I will update
> with my test result and fire a JIRA after that.
>
>
> Best
>
> Yan
> --
> *From:* Fabian Hueske
> *Sent:* Wednesday, May 30, 2018 1:43:01 AM
> *To:* Dawid Wysakowicz
> *Cc:* user
> *Subje
log for ProcTimeBoundedRangeOver. I will update with my
test result and fire a JIRA after that.
Best
Yan
From: Fabian Hueske
Sent: Wednesday, May 30, 2018 1:43:01 AM
To: Dawid Wysakowicz
Cc: user
Subject: Re: NPE in flink sql over-window
Hi,
Dawid's analysis
eft)*
>
>
>
> --
> *From:* Yan Zhou [FDS Science]
> *Sent:* Tuesday, May 29, 2018 10:52:18 PM
> *To:* user@flink.apache.org
> *Subject:* NPE in flink sql over-window
>
>
> Hi,
>
> I am using flink sql 1.5.0. My application throws NPE.
May 29, 2018 10:52:18 PM
> *To:* user@flink.apache.org
> *Subject:* NPE in flink sql over-window
>
>
> Hi,
>
> I am using flink sql 1.5.0. My application throws NPE. And after it
> recover from checkpoint automatically, it throws NPE immediately from
> same line of code
]
total_blobs=54308 nmethods=53551 adapters=617
compilation: disabled (not enough contiguous free space left)
From: Yan Zhou [FDS Science]
Sent: Tuesday, May 29, 2018 10:52:18 PM
To: user@flink.apache.org
Subject: NPE in flink sql over-window
Hi,
I am using flink sql
Hi,
I am using flink sql 1.5.0. My application throws NPE. And after it recover
from checkpoint automatically, it throws NPE immediately from same line of code.
My application read message from kafka, convert the datastream into a table,
issue an Over-window aggregation and write the result
13 matches
Mail list logo
