[jira] [Created] (FLINK-28725) flink-kubernetes-operator taskManager: replicas: 2 error

2022-07-27 Thread lizu18xz (Jira)
lizu18xz created FLINK-28725: Summary: flink-kubernetes-operator taskManager: replicas: 2 error Key: FLINK-28725 URL: https://issues.apache.org/jira/browse/FLINK-28725 Project: Flink Issue

[jira] [Created] (FLINK-28724) Test

2022-07-27 Thread HuangRufei (Jira)
HuangRufei created FLINK-28724: -- Summary: Test Key: FLINK-28724 URL: https://issues.apache.org/jira/browse/FLINK-28724 Project: Flink Issue Type: Bug Reporter: HuangRufei --

Re: I want to contribute to Apache Flink.

2022-07-27 Thread Xingbo Huang
Hi, Thanks for reaching out. Please follow https://flink.apache.org/contributing/contribute-code.html to start with your contribution. You don't need to be in any list to start your contribution. Best, Xingbo 黄如飞 <1369612...@qq.com.invalid> 于2022年7月28日周四 11:25写道: > Hi Guys, > I want to

I want to contribute to Apache Flink.

2022-07-27 Thread ??????
Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA username is Rufy666 ?? 1369612...@qq.com

[jira] [Created] (FLINK-28723) Support json format to serialize the MapData when its key is not STRING

2022-07-27 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28723: - Summary: Support json format to serialize the MapData when its key is not STRING Key: FLINK-28723 URL: https://issues.apache.org/jira/browse/FLINK-28723 Project:

[jira] [Created] (FLINK-28722) Hybrid Source should use .equals() for Integer comparison

2022-07-27 Thread Mason Chen (Jira)
Mason Chen created FLINK-28722: -- Summary: Hybrid Source should use .equals() for Integer comparison Key: FLINK-28722 URL: https://issues.apache.org/jira/browse/FLINK-28722 Project: Flink Issue

[jira] [Created] (FLINK-28721) Support Protobuf in DataStream API

2022-07-27 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-28721: -- Summary: Support Protobuf in DataStream API Key: FLINK-28721 URL: https://issues.apache.org/jira/browse/FLINK-28721 Project: Flink Issue Type: New

Re: [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-27 Thread Gyula Fóra
+1 (binding) Gyula On Wed, 27 Jul 2022 at 03:52, MrL wrote: > +1 (non-binding) > > > 2022年7月27日 09:18,William Wang 写道: > > > > +1 (non-binding) > > > > bo zhaobo 于2022年7月25日周一 09:38写道: > > > >> Hi all, > >> > >> Thank you very much for all feedback after the discussion in [2][3]. > >> Now

Re: [VOTE] FLIP-243: Dedicated Opensearch connectors

2022-07-27 Thread Ryan Skraba
Hello! I'd like to add my non-binding +1 for this FLIP. Full disclosure: as a colleague of Andriy, I sometimes hear the gory details of divergence between Elasticsearch and OpenSearch. Objectively, this is a good reason to create independent OpenSearch connectors. As a side comment, while

Re: [VOTE] FLIP-248: Introduce dynamic partition pruning

2022-07-27 Thread Jing Zhang
+1 (binding) Best, Jing Zhang Jingsong Li 于2022年7月27日周三 16:52写道: > +1 > > On Wed, Jul 27, 2022 at 3:30 PM Jark Wu wrote: > > > > +1 (binding) > > > > Best, > > Jark > > > > On Wed, 27 Jul 2022 at 13:34, Yun Gao > wrote: > > > > > +1 (binding) > > > > > > Thanks for proposing the FLIP! > > >

Re: I want to contribute to Apache Flink.

2022-07-27 Thread Jing Ge
Hi, Do you mean you want to have the access rights to the FLIP wiki page[1]? Your confluence ID is required in this case, which is different from the Jira ID. Generally, you don't need any specific permissions to do contributions. Please follow the introduction [1] and then find some jira issues

I want to contribute to Apache Flink.

2022-07-27 Thread ??????
Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is Rufy666. ?? 1369612...@qq.com

[jira] [Created] (FLINK-28720) Add Hive partition when flink has no data to write

2022-07-27 Thread tartarus (Jira)
tartarus created FLINK-28720: Summary: Add Hive partition when flink has no data to write Key: FLINK-28720 URL: https://issues.apache.org/jira/browse/FLINK-28720 Project: Flink Issue Type:

[jira] [Created] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

2022-07-27 Thread Mykyta Mykhailenko (Jira)
Mykyta Mykhailenko created FLINK-28719: -- Summary: Mapping a data source before window aggregation causes Flink to stop handle late events correctly. Key: FLINK-28719 URL:

[jira] [Created] (FLINK-28718) SinkSavepointITCase.testRecoverFromSavepoint is unstable

2022-07-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28718: Summary: SinkSavepointITCase.testRecoverFromSavepoint is unstable Key: FLINK-28718 URL: https://issues.apache.org/jira/browse/FLINK-28718 Project: Flink

[jira] [Created] (FLINK-28717) Table Store Hive connector will throw exception if primary key fields are not selected

2022-07-27 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-28717: --- Summary: Table Store Hive connector will throw exception if primary key fields are not selected Key: FLINK-28717 URL: https://issues.apache.org/jira/browse/FLINK-28717

[jira] [Created] (FLINK-28716) uploading multiple files/form datas fail randomly when use rest api

2022-07-27 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-28716: - Summary: uploading multiple files/form datas fail randomly when use rest api Key: FLINK-28716 URL: https://issues.apache.org/jira/browse/FLINK-28716 Project: Flink

[jira] [Created] (FLINK-28715) Throw better exception when file not found in reading

2022-07-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28715: Summary: Throw better exception when file not found in reading Key: FLINK-28715 URL: https://issues.apache.org/jira/browse/FLINK-28715 Project: Flink Issue

[jira] [Created] (FLINK-28714) Resolve CVEs from beam-vendor-grpc-1_26_0-0.3

2022-07-27 Thread Bilna (Jira)
Bilna created FLINK-28714: - Summary: Resolve CVEs from beam-vendor-grpc-1_26_0-0.3 Key: FLINK-28714 URL: https://issues.apache.org/jira/browse/FLINK-28714 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28713) Remove unused curator-test dependency from flink-test-utils

2022-07-27 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-28713: Summary: Remove unused curator-test dependency from flink-test-utils Key: FLINK-28713 URL: https://issues.apache.org/jira/browse/FLINK-28713 Project: Flink

[jira] [Created] (FLINK-28712) Default Changelog all when changelog producer is input

2022-07-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28712: Summary: Default Changelog all when changelog producer is input Key: FLINK-28712 URL: https://issues.apache.org/jira/browse/FLINK-28712 Project: Flink Issue

[jira] [Created] (FLINK-28711) Hive connector implements SupportsDynamicFiltering interface

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28711: -- Summary: Hive connector implements SupportsDynamicFiltering interface Key: FLINK-28711 URL: https://issues.apache.org/jira/browse/FLINK-28711 Project: Flink

[jira] [Created] (FLINK-28710) Transform dpp ExecNode to StreamGraph

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28710: -- Summary: Transform dpp ExecNode to StreamGraph Key: FLINK-28710 URL: https://issues.apache.org/jira/browse/FLINK-28710 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28709) Implement dynamic filtering operators

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28709: -- Summary: Implement dynamic filtering operators Key: FLINK-28709 URL: https://issues.apache.org/jira/browse/FLINK-28709 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28708) Introduce planner rules to optimize dpp pattern

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28708: -- Summary: Introduce planner rules to optimize dpp pattern Key: FLINK-28708 URL: https://issues.apache.org/jira/browse/FLINK-28708 Project: Flink Issue Type:

Re: [VOTE] FLIP-247 Bulk fetch of table and column statistics for given partitions

2022-07-27 Thread Rui Fan
+1 non-binding Best Rui Fan On Tue, Jul 26, 2022 at 4:05 PM Jingsong Li wrote: > +1 > > Best, > Jingsong > > On Tue, Jul 26, 2022 at 10:11 AM godfrey he wrote: > > > > +1 > > > > Best, > > Godfrey > > > > Jark Wu 于2022年7月25日周一 17:23写道: > > > > > > +1 (binding) > > > > > > Best, > > > Jark >

[jira] [Created] (FLINK-28707) Introduce interface SupportsDynamicPartitionPruning

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28707: -- Summary: Introduce interface SupportsDynamicPartitionPruning Key: FLINK-28707 URL: https://issues.apache.org/jira/browse/FLINK-28707 Project: Flink Issue Type:

[jira] [Created] (FLINK-28706) FLIP-248: Introduce dynamic partition pruning

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28706: -- Summary: FLIP-248: Introduce dynamic partition pruning Key: FLINK-28706 URL: https://issues.apache.org/jira/browse/FLINK-28706 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28705) Update copyright year to 2014-2022 in NOTICE files

2022-07-27 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-28705: -- Summary: Update copyright year to 2014-2022 in NOTICE files Key: FLINK-28705 URL: https://issues.apache.org/jira/browse/FLINK-28705 Project: Flink Issue

Re: [VOTE] FLIP-248: Introduce dynamic partition pruning

2022-07-27 Thread Jingsong Li
+1 On Wed, Jul 27, 2022 at 3:30 PM Jark Wu wrote: > > +1 (binding) > > Best, > Jark > > On Wed, 27 Jul 2022 at 13:34, Yun Gao wrote: > > > +1 (binding) > > > > Thanks for proposing the FLIP! > > > > Best, > > Yun Gao > > > > > > --

[jira] [Created] (FLINK-28704) Document should add a description that change-log mode cannot support map and multiset data type

2022-07-27 Thread Jane Chan (Jira)
Jane Chan created FLINK-28704: - Summary: Document should add a description that change-log mode cannot support map and multiset data type Key: FLINK-28704 URL: https://issues.apache.org/jira/browse/FLINK-28704

[jira] [Created] (FLINK-28703) Describe partitioned spark table lost partition info

2022-07-27 Thread Jane Chan (Jira)
Jane Chan created FLINK-28703: - Summary: Describe partitioned spark table lost partition info Key: FLINK-28703 URL: https://issues.apache.org/jira/browse/FLINK-28703 Project: Flink Issue Type:

[jira] [Created] (FLINK-28702) Why can't "scan.incremental.snapshot.enabled" be set when using datastream source in MySQL CDC connector

2022-07-27 Thread liujian (Jira)
liujian created FLINK-28702: --- Summary: Why can't "scan.incremental.snapshot.enabled" be set when using datastream source in MySQL CDC connector Key: FLINK-28702 URL: https://issues.apache.org/jira/browse/FLINK-28702

Re: [VOTE] FLIP-248: Introduce dynamic partition pruning

2022-07-27 Thread Jark Wu
+1 (binding) Best, Jark On Wed, 27 Jul 2022 at 13:34, Yun Gao wrote: > +1 (binding) > > Thanks for proposing the FLIP! > > Best, > Yun Gao > > > -- > From:Jing Ge > Send Time:2022 Jul. 27 (Wed.) 03:40 > To:undefined >

[jira] [Created] (FLINK-28701) Minimize the explosion range during failover for hybrid shuffle

2022-07-27 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-28701: -- Summary: Minimize the explosion range during failover for hybrid shuffle Key: FLINK-28701 URL: https://issues.apache.org/jira/browse/FLINK-28701 Project: Flink