[jira] [Created] (FLINK-35664) Flink CDC pipeline transform supports mask function

2024-06-20 Thread melin (Jira)
melin created FLINK-35664: - Summary: Flink CDC pipeline transform supports mask function Key: FLINK-35664 URL: https://issues.apache.org/jira/browse/FLINK-35664 Project: Flink Issue Type:

[jira] [Created] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

2024-06-20 Thread Yubin Li (Jira)
Yubin Li created FLINK-35663: Summary: Release Testing: FLIP-436: Introduce Catalog-related Syntax Key: FLINK-35663 URL: https://issues.apache.org/jira/browse/FLINK-35663 Project: Flink Issue

Re: [ANNOUNCE] Flink 1.20 feature freeze

2024-06-20 Thread Ferenc Csaky
Hi Xintong, Weijie, Thank you both for your answers! Regarding the CLI deprecation process, I agree that it is tricky business, hence I opened this discussion. The proposal makes sense IMO, I will open a discussion thread. With the present timeline, I think it is reasonable to hold it from

[jira] [Created] (FLINK-35662) Use maven batch mode in k8s-operator CI

2024-06-20 Thread Ferenc Csaky (Jira)
Ferenc Csaky created FLINK-35662: Summary: Use maven batch mode in k8s-operator CI Key: FLINK-35662 URL: https://issues.apache.org/jira/browse/FLINK-35662 Project: Flink Issue Type:

FW: Non Nullable fields within objects

2024-06-20 Thread David Radley
Hi, I am looking to get the Avro format to support Non Nullable fields within objects or arrays. It works with Confluent Avro. I notice https://issues.apache.org/jira/browse/CALCITE-4085 where it looks like Calcite was changed to allow this capability to work with Flink.

Re: [DISCUSS] Support to group rows by column ordinals

2024-06-20 Thread Sergey Nuyanzin
Hey Jeyhun, Thanks for starting the discussion. Could you please elaborate more on use cases of this feature? The one that I see in FLINK-34366[1] is to simplify referencing to aliases in SELECT from GROUP BY (also potentially ORDER BY and HAVING). I wonder whether there is some other use cases

[jira] [Created] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions

2024-06-20 Thread Ivan Burmistrov (Jira)
Ivan Burmistrov created FLINK-35661: --- Summary: MiniBatchGroupAggFunction can silently drop records under certain conditions Key: FLINK-35661 URL: https://issues.apache.org/jira/browse/FLINK-35661

Re: [DISCUSS] Support to group rows by column ordinals

2024-06-20 Thread Muhammet Orazov
Hey Jeyhun, Thanks for bringing it up! +-1 from my side. Personally, I find this feature confusing, it feels always natural to use column names. SQL power users will ask for it, I have seen it used in automated complex queries also. But it seems counterintuitive to enable flag for this

Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released

2024-06-20 Thread Muhammet Orazov
Great, thanks Qingsheng for your efforts! Best, Muhammet On 2024-06-18 15:50, Qingsheng Ren wrote: The Apache Flink community is very happy to announce the release of Apache Flink CDC 3.1.1. Apache Flink CDC is a distributed data integration tool for real time data and batch data, bringing

[jira] [Created] (FLINK-35660) Implement parent-child ordering for DDB Streams source

2024-06-20 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-35660: --- Summary: Implement parent-child ordering for DDB Streams source Key: FLINK-35660 URL: https://issues.apache.org/jira/browse/FLINK-35660 Project: Flink

Re: [VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler

2024-06-20 Thread Matthias Pohl
Thanks for participating everyone. I finalized this vote and posted the results in a separate thread [1]. Best, Matthias [1] https://lists.apache.org/thread/1yb46n9rpvl6htdz57kw2whym4qnjptq On Tue, Jun 18, 2024 at 8:47 PM Thomas Weise wrote: > +1 (binding) > > > On Tue, Jun 18, 2024 at 11:38 

[RESULT][VOTE] FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler

2024-06-20 Thread Matthias Pohl
Hi everyone, the vote [1] for FLIP-461 [2] is over. The number of required binding votes (3) was reached (total: 10, binding: 7, non-binding: 3). No objections were raised. - David Morávek (binding) - Rui Fan (binding) - Zakelly Lan (binding) - Gyula Fóra (binding) - Weijie Guo (binding) - Gabor

[jira] [Created] (FLINK-35659) Fix TestFileSystem Connector error setting execution mode

2024-06-20 Thread dalongliu (Jira)
dalongliu created FLINK-35659: - Summary: Fix TestFileSystem Connector error setting execution mode Key: FLINK-35659 URL: https://issues.apache.org/jira/browse/FLINK-35659 Project: Flink Issue

[jira] [Created] (FLINK-35658) Hybrid shuffle external tier can not work with UnknownInputChannel

2024-06-20 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-35658: - Summary: Hybrid shuffle external tier can not work with UnknownInputChannel Key: FLINK-35658 URL: https://issues.apache.org/jira/browse/FLINK-35658 Project: Flink

[jira] [Created] (FLINK-35657) Flink UI not support show float metric value

2024-06-20 Thread Can Luo (Jira)
Can Luo created FLINK-35657: --- Summary: Flink UI not support show float metric value Key: FLINK-35657 URL: https://issues.apache.org/jira/browse/FLINK-35657 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35656) Hive Source has issues setting max parallelism in dynamic inference mode

2024-06-20 Thread xingbe (Jira)
xingbe created FLINK-35656: -- Summary: Hive Source has issues setting max parallelism in dynamic inference mode Key: FLINK-35656 URL: https://issues.apache.org/jira/browse/FLINK-35656 Project: Flink

[jira] [Created] (FLINK-35655) Support more pipeline sources

2024-06-20 Thread linqigeng (Jira)
linqigeng created FLINK-35655: - Summary: Support more pipeline sources Key: FLINK-35655 URL: https://issues.apache.org/jira/browse/FLINK-35655 Project: Flink Issue Type: New Feature