[jira] [Created] (FLINK-12620) Deadlock in task deserialization

Mike Kaplinskiy created FLINK-12620: --- Summary: Deadlock in task deserialization Key: FLINK-12620 URL: https://issues.apache.org/jira/browse/FLINK-12620 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849259#comment-16849259 ] Mike Kaplinskiy commented on FLINK-12620: - Sure, here's an example deadlock that I see,

[jira] [Updated] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Kaplinskiy updated FLINK-12620: Attachment: jstack_snippet.txt > Deadlock in task deserialization >

[jira] [Comment Edited] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849259#comment-16849259 ] Mike Kaplinskiy edited comment on FLINK-12620 at 5/28/19 12:38 AM: ---

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850165#comment-16850165 ] Mike Kaplinskiy commented on FLINK-12620: - With the patch, I'm expecting class initialization to

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16859581#comment-16859581 ] Mike Kaplinskiy commented on FLINK-12620: - Unfortunately my use-case is a bit strange - I'm

[jira] [Updated] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Kaplinskiy updated FLINK-12620: Attachment: BatchJob.java > Deadlock in task deserialization >

[jira] [Updated] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Kaplinskiy updated FLINK-12620: Attachment: jstack_repro.txt > Deadlock in task deserialization >

[jira] [Updated] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Kaplinskiy updated FLINK-12785: Description: I'm running an application that's backfilling data from Kafka. There's

[jira] [Updated] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Kaplinskiy updated FLINK-12785: Description: I'm running an application that's backfilling data from Kafka. There's

[jira] [Commented] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16861347#comment-16861347 ] Mike Kaplinskiy commented on FLINK-12785: - [~klion26] you can go ahead. I know that the 

[jira] [Updated] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Kaplinskiy updated FLINK-12785: Description: I'm running an application that's backfilling data from Kafka. There's

[jira] [Created] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

Mike Kaplinskiy created FLINK-12785: --- Summary: RocksDB savepoint recovery can use a lot of unmanaged memory Key: FLINK-12785 URL: https://issues.apache.org/jira/browse/FLINK-12785 Project: Flink

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16874305#comment-16874305 ] Mike Kaplinskiy commented on FLINK-7289: I've been battling the RocksDB memory usage on my

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905473#comment-16905473 ] Mike Kaplinskiy commented on FLINK-7289: [~aiyangar] I was testing on an unreleased build of 1.9

[jira] [Created] (FLINK-19206) Add an ability to set ownerReference manually in Kubernetes

Mike Kaplinskiy created FLINK-19206: --- Summary: Add an ability to set ownerReference manually in Kubernetes Key: FLINK-19206 URL: https://issues.apache.org/jira/browse/FLINK-19206 Project: Flink

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17236826#comment-17236826 ] Mike Kaplinskiy commented on FLINK-12620: - We discovered a workaround to this problem: passing 

[jira] [Commented] (FLINK-19206) Add an ability to set ownerReference manually in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-19206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17234077#comment-17234077 ] Mike Kaplinskiy commented on FLINK-19206: - Hey Yang, thanks for the quick response. Apologies

[jira] [Commented] (FLINK-19206) Add an ability to set ownerReference manually in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-19206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17234322#comment-17234322 ] Mike Kaplinskiy commented on FLINK-19206: - Yep that’s exactly right. Setting an owner reference