[
https://issues.apache.org/jira/browse/FLINK-33606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788734#comment-17788734
]
Sangram Reddy commented on FLINK-33606:
---------------------------------------
Hi,
So the tools will evolve and adapt. We are building a UI based on Flink SQL,
and right now we can not do streaming for aggregated queries.
Moreover, we are not breaking any JDBC contract with changes, we are going to
provide some additional features on top of plain JDBC. This is true for many of
the databases where there's some special feature.
With FlinkResultSet/FlinkResultSetMetaData, we can optionally provide metadata
for RowKind and Unique ID for the row (hash value of the object). These are
already available in the implementation but not exposed.
> 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)
