[jira] [Comment Edited] (FLINK-4051) RabbitMQ Source might not react to cancel signal

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326810#comment-15326810 ] Subhankar Biswas edited comment on FLINK-4051 at 6/13/16 4:43 AM: --

[jira] [Comment Edited] (FLINK-4051) RabbitMQ Source might not react to cancel signal

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326810#comment-15326810 ] Subhankar Biswas edited comment on FLINK-4051 at 6/13/16 4:42 AM: --

[jira] [Comment Edited] (FLINK-4051) RabbitMQ Source might not react to cancel signal

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326810#comment-15326810 ] Subhankar Biswas edited comment on FLINK-4051 at 6/13/16 4:31 AM: --

[jira] [Comment Edited] (FLINK-4051) RabbitMQ Source might not react to cancel signal

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326810#comment-15326810 ] Subhankar Biswas edited comment on FLINK-4051 at 6/13/16 4:30 AM: --

[jira] [Commented] (FLINK-4051) RabbitMQ Source might not react to cancel signal

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326810#comment-15326810 ] Subhankar Biswas commented on FLINK-4051: - nextDelivery() use take() method of Bl

[jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/2094 [FLINK-3702] Make FieldAccessors support nested field expressions. I finally had some time to complete this, sorry it took so long. I have added `getFieldAccessor` to `TypeInformation`, which

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326578#comment-15326578 ] ASF GitHub Bot commented on FLINK-3702: --- GitHub user ggevay opened a pull request:

[jira] [Comment Edited] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326546#comment-15326546 ] Ivan Mushketyk edited comment on FLINK-3677 at 6/12/16 5:26 PM:

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326546#comment-15326546 ] Ivan Mushketyk commented on FLINK-3677: --- Could you please assign this to me? > File

[jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters

[ https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326513#comment-15326513 ] Ken Krugler commented on FLINK-3839: Hi Robert, >From my email on this... bq. But th

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15326399#comment-15326399 ] ASF GitHub Bot commented on FLINK-3311: --- Github user theomega commented on the issue

[GitHub] flink issue #1771: [FLINK-3311/FLINK-3332] Add Cassandra connector

Github user theomega commented on the issue: https://github.com/apache/flink/pull/1771 I tried out this branch and it works like it should in the scenario I set up: I wrote (so only using the Sink) to a quiet complex columnfamily in a 8 node cassandra cluster. I was using a comple