[
https://issues.apache.org/jira/browse/FLINK-33606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788604#comment-17788604
]
Benchao Li commented on FLINK-33606:
------------------------------------
Leaving out streaming/changelog out of Flink JDBC Driver was intentional, since
AFAIK there is no such protocols in JDBC yet.
As you said, "This is a very useful addition as there are plenty of tools which
can now connect to Flink and run SQL.", this all uses the standard JDBC
protocol. Are u proposing to add a specific method to {{FlinkResultSet}} to get
the {{RowKind}}? I'm wondering how will you gonna to use that method,
especially for existing tools that constructed against standard JDBC protocol?
> Support streaming mode in Flink JDBC driver
> -------------------------------------------
>
> Key: FLINK-33606
> URL: https://issues.apache.org/jira/browse/FLINK-33606
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / JDBC
> Affects Versions: 1.18.0
> Reporter: Sangram Reddy
> Priority: Major
>
> With Flink's 1.18 release we now have JDBC driver for Flink. This is a very
> useful addition as there are plenty of tools which can now connect to Flink
> and run SQL.
> However, one notable difference with other JDBC drivers vs. Flink is the
> streaming/dynamic tables where the data is continously updated. For example,
> we can run an aggregate query with GROUP BY and the groups are always being
> updated as the fresh data arrives.
> This is extremely useful for real-time monitoring applications. However, the
> current JDBC driver implementation only supports batch mode.
> This is Jira is to add support for streaming mode for Flink JDBC driver.
>
> Implementation details:
> FlinkResultSet doesn't have any additional methods to expose RowKind or the
> unique ID for that row. However this information is already available in
> FlinkResultSet class, it just needs to be exposed via methods.
>
> Wiki page with relevant details:
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-293%3A+Introduce+Flink+Jdbc+Driver+For+Sql+Gateway
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
