Re: [ANNOUNCE] New PMC member: Yuan Mei

2022-03-15 Thread Yang Wang
Congratulations, Yuan! Best, Yang Lincoln Lee 于2022年3月15日周二 13:32写道: > Congratulations, Yuan! > > Best, > Lincoln Lee > > > godfrey he 于2022年3月15日周二 09:53写道: > > > Congratulations, Yuan! > > > > Best, > > Godfrey > > > > Lijie Wang 于2022年3月15日周二 09:18写道: > > > > > > Congratulations, Yuan! > >

Re: [ANNOUNCE] New PMC member: Yuan Mei

2022-03-15 Thread Yuxin Tan
Congratulations, Yuan! Best, Yuxin Yang Wang 于2022年3月15日周二 15:00写道: > Congratulations, Yuan! > > Best, > Yang > > Lincoln Lee 于2022年3月15日周二 13:32写道: > > > Congratulations, Yuan! > > > > Best, > > Lincoln Lee > > > > > > godfrey he 于2022年3月15日周二 09:53写道: > > > > > Congratulations, Yuan! > > >

[jira] [Created] (FLINK-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic

2022-03-15 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-26645: --- Summary: Pulsar Source subscribe to a single topic partition will consume all partitions from that topic Key: FLINK-26645 URL: https://issues.apache.org/jira/browse/FLINK-26645

[jira] [Created] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Yang Wang (Jira)
Yang Wang created FLINK-26646: - Summary: Flink kubernetes operator helm template is broken Key: FLINK-26646 URL: https://issues.apache.org/jira/browse/FLINK-26646 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26647) Can not add extra config files on native Kubernetes

2022-03-15 Thread Zhe Wang (Jira)
Zhe Wang created FLINK-26647: Summary: Can not add extra config files on native Kubernetes Key: FLINK-26647 URL: https://issues.apache.org/jira/browse/FLINK-26647 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26648) Ban dependencies on flink-table-planner and depend on flink-table-planner-loader instead

2022-03-15 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-26648: --- Summary: Ban dependencies on flink-table-planner and depend on flink-table-planner-loader instead Key: FLINK-26648 URL: https://issues.apache.org/jira/browse/FLINK-26648

[jira] [Created] (FLINK-26649) Add startTime in JobStatus

2022-03-15 Thread Yang Wang (Jira)
Yang Wang created FLINK-26649: - Summary: Add startTime in JobStatus Key: FLINK-26649 URL: https://issues.apache.org/jira/browse/FLINK-26649 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

2022-03-15 Thread Yun Tang (Jira)
Yun Tang created FLINK-26650: Summary: Avoid to print stack trace for checkpoint trigger failure if not all tasks are started Key: FLINK-26650 URL: https://issues.apache.org/jira/browse/FLINK-26650 Projec

Re: [ANNOUNCE] New PMC member: Yuan Mei

2022-03-15 Thread Qingsheng Ren
Congratulations Yuan! Best regards, Qingsheng Ren > On Mar 15, 2022, at 15:09, Yuxin Tan wrote: > > Congratulations, Yuan! > > Best, > Yuxin > > Yang Wang 于2022年3月15日周二 15:00写道: > >> Congratulations, Yuan! >> >> Best, >> Yang >> >> Lincoln Lee 于2022年3月15日周二 13:32写道: >> >>> Congratulati

Re: [ANNOUNCE] New PMC member: Yuan Mei

2022-03-15 Thread Jark Wu
Congrats Yuan! Well deserved! Best, Jark On Tue, 15 Mar 2022 at 17:42, Qingsheng Ren wrote: > Congratulations Yuan! > > Best regards, > > Qingsheng Ren > > > On Mar 15, 2022, at 15:09, Yuxin Tan wrote: > > > > Congratulations, Yuan! > > > > Best, > > Yuxin > > > > Yang Wang 于2022年3月15日周二 15:0

Re: [ANNOUNCE] release-1.15 branch cut

2022-03-15 Thread Chesnay Schepler
Correction: The fixVersion should not contain 1.15.0 and 1.16.0 at the same time, but only 1.15.0. On 14/03/2022 18:35, Yun Gao wrote: Hi devs, The release-1.15 branch has been forked out from the master branch, at the commit 9c77f13e587d7cb52469cac934c6aaec28dcd17d. Also, the version on the m

[jira] [Created] (FLINK-26651) The connector CI build timeout in azure

2022-03-15 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-26651: -- Summary: The connector CI build timeout in azure Key: FLINK-26651 URL: https://issues.apache.org/jira/browse/FLINK-26651 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26652) Failing to cleanup a job should not fail the flink cluster

2022-03-15 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26652: - Summary: Failing to cleanup a job should not fail the flink cluster Key: FLINK-26652 URL: https://issues.apache.org/jira/browse/FLINK-26652 Project: Flink

[ANNOUNCE] Apache Flink 1.1.4.4 released

2022-03-15 Thread Konstantin Knauf
The Apache Flink community is very happy to announce the release of Apache Flink 1.14.4, which is the third bugfix release for the Apache Flink 1.14 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming a

Re: [ANNOUNCE] Apache Flink 1.1.4.4 released

2022-03-15 Thread Martijn Visser
Thank you Konstantin and everyone who contributed! On Tue, 15 Mar 2022 at 14:22, Konstantin Knauf wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.14.4, which is the third bugfix release for the Apache Flink 1.14 > series. > > Apache Flink® is an open

[jira] [Created] (FLINK-26653) [umbrella] Enhance Table Store SQL ITCases

2022-03-15 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26653: Summary: [umbrella] Enhance Table Store SQL ITCases Key: FLINK-26653 URL: https://issues.apache.org/jira/browse/FLINK-26653 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-26654) Add support for Apicurio Schema Registry

2022-03-15 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26654: -- Summary: Add support for Apicurio Schema Registry Key: FLINK-26654 URL: https://issues.apache.org/jira/browse/FLINK-26654 Project: Flink Issue Type: New

[jira] [Created] (FLINK-26655) Merge isJobManagerPortReady and isJobManagerServing to check if JM pod can work correctly

2022-03-15 Thread Biao Geng (Jira)
Biao Geng created FLINK-26655: - Summary: Merge isJobManagerPortReady and isJobManagerServing to check if JM pod can work correctly Key: FLINK-26655 URL: https://issues.apache.org/jira/browse/FLINK-26655 P

[jira] [Created] (FLINK-26656) Change/remove mentions of "mode" in Source and Sink documentation

2022-03-15 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26656: -- Summary: Change/remove mentions of "mode" in Source and Sink documentation Key: FLINK-26656 URL: https://issues.apache.org/jira/browse/FLINK-26656 Project: Flink

回复:Re: Fwd: [DISCUSS] Flink's supported APIs and Hive query syntax

2022-03-15 Thread 罗宇侠(莫辞)
Hi, thanks for the inputs. ​I wrote a google doc “Plan for decoupling Hive connector with Flink planner” [1] that shows how to decouple Hive connector with planner. [1] https://docs.google.com/document/d/1LMQ_mWfB_mkYkEBCUa2DgCO2YdtiZV7YRs2mpXyjdP4/edit?usp=sharing Best, Yuxia.--

[jira] [Created] (FLINK-26657) Resilient Kinesis consumption

2022-03-15 Thread John Karp (Jira)
John Karp created FLINK-26657: - Summary: Resilient Kinesis consumption Key: FLINK-26657 URL: https://issues.apache.org/jira/browse/FLINK-26657 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-26658) Migrate documentation generation to Github Actions

2022-03-15 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-26658: Summary: Migrate documentation generation to Github Actions Key: FLINK-26658 URL: https://issues.apache.org/jira/browse/FLINK-26658 Project: Flink Is

[jira] [Created] (FLINK-26659) Document UI access via Ingress

2022-03-15 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-26659: - Summary: Document UI access via Ingress Key: FLINK-26659 URL: https://issues.apache.org/jira/browse/FLINK-26659 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26660) Specify EventSource when watching multiple namespaces

2022-03-15 Thread Jira
Márton Balassi created FLINK-26660: -- Summary: Specify EventSource when watching multiple namespaces Key: FLINK-26660 URL: https://issues.apache.org/jira/browse/FLINK-26660 Project: Flink Iss

[jira] [Created] (FLINK-26661) Document Pod template usage

2022-03-15 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26661: -- Summary: Document Pod template usage Key: FLINK-26661 URL: https://issues.apache.org/jira/browse/FLINK-26661 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-26662) Document logging & metrics configs for Operator

2022-03-15 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26662: -- Summary: Document logging & metrics configs for Operator Key: FLINK-26662 URL: https://issues.apache.org/jira/browse/FLINK-26662 Project: Flink Issue Type: Sub-t

Re: [DISCUSS] Conventions on assertions to use in tests

2022-03-15 Thread Francesco Guardiani
Hi all. I've worked on a little tool to try to automatize a bit the conversion of assertions to assertj https://github.com/slinkydeveloper/assertj-migrator. It's not perfect, but it's an attempt to unify a bit the test codebase. We applied it to flink-table modules and it worked like a charm, alt

Re: [ANNOUNCE] Apache Flink 1.1.4.4 released

2022-03-15 Thread Leonard Xu
Thanks a lot for being our release manager Konstantin and everyone who involved! Best, Leonard > 2022年3月15日 下午9:34,Martijn Visser 写道: > > Thank you Konstantin and everyone who contributed!

[jira] [Created] (FLINK-26663) Pod augmentation for the operator

2022-03-15 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-26663: - Summary: Pod augmentation for the operator Key: FLINK-26663 URL: https://issues.apache.org/jira/browse/FLINK-26663 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink

2022-03-15 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26664: Summary: Improve Python exception messages to be more Pythonic in PyFlink Key: FLINK-26664 URL: https://issues.apache.org/jira/browse/FLINK-26664 Project: Flink

[jira] [Created] (FLINK-26665) Improve the error of incomplete pyflink installation package

2022-03-15 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26665: Summary: Improve the error of incomplete pyflink installation package Key: FLINK-26665 URL: https://issues.apache.org/jira/browse/FLINK-26665 Project: Flink

[jira] [Created] (FLINK-26666) Improve the error message of pyflink and flink version mismatch

2022-03-15 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-2: Summary: Improve the error message of pyflink and flink version mismatch Key: FLINK-2 URL: https://issues.apache.org/jira/browse/FLINK-2 Project: Flink

[jira] [Created] (FLINK-26667) Improve the error message that the declared type of UDF is inconsistent with the actual return type

2022-03-15 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26667: Summary: Improve the error message that the declared type of UDF is inconsistent with the actual return type Key: FLINK-26667 URL: https://issues.apache.org/jira/browse/FLINK-2666

[jira] [Created] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

2022-03-15 Thread kangTwang (Jira)
kangTwang created FLINK-26668: - Summary: Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler Key: FLINK-26668 URL: https://issues.apache.org/jira/browse/FLINK-26668

Re: [ANNOUNCE] Apache Flink 1.1.4.4 released

2022-03-15 Thread Xingbo Huang
Thanks a lot for being our release manager Konstantin and everyone who contributed. I have a question about pyflink. I see that there are no corresponding wheel packages uploaded on pypi, only the source package is uploaded. Is there something wrong with building the wheel packages? Best, Xingbo

[jira] [Created] (FLINK-26669) Refactor ReadWriteITCase and add more test cases

2022-03-15 Thread Jane Chan (Jira)
Jane Chan created FLINK-26669: - Summary: Refactor ReadWriteITCase and add more test cases Key: FLINK-26669 URL: https://issues.apache.org/jira/browse/FLINK-26669 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-26670) Rescaling api not working

2022-03-15 Thread Aarsh Shah (Jira)
Aarsh Shah created FLINK-26670: -- Summary: Rescaling api not working Key: FLINK-26670 URL: https://issues.apache.org/jira/browse/FLINK-26670 Project: Flink Issue Type: Bug Components: R

[jira] [Created] (FLINK-26671) Update 'Developer Guide' in README

2022-03-15 Thread Biao Geng (Jira)
Biao Geng created FLINK-26671: - Summary: Update 'Developer Guide' in README Key: FLINK-26671 URL: https://issues.apache.org/jira/browse/FLINK-26671 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-26672) In Table/SQL API, Table configuration ' table.local-time-zone' does not work

2022-03-15 Thread RuiLin-Zhang (Jira)
RuiLin-Zhang created FLINK-26672: Summary: In Table/SQL API, Table configuration ' table.local-time-zone' does not work Key: FLINK-26672 URL: https://issues.apache.org/jira/browse/FLINK-26672 Project: