[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2020-01-06 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008806#comment-17008806 ] Maximilian Michels commented on BEAM-6289: -- Feel free to open an issue and assign it to yourself,

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2020-01-04 Thread sophie (Jira)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008236#comment-17008236 ] sophie commented on BEAM-6289: -- 2. Change the splitting logic of the SourceInputFormat to perform early

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2019-01-11 Thread Shahar Frank (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740768#comment-16740768 ] Shahar Frank commented on BEAM-6289: [~mxm] Thanks. I saw it. Put that in my todo list. Will

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2019-01-11 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740646#comment-16740646 ] Maximilian Michels commented on BEAM-6289: -- [~srfrnk] Just mentioning you in case you didn't see

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16733688#comment-16733688 ] Maximilian Michels commented on BEAM-6289: -- {quote} Is there any example of how that can be done?

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-31 Thread Shahar Frank (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16731220#comment-16731220 ] Shahar Frank commented on BEAM-6289: [~mxm] - I can confirm that indeed the code runs on a remote

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-28 Thread Shahar Frank (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730450#comment-16730450 ] Shahar Frank commented on BEAM-6289: Great. Thanx. I will give this a try on a remote Flink cluster I

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730441#comment-16730441 ] Maximilian Michels commented on BEAM-6289: -- {quote} The issue was first detected on a remote

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-28 Thread Shahar Frank (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730412#comment-16730412 ] Shahar Frank commented on BEAM-6289: Thanks for the info. I will give these a try later on. Just a

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730390#comment-16730390 ] Maximilian Michels commented on BEAM-6289: -- Thanks for the logs and for the great instructions on

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-27 Thread Shahar Frank (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730091#comment-16730091 ] Shahar Frank commented on BEAM-6289: [~mxm] please see full logs from both direct and flink runners

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729735#comment-16729735 ] Maximilian Michels commented on BEAM-6289: -- Thanks for reporting [~srfrnk]. Could you post the

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-27 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729643#comment-16729643 ] Ismaël Mejía commented on BEAM-6289: [~mxm] Reassigned to you to see if you can eventually give us a