[jira] [Assigned] (FLINK-4045) Test AMQP connector using Apache ActiveMQ emebdded broker

[ https://issues.apache.org/jira/browse/FLINK-4045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas reassigned FLINK-4045: --- Assignee: Subhankar Biswas > Test AMQP connector using Apache ActiveMQ emebdded broke

[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=15327758#comment-15327758 ] Subhankar Biswas commented on FLINK-4051: - OK i'll start working on it. > RabbitM

[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] [Assigned] (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:all-tabpanel ] Subhankar Biswas reassigned FLINK-4051: --- Assignee: Subhankar Biswas > RabbitMQ Source might not react to cancel signal > -

[jira] [Issue Comment Deleted] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas updated FLINK-3769: Comment: was deleted (was: IMO user should be able to build different configuration for queu

[jira] [Issue Comment Deleted] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas updated FLINK-3769: Comment: was deleted (was: IMO user should be able to build different configuration for queu

[jira] [Issue Comment Deleted] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas updated FLINK-3769: Comment: was deleted (was: IMO user should be able to build different configuration for queu

[jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316252#comment-15316252 ] Subhankar Biswas commented on FLINK-3769: - IMO user should be able to build differ

[jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316250#comment-15316250 ] Subhankar Biswas commented on FLINK-3769: - IMO user should be able to build differ

[jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316242#comment-15316242 ] Subhankar Biswas commented on FLINK-3769: - IMO user should be able to build differ

[jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316243#comment-15316243 ] Subhankar Biswas commented on FLINK-3769: - IMO user should be able to build differ

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15307250#comment-15307250 ] Subhankar Biswas commented on FLINK-3763: - Hi [~rmetzger], I am working on this. i

[jira] [Assigned] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas reassigned FLINK-3769: --- Assignee: Subhankar Biswas > RabbitMQ Sink ability to publish to a different exchange

[jira] [Assigned] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas reassigned FLINK-3763: --- Assignee: Subhankar Biswas > RabbitMQ Source/Sink standardize connection parameters >

[jira] [Updated] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas updated FLINK-3769: Assignee: (was: Subhankar Biswas) > RabbitMQ Sink ability to publish to a different exch

[jira] [Assigned] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas reassigned FLINK-3769: --- Assignee: Subhankar Biswas > RabbitMQ Sink ability to publish to a different exchange

[jira] [Assigned] (FLINK-3033) Redis Source Connector

[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] subhankar biswas reassigned FLINK-3033: --- Assignee: subhankar biswas > Redis Source Connector > -- > >

[jira] [Assigned] (FLINK-3034) Redis SInk Connector

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] subhankar biswas reassigned FLINK-3034: --- Assignee: subhankar biswas > Redis SInk Connector > > >

[jira] [Commented] (FLINK-3033) Redis Source Connector

[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122945#comment-15122945 ] subhankar biswas commented on FLINK-3033: - i already finished writing the source.

[jira] [Commented] (FLINK-3034) Redis SInk Connector

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15122946#comment-15122946 ] subhankar biswas commented on FLINK-3034: - i already finished the sink. > Redis