[jira] [Created] (FLINK-4837) flink-streaming-akka source connector

Subhobrata Dey created FLINK-4837: - Summary: flink-streaming-akka source connector Key: FLINK-4837 URL: https://issues.apache.org/jira/browse/FLINK-4837 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15269345#comment-15269345 ] Subhobrata Dey commented on FLINK-3857: --- Hello [~fhueske], I'm interested in the task & assigning

[jira] [Assigned] (FLINK-3857) Add reconnect attempt to Elasticsearch host

[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhobrata Dey reassigned FLINK-3857: - Assignee: Subhobrata Dey > Add reconnect attempt to Elasticsearch host >

[jira] [Commented] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

[ https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182331#comment-15182331 ] Subhobrata Dey commented on FLINK-3387: --- Hello [~StephanEwen], Thanks for replying. I need some

[jira] [Commented] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

[ https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15156147#comment-15156147 ] Subhobrata Dey commented on FLINK-3387: --- Hello [~StephanEwen], I see that each class is creating

[jira] [Commented] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

[ https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15147597#comment-15147597 ] Subhobrata Dey commented on FLINK-3387: --- Hello [~StephanEwen], if nobody is working on this issue,

[jira] [Commented] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15141013#comment-15141013 ] Subhobrata Dey commented on FLINK-3035: --- [~mjsax] [~aljoscha] I'll move this discussion to dev

[jira] [Commented] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15140239#comment-15140239 ] Subhobrata Dey commented on FLINK-3035: --- Hello [~mjsax] Thanks for replying. I adopted & created a

[jira] [Commented] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136075#comment-15136075 ] Subhobrata Dey commented on FLINK-3035: --- Hello [~mjsax], I had a look into the rocksdb state backend

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15131661#comment-15131661 ] Subhobrata Dey commented on FLINK-2678: --- [~till.rohrmann] Please help in reviewing the new commit.

[jira] [Assigned] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhobrata Dey reassigned FLINK-3035: - Assignee: Subhobrata Dey > Redis as State Backend > -- > >

[jira] [Commented] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128367#comment-15128367 ] Subhobrata Dey commented on FLINK-3035: --- Hello [~mjsax], Yes, I'm interested in the issue & would

[jira] [Commented] (FLINK-3276) Move runtime parts of flink-streaming-java to flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126524#comment-15126524 ] Subhobrata Dey commented on FLINK-3276: --- Hello Maximilian, If nobody else is working on this issue,

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122486#comment-15122486 ] Subhobrata Dey commented on FLINK-2678: --- Hello Till, I was checking the implementation of

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

[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122563#comment-15122563 ] Subhobrata Dey commented on FLINK-3033: --- Hello, If nobody is working on this issue, I would like to

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

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122562#comment-15122562 ] Subhobrata Dey commented on FLINK-3034: --- Hello, if nobody is working on this issue, I would like to

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121366#comment-15121366 ] Subhobrata Dey commented on FLINK-2678: --- Hello Till, If no one is working on this issue, can I take

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121516#comment-15121516 ] Subhobrata Dey commented on FLINK-2678: --- Hello Till, Please assign me the issue. I would like to

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15120520#comment-15120520 ] Subhobrata Dey commented on FLINK-2985: --- Hello, I want to work on this issue. Can somebody kindly

[jira] [Created] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported

Subhobrata Dey created FLINK-3292: - Summary: Bug in flink-jdbc. Not all JDBC drivers supported Key: FLINK-3292 URL: https://issues.apache.org/jira/browse/FLINK-3292 Project: Flink Issue