[jira] [Created] (BAHIR-230) Add Flink Batch SQL support for flink-connector-kudu
Sebastian Liu created BAHIR-230: --- Summary: Add Flink Batch SQL support for flink-connector-kudu Key: BAHIR-230 URL: https://issues.apache.org/jira/browse/BAHIR-230 Project: Bahir Issue Type: Improvement Components: Flink Streaming Connectors Reporter: Sebastian Liu It was glad to see that community's flink-connector-kudu has been reworked recently. The steaming table api has been supported which enable better interaction between Flink SQL and Kudu. With the improvement of batch SQL support by Flink 1.10, we have some requirements to use Flink batch SQL to analyze the data in Kudu. Therefore, flink-connector-kudu needs to be able to support flink batch env. At the same time, filter push is also necessary to reduce unnecessary data interaction. I've done some implementations of this in [https://github.com/apache/bahir-flink/pull/82]. Thx your time for helping review it. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (BAHIR-230) Add Flink Batch SQL support for flink-connector-kudu
[ https://issues.apache.org/jira/browse/BAHIR-230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Liu updated BAHIR-230: External issue URL: https://github.com/apache/bahir-flink/pull/82 > Add Flink Batch SQL support for flink-connector-kudu > > > Key: BAHIR-230 > URL: https://issues.apache.org/jira/browse/BAHIR-230 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: Sebastian Liu >Priority: Major > Labels: pull-request-available > > It was glad to see that community's flink-connector-kudu has been reworked > recently. The steaming table api has been supported which enable better > interaction between Flink SQL and Kudu. With the improvement of batch SQL > support by Flink 1.10, we have some requirements to use Flink batch SQL to > analyze the data in Kudu. Therefore, flink-connector-kudu needs to be able to > support flink batch env. At the same time, filter push is also necessary to > reduce unnecessary data interaction. I've done some implementations of this > in [https://github.com/apache/bahir-flink/pull/82]. Thx your time for helping > review it. -- This message was sent by Atlassian Jira (v8.3.4#803005)
