[jira] [Created] (FLINK-30688) Disable Kryo fallback in Flink ML tests

Dong Lin created FLINK-30688: Summary: Disable Kryo fallback in Flink ML tests Key: FLINK-30688 URL: https://issues.apache.org/jira/browse/FLINK-30688 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Enabling dynamic partition discovery by default in Kafka source

Thanks for the proposal, Qingsheng. +1 to enable auto partition discovery by default. Just a reminder, we need a FLIP for this. A bit more background on this. Most of the Kafka users simply subscribe to a topic and let the consumer to automatically adapt to partition changes. So enabling auto pa

[jira] [Created] (FLINK-30689) Use auto produce bytes schema in Pulsar sink

Yufan Sheng created FLINK-30689: --- Summary: Use auto produce bytes schema in Pulsar sink Key: FLINK-30689 URL: https://issues.apache.org/jira/browse/FLINK-30689 Project: Flink Issue Type: Improv

Re: [DISCUSS] Enabling dynamic partition discovery by default in Kafka source

Thanks Qingsheng for the proposal. +1 for the change. On Fri, Jan 13, 2023 at 11:32 AM Qingsheng Ren wrote: > Hi devs, > > I’d like to start a discussion about enabling the dynamic partition > discovery feature by default in Kafka source. Dynamic partition discovery > [1] is a useful feature in

[jira] [Created] (FLINK-30690) java document, web document, word some error perfect

zheju_he created FLINK-30690: Summary: java document, web document, word some error perfect Key: FLINK-30690 URL: https://issues.apache.org/jira/browse/FLINK-30690 Project: Flink Issue Type: Impr