Re: Question around Flink's AdaptiveBatchScheduler

2024-04-13 Thread Venkatakrishnan Sowrirajan
Let me state why I think "*jobmanager.adaptive-batch-sche* *duler.default-source-parallelism*" should not be bound by the " *jobmanager.adaptive-batch-sche**duler.max-parallelism*". - Source vertex is unique and does not have any upstream vertices - Downstream vertices read shuffled data par

[jira] [Created] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format

2024-04-13 Thread Andrey Gaskov (Jira)
Andrey Gaskov created FLINK-35098: - Summary: Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format Key: FLINK-35098 URL: https://issues.apache.org/jira/browse/FLINK-35098

Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-04-13 Thread Anupam Aggarwal
Hi David, Thank you for the suggestion. IIUC, you are proposing using an explicit schema string, instead of the schemaID. This makes sense, as it would make the behavior consistent with Avro, although a bit more verbose from a config standpoint. If we go via the schema string route, the user woul

Re: [VOTE] FLIP-399: Flink Connector Doris

2024-04-13 Thread Samrat Deb
+1 ( non binding ) Bests, Samrat On Fri, 12 Apr 2024 at 1:07 PM, Hang Ruan wrote: > +1 (non-binding) > > Best, > Hang > > Martijn Visser 于2024年4月12日周五 05:39写道: > > > +1 (binding) > > > > On Wed, Apr 10, 2024 at 4:34 AM Jing Ge > > wrote: > > > > > +1(binding) > > > > > > Best regards, > > > J