Re: Re:Re: Re: Re: Re: [DISCUSS] FLIP-218: Support SELECT clause in CREATE TABLE(CTAS)

Thanks for the update, Mang and Ron, The new proposal looks good to me in general, especially keeping the behavior consistent between batch and streaming mode by default. This is how we do it in the previous "table.dml-sync" option on ML [1]. Besides that, I just have some final minor comments re

退订

退订

Re: [DISCUSS] FLIP-242: Introduce configurable CongestionControlStrategy for Async Sink

Hi Piotr, Thanks for the further questions. To answer both your questions, let's consider the different flows for interaction between RateLimitingStrategy and AsyncSinkWriter (IMO it is important since it affects the interface!): One potential interaction flow is: 1. AsyncSinkWriter construct

[jira] [Created] (FLINK-28251) flink-avro format reader may thrown ’java.util.NoSuchElementException' Exception in some cases

jinshuangxian created FLINK-28251: - Summary: flink-avro format reader may thrown ’java.util.NoSuchElementException' Exception in some cases Key: FLINK-28251 URL: https://issues.apache.org/jira/browse/FLINK-282

[jira] [Created] (FLINK-28250) exactly-once sink kafka cause out of memory

jinshuangxian created FLINK-28250: - Summary: exactly-once sink kafka cause out of memory Key: FLINK-28250 URL: https://issues.apache.org/jira/browse/FLINK-28250 Project: Flink Issue Type: Bug