Hi, Dawid.
Thanks for replying, happy to know you are working on this.
On 2021/07/08 12:14:21, Dawid Wysakowicz wrote:
> Hi,
>
> Sorry for the late reply.
>
> Indeed I found a couple of problems with clearing the state for short
> lived keys. I created a JIRA[1] issue to track it and opened a
Hi,
Sorry for the late reply.
Indeed I found a couple of problems with clearing the state for short
lived keys. I created a JIRA[1] issue to track it and opened a PR (which
needs test coverage before it can be merged) with fixes for those.
Best,
Dawid
[1] https://issues.apache.org/jira/browse/
tps://issues.apache.org/jira/browse/FLINK-19970. Looks like the bug
> > in scenario 1 got fixed by scenario 2 did not. There's more detail in
> > this thread,
> > http://deprecated-apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-cep-checkpoint-size-td441
more detail in
> this thread,
> http://deprecated-apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-cep-checkpoint-size-td44141.html#a44168
> . Hope that helps
>
> On Tue, Jul 6, 2021 at 12:44 AM Li Jim wrote:
> >
> > I am using Flink CEP to
-user-mailing-list-archive.2336050.n4.nabble.com/Flink-cep-checkpoint-size-td44141.html#a44168
. Hope that helps
On Tue, Jul 6, 2021 at 12:44 AM Li Jim wrote:
>
> I am using Flink CEP to do some performance tests.
>
> Flink version 1.13.1.
>
> below is the sql:
>
> INSERT I
I am using Flink CEP to do some performance tests.
Flink version 1.13.1.
below is the sql:
INSERT INTO to_kafka
SELECT bizName, wdName, wdValue , zbValue , flowId FROM kafka_source
MATCH_RECOGNIZE
(
PARTITION BY flow_id
ORDER BY proctime
MEASURES A.biz_name as bizName, A.wd_name as w
Hi, Mohit,
Have you figured out any solusions on this problem ?
I am now facing the exactly same problem ,
I was using Flink of version 1.12.0 and I also upgrated it to 1.13.1 but the
checkpoint size is still growing.
On 2021/06/02 15:45:59, "Singh, Mohit" wrote:
> Hi,
>
> I am facing an i
