[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336643#comment-17336643
]
Flink Jira Bot commented on FLINK-9009:
---
This issue was labeled "stale-major" 7 ago and has not
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17328645#comment-17328645
]
Flink Jira Bot commented on FLINK-9009:
---
This major issue is unassigned and itself and all of its
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999056#comment-16999056
]
Subramanyam Ramanathan commented on FLINK-9009:
---
Hi,
I'm seeing a similar issue when using
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16415318#comment-16415318
]
Stephan Ewen commented on FLINK-9009:
-
I think the fact that each task has a separate classloader
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413803#comment-16413803
]
Chesnay Schepler commented on FLINK-9009:
-
Doesn't child-first classloading prevent us from doing
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413645#comment-16413645
]
Stephan Ewen commented on FLINK-9009:
-
If the connection is explicitly meant to be shared between
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413587#comment-16413587
]
Pankaj commented on FLINK-9009:
---
CassandraSink when given parallelism=10 at enviornment level. It creates 10
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404850#comment-16404850
]
Chesnay Schepler commented on FLINK-9009:
-
The error message is due to netty's leak detector which
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404760#comment-16404760
]
Pankaj commented on FLINK-9009:
---
Also, If we remove CassandraSink. Everything works fine. One can also check
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404223#comment-16404223
]
Stephan Ewen commented on FLINK-9009:
-
This does not look like a Flink issue. Rather related to
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403461#comment-16403461
]
Pankaj commented on FLINK-9009:
---
Stacktrace
Sink: Cassandra Sink, Filter -> Flat Map -> Sink: Unnamed,
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402323#comment-16402323
]
Pankaj commented on FLINK-9009:
---
No, Is not related with Kafka. I have already tried and check the problem
[
https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401901#comment-16401901
]
Stephan Ewen commented on FLINK-9009:
-
I assume that error is reported by Kafka?
Can you past the
13 matches
Mail list logo