[jira] [Created] (FLINK-33459) Introduce the new source that supports the same functionality as the original JDBC input format

RocMarshal created FLINK-33459: -- Summary: Introduce the new source that supports the same functionality as the original JDBC input format Key: FLINK-33459 URL: https://issues.apache.org/jira/browse/FLINK-33459

[jira] [Created] (FLINK-33460) Support more authentication connection types such as the secret.

RocMarshal created FLINK-33460: -- Summary: Support more authentication connection types such as the secret. Key: FLINK-33460 URL: https://issues.apache.org/jira/browse/FLINK-33460 Project: Flink

[jira] [Created] (FLINK-33461) Support stream related semantics for the new jdbc source

RocMarshal created FLINK-33461: -- Summary: Support stream related semantics for the new jdbc source Key: FLINK-33461 URL: https://issues.apache.org/jira/browse/FLINK-33461 Project: Flink Issue Ty

[jira] [Created] (FLINK-33462) Sort out the document page about the new Jdbc source.

RocMarshal created FLINK-33462: -- Summary: Sort out the document page about the new Jdbc source. Key: FLINK-33462 URL: https://issues.apache.org/jira/browse/FLINK-33462 Project: Flink Issue Type:

[jira] [Created] (FLINK-33463) Support the implementation of dynamic source tables based on the new source

RocMarshal created FLINK-33463: -- Summary: Support the implementation of dynamic source tables based on the new source Key: FLINK-33463 URL: https://issues.apache.org/jira/browse/FLINK-33463 Project: Flin

Re: How do I source debug the scala in the flink table planner?

Hi David since you've mentioned FLINK-33365 I'm curious whether you really need to use SQL client? Couldn't you go same way like it's done for tests like apache.flink.connector.jdbc.table.JdbcDynamicTableSourceITCase and just use TableEnvironment something like env = StreamExecutionEnviro

[DISCUSS] Release Flink 1.16.3

Hi all, I would like to discuss creating a new 1.16 patch release (1.16.3). The last 1.16 release is over five months old, and since then, 50 tickets have been closed [1], of which 10 are blocker/critical [2]. Some of them are quite important, such as FLINK-32296 [3], FLINK-32548 [4] and FLINK-330

[DISCUSS] Release 1.17.2

Hi all, I would like to discuss creating a new 1.17 patch release (1.17.2). The last 1.17 release is near half a year old, and since then, 79 tickets have been closed [1], of which 15 are blocker/critical [2]. Some of them are quite important, such as FLINK-32758 [3], FLINK-32296 [4], FLINK-32548

Re: [DISCUSS] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

Hi Jing, Thank you for your feedback on the proposal. I appreciate your input and understand your concerns. Regarding your questions, the complex Java class that will be deprecated is org.apache.flink.api.common.restartstrategy.RestartStrategies and and its internal classes, which include: - Res

[DISCUSS] Release flink-shaded 16.2

Hi, all, I would like to discuss creating a new 16.2 patch release for flink-shaded[1]. In our ARM environment, we recently encountered a critical bug (FLINK-33417[2]) while using flink-shaded 16.1 in flink 1.17. The issue has been discussed in the discussion[3]. Fortunately, we could resolve thi