[jira] [Commented] (FLINK-30562) CEP Operator misses patterns on SideOutputs and parallelism >1 since 1.15.x+

2023-01-05 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655070#comment-17655070 ] Thomas Wozniakowski commented on FLINK-30562: - [^flink-asf-30562-clean.zip] I've produced

[jira] [Updated] (FLINK-30562) CEP Operator misses patterns on SideOutputs and parallelism >1 since 1.15.x+

2023-01-05 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-30562: Attachment: flink-asf-30562-clean.zip > CEP Operator misses patterns on

[jira] [Updated] (FLINK-30562) CEP Operator misses patterns on SideOutputs and parallelism >1 since 1.15.x+

2023-01-05 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-30562: Component/s: API / DataStream > CEP Operator misses patterns on SideOutputs and

[jira] [Updated] (FLINK-30562) CEP Operator misses patterns on SideOutputs and parallelism >1 since 1.15.x+

2023-01-05 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-30562: Summary: CEP Operator misses patterns on SideOutputs and parallelism >1 since

[jira] [Commented] (FLINK-30562) Patterns are not emitted with parallelism >1 since 1.15.x+

2023-01-05 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655011#comment-17655011 ] Thomas Wozniakowski commented on FLINK-30562: - Hi [~bgeng777] I've made some progress in

[jira] [Commented] (FLINK-30562) Patterns are not emitted with parallelism >1 since 1.15.x+

2023-01-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654511#comment-17654511 ] Thomas Wozniakowski commented on FLINK-30562: - Hi [~bgeng777], thanks for the quick

[jira] [Updated] (FLINK-30562) Patterns are not emitted with parallelism >1 since 1.15.x+

2023-01-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-30562: Description: (Apologies for the speculative and somewhat vague ticket, but I

[jira] [Created] (FLINK-30562) Patterns are not emitted with parallelism >1 since 1.15.x+

2023-01-04 Thread Thomas Wozniakowski (Jira)
Thomas Wozniakowski created FLINK-30562: --- Summary: Patterns are not emitted with parallelism >1 since 1.15.x+ Key: FLINK-30562 URL: https://issues.apache.org/jira/browse/FLINK-30562 Project:

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-11 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247999#comment-17247999 ] Thomas Wozniakowski commented on FLINK-19970: - [~dwysakowicz] I've emailed you over the code

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-08 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245902#comment-17245902 ] Thomas Wozniakowski commented on FLINK-19970: - Ok, I am working on this now. It's going to

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-07 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245327#comment-17245327 ] Thomas Wozniakowski commented on FLINK-19970: - Ok, I've built another version of our app

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244094#comment-17244094 ] Thomas Wozniakowski commented on FLINK-19970: - Ah sorry, I mixed up the `key` and `id` value

[jira] [Updated] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-19970: Attachment: screenshot-3.png > State leak in CEP Operators (expired events/keys

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244083#comment-17244083 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] Am I correct in saying

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244047#comment-17244047 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz], Just to confirm, it's

[jira] [Updated] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-19970: Attachment: screenshot-2.png > State leak in CEP Operators (expired events/keys

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243915#comment-17243915 ] Thomas Wozniakowski commented on FLINK-19970: - Results over a longer period, state still

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-03 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243327#comment-17243327 ] Thomas Wozniakowski commented on FLINK-19970: - !screenshot-1.png! Unfortunately it

[jira] [Updated] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-03 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-19970: Attachment: screenshot-1.png > State leak in CEP Operators (expired events/keys

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-03 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243202#comment-17243202 ] Thomas Wozniakowski commented on FLINK-19970: - Ok, our load test is running now after a

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242478#comment-17242478 ] Thomas Wozniakowski commented on FLINK-19970: - For some reason I can't compile your branch,

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242459#comment-17242459 ] Thomas Wozniakowski commented on FLINK-19970: - Do I need to rebuild our Job JAR using the

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242433#comment-17242433 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] - great to hear you have a

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-01 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241445#comment-17241445 ] Thomas Wozniakowski commented on FLINK-19970: - Hi [~wind_ljy], No, we didn't identify a

[jira] [Commented] (FLINK-19293) RocksDB last_checkpoint.state_size grows endlessly until savepoint/restore

2020-11-23 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237395#comment-17237395 ] Thomas Wozniakowski commented on FLINK-19293: - Hi [~AHeise] Sorry, I meant to update this

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-11-16 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232913#comment-17232913 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] - thanks for the update.

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-11-06 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227329#comment-17227329 ] Thomas Wozniakowski commented on FLINK-19970: - [~dwysakowicz] Please give me a shout if

[jira] [Updated] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-11-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-19970: Description: We have been observing instability in our production environment

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-11-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226022#comment-17226022 ] Thomas Wozniakowski commented on FLINK-19970: - Hi [~dwysakowicz], Sorry for not including

[jira] [Updated] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-11-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-19970: Description: We have been observing instability in our production environment

[jira] [Updated] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-11-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-19970: Description: We have been observing instability in our production environment

[jira] [Created] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-11-04 Thread Thomas Wozniakowski (Jira)
Thomas Wozniakowski created FLINK-19970: --- Summary: State leak in CEP Operators (expired events/keys not removed from state) Key: FLINK-19970 URL: https://issues.apache.org/jira/browse/FLINK-19970

[jira] [Created] (FLINK-19293) RocksDB last_checkpoint.state_size grows endlessly until savepoint/restore

2020-09-18 Thread Thomas Wozniakowski (Jira)
Thomas Wozniakowski created FLINK-19293: --- Summary: RocksDB last_checkpoint.state_size grows endlessly until savepoint/restore Key: FLINK-19293 URL: https://issues.apache.org/jira/browse/FLINK-19293

[jira] [Commented] (FLINK-16588) Add Disk Space metrics to TaskManagers

2020-03-23 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064889#comment-17064889 ] Thomas Wozniakowski commented on FLINK-16588: - I think that's a fair enough assessment. I'll

[jira] [Commented] (FLINK-16588) Add Disk Space metrics to TaskManagers

2020-03-20 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063342#comment-17063342 ] Thomas Wozniakowski commented on FLINK-16588: - So we're running them in AWS Fargate. The

[jira] [Commented] (FLINK-16588) Add Disk Space metrics to TaskManagers

2020-03-20 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063201#comment-17063201 ] Thomas Wozniakowski commented on FLINK-16588: - Hey [~gjy], I take your point, but as a user

[jira] [Created] (FLINK-16588) Add Disk Space metrics to TaskManagers

2020-03-13 Thread Thomas Wozniakowski (Jira)
Thomas Wozniakowski created FLINK-16588: --- Summary: Add Disk Space metrics to TaskManagers Key: FLINK-16588 URL: https://issues.apache.org/jira/browse/FLINK-16588 Project: Flink Issue

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-03-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051086#comment-17051086 ] Thomas Wozniakowski commented on FLINK-16142: - Hey [~xintongsong], we set the metaspace to

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-26 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045467#comment-17045467 ] Thomas Wozniakowski commented on FLINK-16142: - Yeah, increasing the metaspace seems to

[jira] [Comment Edited] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-24 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043658#comment-17043658 ] Thomas Wozniakowski edited comment on FLINK-16142 at 2/24/20 4:36 PM:

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-24 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043658#comment-17043658 ] Thomas Wozniakowski commented on FLINK-16142: - Hey [~sewen] - we've applied the fix on our

[jira] [Updated] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-24 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-16142: Attachment: java_pid1.hprof > Memory Leak causes Metaspace OOM error on repeated

[jira] [Comment Edited] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042027#comment-17042027 ] Thomas Wozniakowski edited comment on FLINK-16142 at 2/21/20 5:14 PM:

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042027#comment-17042027 ] Thomas Wozniakowski commented on FLINK-16142: - [~sewen] I don't have access to the Kinesis

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041933#comment-17041933 ] Thomas Wozniakowski commented on FLINK-16142: - Just in case it is relevant, given we're

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041919#comment-17041919 ] Thomas Wozniakowski commented on FLINK-16142: - [~pnowojski] We load the S3 plugin via this:

[jira] [Comment Edited] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041816#comment-17041816 ] Thomas Wozniakowski edited comment on FLINK-16142 at 2/21/20 12:48 PM:

[jira] [Updated] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-16142: Attachment: java_pid1.hprof > Memory Leak causes Metaspace OOM error on repeated

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041816#comment-17041816 ] Thomas Wozniakowski commented on FLINK-16142: - Hi [~sewen] I've attached the heap dump. It

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041683#comment-17041683 ] Thomas Wozniakowski commented on FLINK-16142: - Hi [~sewen], here is the first chunk of the

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-20 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041156#comment-17041156 ] Thomas Wozniakowski commented on FLINK-16142: - Hey [~sewen] we are using the official Flink

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-20 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041059#comment-17041059 ] Thomas Wozniakowski commented on FLINK-16142: - [~arvid heise] I managed to get hold of those

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-20 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041005#comment-17041005 ] Thomas Wozniakowski commented on FLINK-16142: - On further investigation, I can see that this

[jira] [Comment Edited] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-20 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040885#comment-17040885 ] Thomas Wozniakowski edited comment on FLINK-16142 at 2/20/20 11:54 AM:

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-20 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040885#comment-17040885 ] Thomas Wozniakowski commented on FLINK-16142: - Here is a threaddump (just the last one this

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-19 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040239#comment-17040239 ] Thomas Wozniakowski commented on FLINK-16142: - After first run {code:json} [ {

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-19 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040163#comment-17040163 ] Thomas Wozniakowski commented on FLINK-16142: - Ok, I put the following in the OPEN method of

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-19 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040146#comment-17040146 ] Thomas Wozniakowski commented on FLINK-16142: - [~kevin.cyj] it would be quite difficult for

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-18 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039260#comment-17039260 ] Thomas Wozniakowski commented on FLINK-16142: - Explicitly calling `.shutdown()` on the SQS

[jira] [Commented] (FLINK-16142) Memory Le!k causes Metaspace OOM error on repeated job submission

2020-02-18 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039227#comment-17039227 ] Thomas Wozniakowski commented on FLINK-16142: - Hi Guys, Thanks for the speedy response.

[jira] [Created] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-18 Thread Thomas Wozniakowski (Jira)
Thomas Wozniakowski created FLINK-16142: --- Summary: Memory Leak causes Metaspace OOM error on repeated job submission Key: FLINK-16142 URL: https://issues.apache.org/jira/browse/FLINK-16142

[jira] [Commented] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

2020-01-31 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027328#comment-17027328 ] Thomas Wozniakowski commented on FLINK-14812: - FYI - I am implementing a slightly inelegant

[jira] [Closed] (FLINK-10960) CEP: Job Failure when .times(2) is used

2019-01-03 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski closed FLINK-10960. --- Resolution: Workaround Release Note: It seems this issue was as David

[jira] [Updated] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-12-12 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10960: Priority: Critical (was: Major) > CEP: Job Failure when .times(2) is used >

[jira] [Commented] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-12-12 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718899#comment-16718899 ] Thomas Wozniakowski commented on FLINK-10960: - Ok, so a way to reproduce this should be: 1.

[jira] [Comment Edited] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-12-12 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718899#comment-16718899 ] Thomas Wozniakowski edited comment on FLINK-10960 at 12/12/18 12:11 PM:

[jira] [Comment Edited] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-12-12 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718899#comment-16718899 ] Thomas Wozniakowski edited comment on FLINK-10960 at 12/12/18 12:11 PM:

[jira] [Commented] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-12-12 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718816#comment-16718816 ] Thomas Wozniakowski commented on FLINK-10960: - Hi [~dawidwys], I'm hoping you might be able

[jira] [Comment Edited] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-12-12 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718816#comment-16718816 ] Thomas Wozniakowski edited comment on FLINK-10960 at 12/12/18 11:23 AM:

[jira] [Updated] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-11-21 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10960: Description: Hi Guys, Encountered a strange one today. We use the CEP library in

[jira] [Updated] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-11-21 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10960: Description: Hi Guys, Encountered a strange one today. We use the CEP library in

[jira] [Created] (FLINK-10960) CEP: Job Failure when .times(2) is used

2018-11-21 Thread Thomas Wozniakowski (JIRA)
Thomas Wozniakowski created FLINK-10960: --- Summary: CEP: Job Failure when .times(2) is used Key: FLINK-10960 URL: https://issues.apache.org/jira/browse/FLINK-10960 Project: Flink Issue

[jira] [Commented] (FLINK-10570) State grows unbounded when "within" constraint not applied

2018-11-04 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674424#comment-16674424 ] Thomas Wozniakowski commented on FLINK-10570: - Hi [~dawidwys], I notice this is scheduled

[jira] [Created] (FLINK-10570) State grows unbounded when "within" constraint not applied

2018-10-16 Thread Thomas Wozniakowski (JIRA)
Thomas Wozniakowski created FLINK-10570: --- Summary: State grows unbounded when "within" constraint not applied Key: FLINK-10570 URL: https://issues.apache.org/jira/browse/FLINK-10570 Project:

[jira] [Commented] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader (ZK 3.5.3-beta only)

2018-10-04 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638747#comment-16638747 ] Thomas Wozniakowski commented on FLINK-10475: - Sure - I can update the docs. I'll say that

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader (ZK 3.5.3-beta only)

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Summary: Standalone HA - Leader election is not triggered on loss of leader (ZK

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader (ZK 3.5.3-beta only)

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Priority: Minor (was: Blocker) > Standalone HA - Leader election is not

[jira] [Commented] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636033#comment-16636033 ] Thomas Wozniakowski commented on FLINK-10475: - Aha - so it appears to be the version of

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4 (edit: also

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Affects Version/s: 1.6.1 > Standalone HA - Leader election is not triggered on

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4 (edit: also

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4. Happy to

[jira] [Commented] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635441#comment-16635441 ] Thomas Wozniakowski commented on FLINK-10475: - [~till.rohrmann] Thanks for the response -

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4. Happy to

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Attachment: t1.log t2.log t3.log > Standalone HA

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-10-01 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634203#comment-16634203 ] Thomas Wozniakowski commented on FLINK-10184: - [~till.rohrmann] I've now tested the fix on

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-01 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4. Happy to

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-01 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4. Happy to

[jira] [Created] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-01 Thread Thomas Wozniakowski (JIRA)
Thomas Wozniakowski created FLINK-10475: --- Summary: Standalone HA - Leader election is not triggered on loss of leader Key: FLINK-10475 URL: https://issues.apache.org/jira/browse/FLINK-10475

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-09-20 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621772#comment-16621772 ] Thomas Wozniakowski commented on FLINK-10184: - Hey [~till.rohrmann], It's kind of

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-09-10 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16609299#comment-16609299 ] Thomas Wozniakowski commented on FLINK-10184: - Hey [~till.rohrmann] - this may sound like a

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-09-06 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605882#comment-16605882 ] Thomas Wozniakowski commented on FLINK-10184: - Hi [~till.rohrmann] Happy to help out with

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-09-06 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605485#comment-16605485 ] Thomas Wozniakowski commented on FLINK-10184: - Hi [~till.rohrmann], Yes. We are running

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-08-21 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587293#comment-16587293 ] Thomas Wozniakowski commented on FLINK-10184: - I'm just combing through the Zookeeper logs

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-08-21 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587280#comment-16587280 ] Thomas Wozniakowski commented on FLINK-10184: - We also performed a Zookeeper upgrade as part

[jira] [Updated] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-08-21 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10184: Affects Version/s: 1.6.0 > HA Failover broken due to JobGraphs not being removed

[jira] [Comment Edited] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-08-21 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587119#comment-16587119 ] Thomas Wozniakowski edited comment on FLINK-10184 at 8/21/18 7:52 AM:

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-08-21 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587119#comment-16587119 ] Thomas Wozniakowski commented on FLINK-10184: - Hey [~wcummings], I'm not 100% sure what is

[jira] [Comment Edited] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-08-21 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587119#comment-16587119 ] Thomas Wozniakowski edited comment on FLINK-10184 at 8/21/18 7:52 AM:

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-08-20 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586188#comment-16586188 ] Thomas Wozniakowski commented on FLINK-10184: - Hi [~elevy], I don't believe it is the same

  1   2   >