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

[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655070#comment-17655070 ] Thomas Wozniakowski commented on FLINK-30562: - [^flink-asf-30562-clean.zip]

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

[ 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 SideOutput

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

[ 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 pa

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

[ 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 1.15

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

[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655011#comment-17655011 ] Thomas Wozniakowski commented on FLINK-30562: - Hi [~bgeng777] I've made som

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

[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654511#comment-17654511 ] Thomas Wozniakowski commented on FLINK-30562: - Hi [~bgeng777], thanks for th

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

[ 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 wante

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

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: Flin

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247999#comment-17247999 ] Thomas Wozniakowski commented on FLINK-19970: - [~dwysakowicz] I've emailed y

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245902#comment-17245902 ] Thomas Wozniakowski commented on FLINK-19970: - Ok, I am working on this now.

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245327#comment-17245327 ] Thomas Wozniakowski commented on FLINK-19970: - Ok, I've built another versio

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244094#comment-17244094 ] Thomas Wozniakowski commented on FLINK-19970: - Ah sorry, I mixed up the `key

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

[ 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 no

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244083#comment-17244083 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] Am I corr

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244047#comment-17244047 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz], Just to

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

[ 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 no

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243915#comment-17243915 ] Thomas Wozniakowski commented on FLINK-19970: - Results over a longer period,

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243327#comment-17243327 ] Thomas Wozniakowski commented on FLINK-19970: - !screenshot-1.png! Unfortu

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

[ 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 no

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243202#comment-17243202 ] Thomas Wozniakowski commented on FLINK-19970: - Ok, our load test is running

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242478#comment-17242478 ] Thomas Wozniakowski commented on FLINK-19970: - For some reason I can't compi

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242459#comment-17242459 ] Thomas Wozniakowski commented on FLINK-19970: - Do I need to rebuild our Job

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242433#comment-17242433 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] - great to

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241445#comment-17241445 ] Thomas Wozniakowski commented on FLINK-19970: - Hi [~wind_ljy], No, we didn'

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

[ https://issues.apache.org/jira/browse/FLINK-19293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237395#comment-17237395 ] Thomas Wozniakowski commented on FLINK-19293: - Hi [~AHeise] Sorry, I meant

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232913#comment-17232913 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] - thanks f

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227329#comment-17227329 ] Thomas Wozniakowski commented on FLINK-19970: - [~dwysakowicz] Please give me

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

[ 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 rece

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

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226022#comment-17226022 ] Thomas Wozniakowski commented on FLINK-19970: - Hi [~dwysakowicz], Sorry for

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

[ 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 rece

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

[ 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 rece

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-16588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064889#comment-17064889 ] Thomas Wozniakowski commented on FLINK-16588: - I think that's a fair enough

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

[ https://issues.apache.org/jira/browse/FLINK-16588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063342#comment-17063342 ] Thomas Wozniakowski commented on FLINK-16588: - So we're running them in AWS

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

[ https://issues.apache.org/jira/browse/FLINK-16588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063201#comment-17063201 ] Thomas Wozniakowski commented on FLINK-16588: - Hey [~gjy], I take your poin

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

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 Ty

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051086#comment-17051086 ] Thomas Wozniakowski commented on FLINK-16142: - Hey [~xintongsong], we set th

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045467#comment-17045467 ] Thomas Wozniakowski commented on FLINK-16142: - Yeah, increasing the metaspac

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17043658#comment-17043658 ] Thomas Wozniakowski commented on FLINK-16142: - Hey [~sewen] - we've applied

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

[ 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 j

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17042027#comment-17042027 ] Thomas Wozniakowski commented on FLINK-16142: - [~sewen] I don't have access

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041933#comment-17041933 ] Thomas Wozniakowski commented on FLINK-16142: - Just in case it is relevant,

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041919#comment-17041919 ] Thomas Wozniakowski commented on FLINK-16142: - [~pnowojski] We load the S3 p

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ 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 j

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041816#comment-17041816 ] Thomas Wozniakowski commented on FLINK-16142: - Hi [~sewen] I've attached th

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041683#comment-17041683 ] Thomas Wozniakowski commented on FLINK-16142: - Hi [~sewen], here is the firs

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041156#comment-17041156 ] Thomas Wozniakowski commented on FLINK-16142: - Hey [~sewen] we are using the

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041059#comment-17041059 ] Thomas Wozniakowski commented on FLINK-16142: - [~arvid heise] I managed to g

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041005#comment-17041005 ] Thomas Wozniakowski commented on FLINK-16142: - On further investigation, I c

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040885#comment-17040885 ] Thomas Wozniakowski commented on FLINK-16142: - Here is a threaddump (just th

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040163#comment-17040163 ] Thomas Wozniakowski commented on FLINK-16142: - Ok, I put the following in th

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040146#comment-17040146 ] Thomas Wozniakowski commented on FLINK-16142: - [~kevin.cyj] it would be quit

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039260#comment-17039260 ] Thomas Wozniakowski commented on FLINK-16142: - Explicitly calling `.shutdown

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

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039227#comment-17039227 ] Thomas Wozniakowski commented on FLINK-16142: - Hi Guys, Thanks for the spee

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

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 Proje

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

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027328#comment-17027328 ] Thomas Wozniakowski commented on FLINK-14812: - FYI - I am implementing a sli

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

[ 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 described

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718899#comment-16718899 ] Thomas Wozniakowski commented on FLINK-10960: - Ok, so a way to reproduce thi

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

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718816#comment-16718816 ] Thomas Wozniakowski commented on FLINK-10960: - Hi [~dawidwys], I'm hoping y

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

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ 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

[ 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] [Commented] (FLINK-10960) CEP: Job Failure when .times(2) is used

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694686#comment-16694686 ] Thomas Wozniakowski commented on FLINK-10960: - Hey [~dawidwys], It's tricky

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

[ 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

[ 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

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 T

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

[ https://issues.apache.org/jira/browse/FLINK-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16674424#comment-16674424 ] Thomas Wozniakowski commented on FLINK-10570: - Hi [~dawidwys], I notice this

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

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: Flin

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

[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638747#comment-16638747 ] Thomas Wozniakowski commented on FLINK-10475: - Sure - I can update the docs.

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

[ 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 3.

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

[ 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 triggered

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

[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16636033#comment-16636033 ] Thomas Wozniakowski commented on FLINK-10475: - Aha - so it appears to be the

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

[ 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 h

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

[ 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 los

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

[ 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 h

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

[ 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 see

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

[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635441#comment-16635441 ] Thomas Wozniakowski commented on FLINK-10475: - [~till.rohrmann] Thanks for t

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

[ 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 see

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16634203#comment-16634203 ] Thomas Wozniakowski commented on FLINK-10184: - [~till.rohrmann] I've now tes

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

[ 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 see

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

[ 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 see

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

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 Proj

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

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16621772#comment-16621772 ] Thomas Wozniakowski commented on FLINK-10184: - Hey [~till.rohrmann], It's k

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

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609299#comment-16609299 ] Thomas Wozniakowski commented on FLINK-10184: - Hey [~till.rohrmann] - this m

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

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605882#comment-16605882 ] Thomas Wozniakowski commented on FLINK-10184: - Hi [~till.rohrmann] Happy to

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

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605485#comment-16605485 ] Thomas Wozniakowski commented on FLINK-10184: - Hi [~till.rohrmann], Yes. We

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

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587293#comment-16587293 ] Thomas Wozniakowski commented on FLINK-10184: - I'm just combing through the

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

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587280#comment-16587280 ] Thomas Wozniakowski commented on FLINK-10184: - We also performed a Zookeeper

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

[ 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 f

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

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

  1   2   >