[jira] [Created] (FLINK-31022) Using new Serializer for table store

Jingsong Lee created FLINK-31022: Summary: Using new Serializer for table store Key: FLINK-31022 URL: https://issues.apache.org/jira/browse/FLINK-31022 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Promote SinkV2 to @Public and deprecate SinkFunction

Regarding this part: @Dong > And Yuxia mentioned earlier in this thread that there are bugs such as FLINK-30238 and FLINK-29459 , which makes it hard to use SinkV2 properly in production. I'll

[jira] [Created] (FLINK-31023) Introduce ConfigOption for table store

Jingsong Lee created FLINK-31023: Summary: Introduce ConfigOption for table store Key: FLINK-31023 URL: https://issues.apache.org/jira/browse/FLINK-31023 Project: Flink Issue Type: Improvemen

Proposal to mark package private classes public

Hi Flink community, Was wondering if it is possible to mark the following DynamicKafkaDeserializationSchema https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java D

Re: [DISCUSS] Promote SinkV2 to @Public and deprecate SinkFunction

Hi Galen, I am not directly involved in the creation of FLINK-30238 and my understanding could be incorrect. But yes, I get a similar sense as you do. According to FLINK-30238's description, there is the risk of losing data if we use stop-with-sa

Re: [DISCUSS] Promote SinkV2 to @Public and deprecate SinkFunction

Hi Martijn, Thanks for the reply. Please see my comments inline. Regards, Dong On Sat, Feb 11, 2023 at 4:31 AM Martijn Visser wrote: > Hi all, > > I wanted to get back on a couple of comments and have a proposal at the end > for the next steps: > > @Steven Wu > If I look back at the original d

[jira] [Created] (FLINK-31024) Copy code splitter to table store from flink table

Jingsong Lee created FLINK-31024: Summary: Copy code splitter to table store from flink table Key: FLINK-31024 URL: https://issues.apache.org/jira/browse/FLINK-31024 Project: Flink Issue Type