[jira] [Comment Edited] (FLINK-5601) Window operator does not checkpoint watermarks

2021-03-16 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301571#comment-17301571 ] Julius Michaelis edited comment on FLINK-5601 at 3/16/21, 10:11 AM:

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

2021-03-15 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301571#comment-17301571 ] Julius Michaelis commented on FLINK-5601: - Hey, we're also affected by this, and I'd love to know

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-11-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228402#comment-17228402 ] Julius Michaelis edited comment on FLINK-18150 at 11/9/20, 8:19 AM:

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-11-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228402#comment-17228402 ] Julius Michaelis commented on FLINK-18150: -- Sorry, I still haven't gotten around to giving this

[jira] [Comment Edited] (FLINK-18712) Flink RocksDB statebackend memory leak issue

2020-10-16 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215118#comment-17215118 ] Julius Michaelis edited comment on FLINK-18712 at 10/16/20, 9:58 AM: -

[jira] [Commented] (FLINK-18712) Flink RocksDB statebackend memory leak issue

2020-10-15 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215118#comment-17215118 ] Julius Michaelis commented on FLINK-18712: -- [~yunta] , may I ask: are you still working on

[jira] [Closed] (FLINK-19502) Flink docker images: allow specifying arbitrary configuration values through environment

2020-10-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julius Michaelis closed FLINK-19502. Resolution: Invalid > Flink docker images: allow specifying arbitrary configuration

[jira] [Commented] (FLINK-19502) Flink docker images: allow specifying arbitrary configuration values through environment

2020-10-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208080#comment-17208080 ] Julius Michaelis commented on FLINK-19502: -- Argh, I missed that. Sorry for the noise.

[jira] [Created] (FLINK-19502) Flink docker images: allow specifying arbitrary configuration values through environment

2020-10-05 Thread Julius Michaelis (Jira)
Julius Michaelis created FLINK-19502: Summary: Flink docker images: allow specifying arbitrary configuration values through environment Key: FLINK-19502 URL: https://issues.apache.org/jira/browse/FLINK-19502

[jira] [Comment Edited] (FLINK-18712) Flink RocksDB statebackend memory leak issue

2020-08-28 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186505#comment-17186505 ] Julius Michaelis edited comment on FLINK-18712 at 8/28/20, 12:35 PM: -

[jira] [Commented] (FLINK-18712) Flink RocksDB statebackend memory leak issue

2020-08-28 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186505#comment-17186505 ] Julius Michaelis commented on FLINK-18712: -- @Farnight, have you tried setting

[jira] [Comment Edited] (FLINK-18712) Flink RocksDB statebackend memory leak issue

2020-08-28 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186505#comment-17186505 ] Julius Michaelis edited comment on FLINK-18712 at 8/28/20, 12:15 PM: -

[jira] [Comment Edited] (FLINK-18712) Flink RocksDB statebackend memory leak issue

2020-08-28 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186505#comment-17186505 ] Julius Michaelis edited comment on FLINK-18712 at 8/28/20, 12:14 PM: -

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 2:55 AM:

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 2:54 AM:

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 2:42 AM:

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 2:34 AM:

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155006#comment-17155006 ] Julius Michaelis commented on FLINK-18150: -- For Flink 1.10 / Kafka 2.2.0, the

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 12:21 AM: -

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-07 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152630#comment-17152630 ] Julius Michaelis commented on FLINK-18150: -- That's reassuring to hear. It's my first time

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-07 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152630#comment-17152630 ] Julius Michaelis edited comment on FLINK-18150 at 7/7/20, 10:22 AM:

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151690#comment-17151690 ] Julius Michaelis commented on FLINK-18150: -- Even worse, with Flink 1.11, the options that

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17144768#comment-17144768 ] Julius Michaelis edited comment on FLINK-18150 at 7/6/20, 1:23 AM: --- My

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17144768#comment-17144768 ] Julius Michaelis edited comment on FLINK-18150 at 7/6/20, 1:23 AM: --- My

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-26 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17146262#comment-17146262 ] Julius Michaelis commented on FLINK-18150: -- Finally managed to build my job on

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-26 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17146138#comment-17146138 ] Julius Michaelis edited comment on FLINK-18150 at 6/26/20, 9:15 AM:

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-26 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17146138#comment-17146138 ] Julius Michaelis edited comment on FLINK-18150 at 6/26/20, 9:14 AM:

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-26 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17146138#comment-17146138 ] Julius Michaelis edited comment on FLINK-18150 at 6/26/20, 9:12 AM:

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-26 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17146138#comment-17146138 ] Julius Michaelis edited comment on FLINK-18150 at 6/26/20, 9:12 AM:

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-26 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17146138#comment-17146138 ] Julius Michaelis edited comment on FLINK-18150 at 6/26/20, 9:11 AM:

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-26 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17146138#comment-17146138 ] Julius Michaelis commented on FLINK-18150: -- Uh. It probably doesn't happen without producers.

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-25 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17144768#comment-17144768 ] Julius Michaelis commented on FLINK-18150: -- My current guess is that this relates to the way

[jira] [Commented] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-16 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138102#comment-17138102 ] Julius Michaelis commented on FLINK-18150: -- I tried reproducing the problem outside of this

[jira] [Updated] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julius Michaelis updated FLINK-18150: - Environment: It is a bit unclear to me under what circumstances this can be reproduced.

[jira] [Updated] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julius Michaelis updated FLINK-18150: - Description: When a Kafka broker fails that is listed among the bootstrap servers and

[jira] [Updated] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julius Michaelis updated FLINK-18150: - Description: When a Kafka broker fails that is listed among the bootstrap servers and

[jira] [Updated] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-05 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julius Michaelis updated FLINK-18150: - Description: When a Kafka broker fails that is listed among the bootstrap servers and

[jira] [Created] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-05 Thread Julius Michaelis (Jira)
Julius Michaelis created FLINK-18150: Summary: A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata Key: FLINK-18150 URL:

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-10-16 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953299#comment-16953299 ] Julius Michaelis commented on FLINK-13808: -- As for something else that may be easier to

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-09-18 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932283#comment-16932283 ] Julius Michaelis commented on FLINK-13808: -- Hm, Is it possible that checkpoints also spawn

[jira] [Updated] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-08-21 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julius Michaelis updated FLINK-13808: - Description: A RocksDB state backend with HDFS checkpoints, with or without local

[jira] [Updated] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-08-21 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julius Michaelis updated FLINK-13808: - Description: A RocksDB state backend with HDFS checkpoints, with or without local

[jira] [Updated] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-08-21 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julius Michaelis updated FLINK-13808: - Environment: So far only reliably reproducible on a 4-node cluster with parallelism ≥

[jira] [Created] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-08-21 Thread Julius Michaelis (Jira)
Julius Michaelis created FLINK-13808: Summary: Checkpoints expired by timeout may leak RocksDB files Key: FLINK-13808 URL: https://issues.apache.org/jira/browse/FLINK-13808 Project: Flink