[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 Feature Components: Streaming Connectors Reporter: Subhobrata Dey Hello, This issue is created to propose the idea of having a flink-streaming-akka source connector. The source connector can be used to receive messages from an Akka feeder or publisher actor & these messages can then be processed using flink streaming. The source connector has the following features. 1. It can supports several different message formats like iterable data, bytes array & data with timestamp. 2. It can send back acknowledgements to the feeder actor. Thanks & regards, Subhobrata -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[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 Type: Bug Components: other Affects Versions: 1.0.0 Reporter: Subhobrata Dey Priority: Minor Fix For: 1.0.0 Hello, In method open in JDBCInputFormat.java, while using dbConn.createStatement, the resultSetType & resultSetConcurrency are hardcoded. These two fields may vary with different JDBC drivers & hence it fails in a few cases like SAP HANA Jdbc driver. There are two variants of the method dbCon.createStatement, one with parameters & the other without parameters. Both should be supported. Thanks & regards, Subhobrata -- This message was sent by Atlassian JIRA (v6.3.4#6332)
