[jira] [Commented] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

[ https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16245474#comment-16245474 ] Erik van Oosten commented on FLINK-5633: bq. Just curious, why are you creating a new reader for

[jira] [Commented] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

[ https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241701#comment-16241701 ] Erik van Oosten commented on FLINK-5633: [~StephanEwen] We need to process 130K msg/s, I guess

[jira] [Commented] (FLINK-4796) Add new Sink interface with access to more meta data

[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166443#comment-16166443 ] Erik van Oosten commented on FLINK-4796: I am not sure why this is marked as a duplicate. The

[jira] [Commented] (FLINK-4796) Add new Sink interface with access to more meta data

[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160810#comment-16160810 ] Erik van Oosten commented on FLINK-4796: A workaround is to override {{setRuntimeContext}} (make

[jira] [Commented] (FLINK-1390) java.lang.ClassCastException: X cannot be cast to X

[ https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058708#comment-16058708 ] Erik van Oosten commented on FLINK-1390: See

[jira] [Commented] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

[ https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058706#comment-16058706 ] Erik van Oosten commented on FLINK-5633: In case you need throughput (like we do), the caching is

[jira] [Comment Edited] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050925#comment-16050925 ] Erik van Oosten edited comment on FLINK-6928 at 6/15/17 6:39 PM: - In my

[jira] [Commented] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050925#comment-16050925 ] Erik van Oosten commented on FLINK-6928: In my ideal world method {{getTargetTopic}} would be

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Description: When using a Kafka sink, the defaultTopic needs to exist even when it is never

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Description: When using a Kafka sink, the defaultTopic needs to exist even when it is never

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Summary: Kafka sink: default topic should not need to exist (was: Kafka source: default

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Description: When using a Kafka sink, the defaultTopic needs to exist even when it is never

[jira] [Updated] (FLINK-6928) Kafka source: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Summary: Kafka source: default topic should not need to exist (was: Kafka source: default

[jira] [Created] (FLINK-6928) Kafka source: default topic needs to exist

Erik van Oosten created FLINK-6928: -- Summary: Kafka source: default topic needs to exist Key: FLINK-6928 URL: https://issues.apache.org/jira/browse/FLINK-6928 Project: Flink Issue Type: Bug