Re: [ANNOUNCE] New PMC member: Yuan Mei

[Lincoln Lee]

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!
> >
> > Best,
> > Lijie
> >
> > Benchao Li  于2022年3月15日周二 08:18写道：
> >
> > > Congratulations, Yuan!
> > >
> > > Yun Gao  于2022年3月15日周二 01:37写道：
> > >
> > > > Congratulations, Yuan!
> > > >
> > > > Best,
> > > > Yun Gao
> > > >
> > > >
> > > >
> > > > --
> > > > From:Francesco Guardiani 
> > > > Send Time:2022 Mar. 15 (Tue.) 00:21
> > > > To:dev 
> > > > Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > >
> > > > Congratulations, Yuan!
> > > >
> > > > On Mon, Mar 14, 2022 at 3:51 PM yanfei lei 
> wrote:
> > > >
> > > > > Congratulations, Yuan!
> > > > >
> > > > >
> > > > >
> > > > > Zhilong Hong  于2022年3月14日周一 19:31写道：
> > > > >
> > > > > > Congratulations, Yuan!
> > > > > >
> > > > > > Best,
> > > > > > Zhilong
> > > > > >
> > > > > > On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf <
> kna...@apache.org>
> > > > > > wrote:
> > > > > >
> > > > > > > Congratulations, Yuan!
> > > > > > >
> > > > > > > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang <
> beyond1...@gmail.com>
> > > > > > wrote:
> > > > > > >
> > > > > > > > Congratulations, Yuan!
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Jing Zhang
> > > > > > > >
> > > > > > > > Jing Ge  于2022年3月14日周一 18:15写道：
> > > > > > > >
> > > > > > > > > Congrats! Very well deserved!
> > > > > > > > >
> > > > > > > > > Best,
> > > > > > > > > Jing
> > > > > > > > >
> > > > > > > > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> > > > > > pnowoj...@apache.org>
> > > > > > > > > wrote:
> > > > > > > > >
> > > > > > > > > > Congratulations :)
> > > > > > > > > >
> > > > > > > > > > pon., 14 mar 2022 o 09:59 Yun Tang 
> > > > > napisał(a):
> > > > > > > > > >
> > > > > > > > > > > Congratulations, Yuan!
> > > > > > > > > > >
> > > > > > > > > > > Best,
> > > > > > > > > > > Yun Tang
> > > > > > > > > > > 
> > > > > > > > > > > From: Zakelly Lan 
> > > > > > > > > > > Sent: Monday, March 14, 2022 16:55
> > > > > > > > > > > To: dev@flink.apache.org 
> > > > > > > > > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > > > > > > > > >
> > > > > > > > > > > Congratulations, Yuan!
> > > > > > > > > > >
> > > > > > > > > > > Best,
> > > > > > > > > > > Zakelly
> > > > > > > > > > >
> > > > > > > > > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> > > > > > j...@ververica.com>
> > > > > > > > > > wrote:
> > > > > > > > > > >
> > > > > > > > > > > > Congrats Yuan.
> > > > > > > > > > > >
> > > > > > > > > > > > > On 14.03.2022, at 09:45, Arvid Heise <
> ar...@apache.org
> > > >
> > > > > > wrote:
> > > > > > > > > > > > >
> > > > > > > > > > > > > Congratulations and well deserved!
> > > > > > > > > > > > >
> > > > > > > > > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > > > > > > map...@apache.org
> > > > > > > > >
> > > > > > > > > > > wrote:
> > > > > > > > > > > > >
> > > > > > > > > > > > >> Congratulations, Yuan.
> > > > > > > > > > > > >>
> > > > > > > > > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > > > > > > njucs...@gmail.com>
> > > > > > > > > > > wrote:
> > > > > > > > > > > > >>
> > > > > > > > > > > > >>> Congratulations, Yuan!
> > > > > > > > > > > > >>>
> > > > > > > > > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton
> Kalashnikov <
> > > > > > > > > > > kaa@yandex.com>
> > > > > > > > > > > > >>> wrote:
> > > > > > > > > > > > >>>
> > > > > > > > > > > >  Congratulations, Yuan!
> > > > > > > > > > > > 
> > > > > > > > > > > >  --
> > > > > > > > > > > > 
> > > > > > > > > > > >  Best regards,
> > > > > > > > > > > >  Anton Kalashnikov
> > > > > > > > > > > > 
> > > > > > > > > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > > > > > > > > Congratulations Yuan!
> > > > > > > > > > > > >
> > > > > > > > > > > > > Best,
> > > > > > > > > > > > > Leonard
> > > > > > > > > > > > >
> > > > > > > > > > > > >> 2022年3月14日 下午4:09，Yangze Guo <
> karma...@gmail.com>
> > > > 写道：
> > > > > > > > > > > > >>
> > > > > > > > > > > > >> Congratulations!
> > > > > > > > > > > > >>
> > > > > > > > > > > > >> Best,
> > > > > > > > > > > > >> Yangze Guo
> > > > > > > > > > > > >>
> > > > > > > > > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn
> Visser <
> > > > > > > > > > > >  martijnvis...@apache.org> wrote:
> > > > > > > > > > > > >>> Congratulations Yuan!
> > > > > > > > > > > > >>>
> > > > > > > > > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li <
> > > > > car...@gmail.com>
> > > > > > > > > wrote:
> > > > > > > > > > > > >>>
> > > > > > > > > > > >  Hi all!
> > > > > > > > > > > > 
> > > > > > > > > > > >  I'm very happy to announce that Yuan Mei has
> > > > joined
> > > > > > the
> > > > > > > > 

[jira] [Created] (FLINK-26642) Pulsar sink fails with non-partitioned topic

[goldenyang (Jira)]

goldenyang created FLINK-26642:
--

 Summary: Pulsar sink fails with non-partitioned topic
 Key: FLINK-26642
 URL: https://issues.apache.org/jira/browse/FLINK-26642
 Project: Flink
  Issue Type: Bug
  Components: Connectors / Pulsar
Affects Versions: 1.15.0
Reporter: goldenyang


Flink support pulsar sink now in 
[FLINK-20732|https://issues.apache.org/jira/browse/FLINK-20732]. I encountered 
a problem when using pulsar sink in master branch, when I use non-partitioned 
topic.

The current test found that both partitioned topics and non-partitioned topics 
ending with -partition-i can be supported, but ordinary non-partitioned topics 
without -partition-i will have problems, such as 'test_topic'. 

Reproducing the problem requires writing to a non-partitioned topic. Below is 
the stack information when the exception is encountered. I briefly communicated 
with [~Jianyun Zhao] , this may be a bug. 

 
{code:java}
2022-03-08 21:39:13,622 - INFO - 
[flink-akka.actor.default-dispatcher-13:Execution@1419] - Source: Pulsar Source 
-> (Sink: Writer -> Sink: Committer, Sink: Print to Std. Out) (1/6) 
(44af5e8a2b9d553952c7ed3e5d40e672) switched from RUNNING to FAILED on 
54284e57-42a9-4e2e-9c41-54b0ad559832 @ 127.0.0.1 
(dataPort=-1).java.lang.IllegalArgumentException: You should provide topics for 
routing topic by message key hash.at 
org.apache.flink.shaded.guava30.com.google.common.base.Preconditions.checkArgument(Preconditions.java:144)at
 
org.apache.flink.connector.pulsar.sink.writer.router.RoundRobinTopicRouter.route(RoundRobinTopicRouter.java:54)at
 
org.apache.flink.connector.pulsar.sink.writer.PulsarWriter.write(PulsarWriter.java:138)at
 
org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.processElement(SinkWriterOperator.java:124)at
 
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)at
 
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)at
 
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)at
 
org.apache.flink.streaming.runtime.tasks.BroadcastingOutputCollector.collect(BroadcastingOutputCollector.java:77)at
 
org.apache.flink.streaming.runtime.tasks.BroadcastingOutputCollector.collect(BroadcastingOutputCollector.java:32)at
 
org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask$AsyncDataOutputToOutput.emitRecord(SourceOperatorStreamTask.java:205)at
 
org.apache.flink.streaming.api.operators.source.SourceOutputWithWatermarks.collect(SourceOutputWithWatermarks.java:110)at
 
org.apache.flink.connector.pulsar.source.reader.emitter.PulsarRecordEmitter.emitRecord(PulsarRecordEmitter.java:41)at
 
org.apache.flink.connector.pulsar.source.reader.emitter.PulsarRecordEmitter.emitRecord(PulsarRecordEmitter.java:33)at
 
org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:143)at
 
org.apache.flink.connector.pulsar.source.reader.source.PulsarOrderedSourceReader.pollNext(PulsarOrderedSourceReader.java:106)at
 
org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:382)at
 
org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68)at
 
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)at
 
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:519)at
 
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)at
 
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:804)at
 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:753)at
 
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)at
 org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)at 
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)at 
org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)at 
java.lang.Thread.run(Thread.java:748) {code}
 
 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Created] (FLINK-26641) Optimize the time of fetching job status in the job submission of session cluster

[Yangze Guo (Jira)]

Yangze Guo created FLINK-26641:
--

 Summary: Optimize the time of fetching job status in the job 
submission of session cluster
 Key: FLINK-26641
 URL: https://issues.apache.org/jira/browse/FLINK-26641
 Project: Flink
  Issue Type: Sub-task
  Components: Client / Job Submission, Runtime / REST
Reporter: Yangze Guo
Assignee: Yangze Guo
 Fix For: 1.16.0


Currently, in the session cluster, the client will wait until the job 
initialization is finished in the job submission period. However, it will first 
get the job details from the `ExecutionGraphCache`. For short queries in OLAP 
scenarios, the job might have been finished before the cache refreshed, which 
increase the e2e time of fetching the result.

We proposed to introduce a REST API for the job status to replace it.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Re: [DISCUSS] Preview release for Flink Kubernetes Operator

[Aitozi]

Hi all
Thanks for starting the discussion. The first release at the end of
March looks good to me, I think the flink-kubernetes-operator is in a good
shape now. I will try to complete the design to support the session job in
these two days and will start another discussion before the work.
Regarding what has to be improved before release, I think the operator
metrics are not completed yet, we may have to inject more useful metrics.
The feature list
https://github.com/bgeng777/flink-kubernetes-operator/blob/features/doc/features.md
posted
by @Biao Geng looks good, Maybe we could include this to track the
supported features.

Best,
Aitozi.

Gyula Fóra  于2022年3月14日周一 16:58写道：

> Hi Xintong!
>
> Thank you for the valuable input, you are completely right we need to agree
> and document these aspects.
>
> Let me try to address some of the questions and others should chip in also
> :)
>
> 1. Version convention:
>
> I think we should adopt the 3 digit versioning scheme like other flink
> projects (I think flink-shaded is a bit of an outlier here).
> The preview release should be 0.1.0.
>
> The supported Flink versions should be documented with the release, each
> version of the operator should technically be able to support multiple
> Flink versions at the same time.
> For the preview release this should be Flink version >= 1.14. We should
> later come up with a guarantee that we do not drop flink version support
> within the same minor version.
>
> The only public API here at the moment are the custom resource definitions.
> We agreed to mark them all experimental for the preview release, and I
> think for 1.0.0 we  should aim for public evolving.
> Otherwise we should respect the Flink guarantees here. Practically this
> means that for the preview release we do not guarantee anything in terms of
> later compatibility.
>
> 2. Release process:
> I agree that we should follow the official Flink process as much as
> possible (and makes sense) with proper voting etc.
>
> Cheers,
> Gyula
>
>
> On Mon, Mar 14, 2022 at 8:32 AM Xintong Song 
> wrote:
>
> > How everyone,
> >
> > It's great to learn that we are approaching a preview release for
> > the flink-kubernetes-operator. Thanks for the efforts.
> >
> > I have not been involved with any developing efforts in
> > flink-kubernetes-operator, thus have no comment on end of March being the
> > targeting date.
> >
> > However, based on my experiences being one of the Flink release
> managers, I
> > see a few things that are still missing for creating an official release.
> > (IIUC, the preview release is still an official release, just with weak
> > functionality and compatibility guarantees.)
> >
> > 1. The version conventions:
> > - How does a flink-kubernetes-operator version look like? E.g., flink /
> > flink-statefun / flink-ml have three digits x.y.z, while flink-shaded has
> > only two digits x.y.
> > - What is the relationship between flink-kubernetes-operator and flink
> > versions? E.g., flink-shaded x.* is only designed to support flink *.x.*.
> > - What kind of compatibility guarantees do we provide? E.g., flink
> expects
> > no Public API compatibility should be broken between minor releases (the
> > 2nd digit) and no PublicEvolving APIs should be broken between bugfix
> > releases (the 3rd digit).
> > - What kind of support do we provide for old releases? E.g., flink
> provides
> > bug fixes for the latest two minor releases (the 2nd digit).
> >
> > 2. Release process
> > You may find the release process for all Flink artifacts in this wiki
> page
> > [1]. Such a formal documented process would help us to reach consensus on
> > what needs to be done and make sure it complies with the ASF regulations
> > before creating a release. We probably don't need something as formal as
> a
> > vote to approve the release process. But we definitely need a formal vote
> > for the flink-kubernetes-operator release, and the release process would
> > help making sure we are on the same page about what is a releasable state
> > for this artifact.
> >
> > WDYT?
> >
> > Thank you~
> >
> > Xintong Song
> >
> >
> > [1] https://cwiki.apache.org/confluence/display/FLINK/Releasing
> >
> > On Mon, Mar 14, 2022 at 11:34 AM Biao Geng  wrote:
> >
> > > Hi there,
> > >
> > > It is exciting to see the discussion of the release timeline! I agree
> > that
> > > the end of March is a proper date.
> > > To make others easier get involved in this discussion, I think we may
> > need
> > > to provide a more straightforward feature list for the preview release.
> > The
> > > "Initial Feature Set" in FLIP-212
> > > <
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-212:+Introduce+Flink+Kubernetes+Operator
> > > >
> > > is
> > > almost complete. But some new features like webhook based validate and
> > > flink operator metric are not added and they are only tracked in the
> long
> > > JIRA list. If we can update the FLIP, it may be more convenient and can
> > > also help 

Re: [DISCUSS] Preview release for Flink Kubernetes Operator

[Xintong Song]

Hi Gyula,

Thanks for the quick response. And your answers to the questions sound good
to me.

I'd suggest first creating a "Creating a Flink Kubernetes Operator Release"
page and a "Verifying a Flink Kubernetes Operator Release" page on the
wiki[1], just like other projects. We can then discuss / comment around the
docs and keep refining them.

Thank you~

Xintong Song


[1] https://cwiki.apache.org/confluence/display/FLINK/Releasing

On Mon, Mar 14, 2022 at 4:52 PM Gyula Fóra  wrote:

> Hi Xintong!
>
> Thank you for the valuable input, you are completely right we need to agree
> and document these aspects.
>
> Let me try to address some of the questions and others should chip in also
> :)
>
> 1. Version convention:
>
> I think we should adopt the 3 digit versioning scheme like other flink
> projects (I think flink-shaded is a bit of an outlier here).
> The preview release should be 0.1.0.
>
> The supported Flink versions should be documented with the release, each
> version of the operator should technically be able to support multiple
> Flink versions at the same time.
> For the preview release this should be Flink version >= 1.14. We should
> later come up with a guarantee that we do not drop flink version support
> within the same minor version.
>
> The only public API here at the moment are the custom resource definitions.
> We agreed to mark them all experimental for the preview release, and I
> think for 1.0.0 we  should aim for public evolving.
> Otherwise we should respect the Flink guarantees here. Practically this
> means that for the preview release we do not guarantee anything in terms of
> later compatibility.
>
> 2. Release process:
> I agree that we should follow the official Flink process as much as
> possible (and makes sense) with proper voting etc.
>
> Cheers,
> Gyula
>
>
> On Mon, Mar 14, 2022 at 8:32 AM Xintong Song 
> wrote:
>
> > How everyone,
> >
> > It's great to learn that we are approaching a preview release for
> > the flink-kubernetes-operator. Thanks for the efforts.
> >
> > I have not been involved with any developing efforts in
> > flink-kubernetes-operator, thus have no comment on end of March being the
> > targeting date.
> >
> > However, based on my experiences being one of the Flink release
> managers, I
> > see a few things that are still missing for creating an official release.
> > (IIUC, the preview release is still an official release, just with weak
> > functionality and compatibility guarantees.)
> >
> > 1. The version conventions:
> > - How does a flink-kubernetes-operator version look like? E.g., flink /
> > flink-statefun / flink-ml have three digits x.y.z, while flink-shaded has
> > only two digits x.y.
> > - What is the relationship between flink-kubernetes-operator and flink
> > versions? E.g., flink-shaded x.* is only designed to support flink *.x.*.
> > - What kind of compatibility guarantees do we provide? E.g., flink
> expects
> > no Public API compatibility should be broken between minor releases (the
> > 2nd digit) and no PublicEvolving APIs should be broken between bugfix
> > releases (the 3rd digit).
> > - What kind of support do we provide for old releases? E.g., flink
> provides
> > bug fixes for the latest two minor releases (the 2nd digit).
> >
> > 2. Release process
> > You may find the release process for all Flink artifacts in this wiki
> page
> > [1]. Such a formal documented process would help us to reach consensus on
> > what needs to be done and make sure it complies with the ASF regulations
> > before creating a release. We probably don't need something as formal as
> a
> > vote to approve the release process. But we definitely need a formal vote
> > for the flink-kubernetes-operator release, and the release process would
> > help making sure we are on the same page about what is a releasable state
> > for this artifact.
> >
> > WDYT?
> >
> > Thank you~
> >
> > Xintong Song
> >
> >
> > [1] https://cwiki.apache.org/confluence/display/FLINK/Releasing
> >
> > On Mon, Mar 14, 2022 at 11:34 AM Biao Geng  wrote:
> >
> > > Hi there,
> > >
> > > It is exciting to see the discussion of the release timeline! I agree
> > that
> > > the end of March is a proper date.
> > > To make others easier get involved in this discussion, I think we may
> > need
> > > to provide a more straightforward feature list for the preview release.
> > The
> > > "Initial Feature Set" in FLIP-212
> > > <
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-212:+Introduce+Flink+Kubernetes+Operator
> > > >
> > > is
> > > almost complete. But some new features like webhook based validate and
> > > flink operator metric are not added and they are only tracked in the
> long
> > > JIRA list. If we can update the FLIP, it may be more convenient and can
> > > also help us write release notes later. I also created a draft
> > > <
> > >
> >
> https://github.com/bgeng777/flink-kubernetes-operator/blob/features/doc/features.md
> > > >
> > > for myself to track 

Re: [ANNOUNCE] New PMC member: Yuan Mei

[LuNing Wang]

Congratulations, Yuan!

Best,
LuNing Wang

Aitozi  于2022年3月15日周二 10:22写道：

> Congratulations, Yuan!
>
> Best,
> Aitozi
>
> Zhipeng Zhang  于2022年3月15日周二 10:21写道：
>
> > Congratulations, Yuan!
> >
> > Matt Wang  于2022年3月15日周二 10:13写道：
> >
> > > Congratulations, Yuan!
> > >
> > >
> > > --
> > >
> > > Best,
> > > Matt Wang
> > >
> > >
> > > On 03/15/2022 09:51，godfrey he wrote：
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Godfrey
> > >
> > > Lijie Wang  于2022年3月15日周二 09:18写道：
> > >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Lijie
> > >
> > > Benchao Li  于2022年3月15日周二 08:18写道：
> > >
> > > Congratulations, Yuan!
> > >
> > > Yun Gao  于2022年3月15日周二 01:37写道：
> > >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Yun Gao
> > >
> > >
> > >
> > > --
> > > From:Francesco Guardiani 
> > > Send Time:2022 Mar. 15 (Tue.) 00:21
> > > To:dev 
> > > Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei
> > >
> > > Congratulations, Yuan!
> > >
> > > On Mon, Mar 14, 2022 at 3:51 PM yanfei lei 
> wrote:
> > >
> > > Congratulations, Yuan!
> > >
> > >
> > >
> > > Zhilong Hong  于2022年3月14日周一 19:31写道：
> > >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Zhilong
> > >
> > > On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> > > wrote:
> > >
> > > Congratulations, Yuan!
> > >
> > > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> > > wrote:
> > >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Jing Zhang
> > >
> > > Jing Ge  于2022年3月14日周一 18:15写道：
> > >
> > > Congrats! Very well deserved!
> > >
> > > Best,
> > > Jing
> > >
> > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> > > pnowoj...@apache.org>
> > > wrote:
> > >
> > > Congratulations :)
> > >
> > > pon., 14 mar 2022 o 09:59 Yun Tang 
> > > napisał(a):
> > >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Yun Tang
> > > 
> > > From: Zakelly Lan 
> > > Sent: Monday, March 14, 2022 16:55
> > > To: dev@flink.apache.org 
> > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Zakelly
> > >
> > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> > > j...@ververica.com>
> > > wrote:
> > >
> > > Congrats Yuan.
> > >
> > > On 14.03.2022, at 09:45, Arvid Heise  > >
> > > wrote:
> > >
> > > Congratulations and well deserved!
> > >
> > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > > map...@apache.org
> > >
> > > wrote:
> > >
> > > Congratulations, Yuan.
> > >
> > > On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > > njucs...@gmail.com>
> > > wrote:
> > >
> > > Congratulations, Yuan!
> > >
> > > On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > kaa@yandex.com>
> > > wrote:
> > >
> > > Congratulations, Yuan!
> > >
> > > --
> > >
> > > Best regards,
> > > Anton Kalashnikov
> > >
> > > 14.03.2022 09:13, Leonard Xu пишет:
> > > Congratulations Yuan!
> > >
> > > Best,
> > > Leonard
> > >
> > > 2022年3月14日 下午4:09，Yangze Guo 
> > > 写道：
> > >
> > > Congratulations!
> > >
> > > Best,
> > > Yangze Guo
> > >
> > > On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > martijnvis...@apache.org> wrote:
> > > Congratulations Yuan!
> > >
> > > On Mon, 14 Mar 2022 at 09:02, Yu Li <
> > > car...@gmail.com>
> > > wrote:
> > >
> > > Hi all!
> > >
> > > I'm very happy to announce that Yuan Mei has
> > > joined
> > > the
> > > Flink
> > > PMC!
> > >
> > > Yuan is helping the community a lot with
> > > creating
> > > and
> > > validating
> > > releases,
> > > contributing to FLIP discussions and good code
> > > contributions
> > > to
> > > the
> > > state backend and related components.
> > >
> > > Congratulations and welcome, Yuan!
> > >
> > > Best Regards,
> > > Yu (On behalf of the Apache Flink PMC)
> > >
> > > --
> > >
> > > Best regards,
> > > Anton Kalashnikov
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > > --
> > >
> > > Konstantin Knauf
> > >
> > > https://twitter.com/snntrable
> > >
> > > https://github.com/knaufk
> > >
> > >
> > >
> > >
> > >
> > >
> > > --
> > >
> > > Best,
> > > Benchao Li
> > >
> > >
> >
> > --
> > best,
> > Zhipeng
> >
>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Aitozi]

Congratulations, Yuan!

Best,
Aitozi

Zhipeng Zhang  于2022年3月15日周二 10:21写道：

> Congratulations, Yuan!
>
> Matt Wang  于2022年3月15日周二 10:13写道：
>
> > Congratulations, Yuan!
> >
> >
> > --
> >
> > Best,
> > Matt Wang
> >
> >
> > On 03/15/2022 09:51，godfrey he wrote：
> > Congratulations, Yuan!
> >
> > Best,
> > Godfrey
> >
> > Lijie Wang  于2022年3月15日周二 09:18写道：
> >
> > Congratulations, Yuan!
> >
> > Best,
> > Lijie
> >
> > Benchao Li  于2022年3月15日周二 08:18写道：
> >
> > Congratulations, Yuan!
> >
> > Yun Gao  于2022年3月15日周二 01:37写道：
> >
> > Congratulations, Yuan!
> >
> > Best,
> > Yun Gao
> >
> >
> >
> > --
> > From:Francesco Guardiani 
> > Send Time:2022 Mar. 15 (Tue.) 00:21
> > To:dev 
> > Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei
> >
> > Congratulations, Yuan!
> >
> > On Mon, Mar 14, 2022 at 3:51 PM yanfei lei  wrote:
> >
> > Congratulations, Yuan!
> >
> >
> >
> > Zhilong Hong  于2022年3月14日周一 19:31写道：
> >
> > Congratulations, Yuan!
> >
> > Best,
> > Zhilong
> >
> > On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> > wrote:
> >
> > Congratulations, Yuan!
> >
> > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> > wrote:
> >
> > Congratulations, Yuan!
> >
> > Best,
> > Jing Zhang
> >
> > Jing Ge  于2022年3月14日周一 18:15写道：
> >
> > Congrats! Very well deserved!
> >
> > Best,
> > Jing
> >
> > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> > pnowoj...@apache.org>
> > wrote:
> >
> > Congratulations :)
> >
> > pon., 14 mar 2022 o 09:59 Yun Tang 
> > napisał(a):
> >
> > Congratulations, Yuan!
> >
> > Best,
> > Yun Tang
> > 
> > From: Zakelly Lan 
> > Sent: Monday, March 14, 2022 16:55
> > To: dev@flink.apache.org 
> > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> >
> > Congratulations, Yuan!
> >
> > Best,
> > Zakelly
> >
> > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> > j...@ververica.com>
> > wrote:
> >
> > Congrats Yuan.
> >
> > On 14.03.2022, at 09:45, Arvid Heise  >
> > wrote:
> >
> > Congratulations and well deserved!
> >
> > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > map...@apache.org
> >
> > wrote:
> >
> > Congratulations, Yuan.
> >
> > On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > njucs...@gmail.com>
> > wrote:
> >
> > Congratulations, Yuan!
> >
> > On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > kaa@yandex.com>
> > wrote:
> >
> > Congratulations, Yuan!
> >
> > --
> >
> > Best regards,
> > Anton Kalashnikov
> >
> > 14.03.2022 09:13, Leonard Xu пишет:
> > Congratulations Yuan!
> >
> > Best,
> > Leonard
> >
> > 2022年3月14日 下午4:09，Yangze Guo 
> > 写道：
> >
> > Congratulations!
> >
> > Best,
> > Yangze Guo
> >
> > On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > martijnvis...@apache.org> wrote:
> > Congratulations Yuan!
> >
> > On Mon, 14 Mar 2022 at 09:02, Yu Li <
> > car...@gmail.com>
> > wrote:
> >
> > Hi all!
> >
> > I'm very happy to announce that Yuan Mei has
> > joined
> > the
> > Flink
> > PMC!
> >
> > Yuan is helping the community a lot with
> > creating
> > and
> > validating
> > releases,
> > contributing to FLIP discussions and good code
> > contributions
> > to
> > the
> > state backend and related components.
> >
> > Congratulations and welcome, Yuan!
> >
> > Best Regards,
> > Yu (On behalf of the Apache Flink PMC)
> >
> > --
> >
> > Best regards,
> > Anton Kalashnikov
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> > --
> >
> > Konstantin Knauf
> >
> > https://twitter.com/snntrable
> >
> > https://github.com/knaufk
> >
> >
> >
> >
> >
> >
> > --
> >
> > Best,
> > Benchao Li
> >
> >
>
> --
> best,
> Zhipeng
>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Zhipeng Zhang]

Congratulations, Yuan!

Matt Wang  于2022年3月15日周二 10:13写道：

> Congratulations, Yuan!
>
>
> --
>
> Best,
> Matt Wang
>
>
> On 03/15/2022 09:51，godfrey he wrote：
> Congratulations, Yuan!
>
> Best,
> Godfrey
>
> Lijie Wang  于2022年3月15日周二 09:18写道：
>
> Congratulations, Yuan!
>
> Best,
> Lijie
>
> Benchao Li  于2022年3月15日周二 08:18写道：
>
> Congratulations, Yuan!
>
> Yun Gao  于2022年3月15日周二 01:37写道：
>
> Congratulations, Yuan!
>
> Best,
> Yun Gao
>
>
>
> --
> From:Francesco Guardiani 
> Send Time:2022 Mar. 15 (Tue.) 00:21
> To:dev 
> Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei
>
> Congratulations, Yuan!
>
> On Mon, Mar 14, 2022 at 3:51 PM yanfei lei  wrote:
>
> Congratulations, Yuan!
>
>
>
> Zhilong Hong  于2022年3月14日周一 19:31写道：
>
> Congratulations, Yuan!
>
> Best,
> Zhilong
>
> On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> wrote:
>
> Congratulations, Yuan!
>
> On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> wrote:
>
> Congratulations, Yuan!
>
> Best,
> Jing Zhang
>
> Jing Ge  于2022年3月14日周一 18:15写道：
>
> Congrats! Very well deserved!
>
> Best,
> Jing
>
> On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> pnowoj...@apache.org>
> wrote:
>
> Congratulations :)
>
> pon., 14 mar 2022 o 09:59 Yun Tang 
> napisał(a):
>
> Congratulations, Yuan!
>
> Best,
> Yun Tang
> 
> From: Zakelly Lan 
> Sent: Monday, March 14, 2022 16:55
> To: dev@flink.apache.org 
> Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
>
> Congratulations, Yuan!
>
> Best,
> Zakelly
>
> On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> j...@ververica.com>
> wrote:
>
> Congrats Yuan.
>
> On 14.03.2022, at 09:45, Arvid Heise 
> wrote:
>
> Congratulations and well deserved!
>
> On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> map...@apache.org
>
> wrote:
>
> Congratulations, Yuan.
>
> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> njucs...@gmail.com>
> wrote:
>
> Congratulations, Yuan!
>
> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> kaa@yandex.com>
> wrote:
>
> Congratulations, Yuan!
>
> --
>
> Best regards,
> Anton Kalashnikov
>
> 14.03.2022 09:13, Leonard Xu пишет:
> Congratulations Yuan!
>
> Best,
> Leonard
>
> 2022年3月14日 下午4:09，Yangze Guo 
> 写道：
>
> Congratulations!
>
> Best,
> Yangze Guo
>
> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> martijnvis...@apache.org> wrote:
> Congratulations Yuan!
>
> On Mon, 14 Mar 2022 at 09:02, Yu Li <
> car...@gmail.com>
> wrote:
>
> Hi all!
>
> I'm very happy to announce that Yuan Mei has
> joined
> the
> Flink
> PMC!
>
> Yuan is helping the community a lot with
> creating
> and
> validating
> releases,
> contributing to FLIP discussions and good code
> contributions
> to
> the
> state backend and related components.
>
> Congratulations and welcome, Yuan!
>
> Best Regards,
> Yu (On behalf of the Apache Flink PMC)
>
> --
>
> Best regards,
> Anton Kalashnikov
>
>
>
>
>
>
>
>
>
>
>
> --
>
> Konstantin Knauf
>
> https://twitter.com/snntrable
>
> https://github.com/knaufk
>
>
>
>
>
>
> --
>
> Best,
> Benchao Li
>
>

-- 
best,
Zhipeng

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Matt Wang]

Congratulations, Yuan!


--

Best,
Matt Wang


On 03/15/2022 09:51，godfrey he wrote：
Congratulations, Yuan!

Best,
Godfrey

Lijie Wang  于2022年3月15日周二 09:18写道：

Congratulations, Yuan!

Best,
Lijie

Benchao Li  于2022年3月15日周二 08:18写道：

Congratulations, Yuan!

Yun Gao  于2022年3月15日周二 01:37写道：

Congratulations, Yuan!

Best,
Yun Gao



--
From:Francesco Guardiani 
Send Time:2022 Mar. 15 (Tue.) 00:21
To:dev 
Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei

Congratulations, Yuan!

On Mon, Mar 14, 2022 at 3:51 PM yanfei lei  wrote:

Congratulations, Yuan!



Zhilong Hong  于2022年3月14日周一 19:31写道：

Congratulations, Yuan!

Best,
Zhilong

On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
wrote:

Congratulations, Yuan!

On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
wrote:

Congratulations, Yuan!

Best,
Jing Zhang

Jing Ge  于2022年3月14日周一 18:15写道：

Congrats! Very well deserved!

Best,
Jing

On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
pnowoj...@apache.org>
wrote:

Congratulations :)

pon., 14 mar 2022 o 09:59 Yun Tang 
napisał(a):

Congratulations, Yuan!

Best,
Yun Tang

From: Zakelly Lan 
Sent: Monday, March 14, 2022 16:55
To: dev@flink.apache.org 
Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei

Congratulations, Yuan!

Best,
Zakelly

On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
j...@ververica.com>
wrote:

Congrats Yuan.

On 14.03.2022, at 09:45, Arvid Heise 
wrote:

Congratulations, Yuan!

On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
kaa@yandex.com>
wrote:

Congratulations, Yuan!

--

Best regards,
Anton Kalashnikov

14.03.2022 09:13, Leonard Xu пишет:
Congratulations Yuan!

Best,
Leonard

2022年3月14日 下午4:09，Yangze Guo 
写道：

Congratulations!

Best,
Yangze Guo

On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
martijnvis...@apache.org> wrote:
Congratulations Yuan!

On Mon, 14 Mar 2022 at 09:02, Yu Li <
car...@gmail.com>
wrote:

Hi all!

I'm very happy to announce that Yuan Mei has
joined
the
Flink
PMC!

Yuan is helping the community a lot with
creating
and
validating
releases,
contributing to FLIP discussions and good code
contributions
to
the
state backend and related components.

Congratulations and welcome, Yuan!

Best Regards,
Yu (On behalf of the Apache Flink PMC)

--

Best regards,
Anton Kalashnikov











--

Konstantin Knauf

https://twitter.com/snntrable

https://github.com/knaufk






--

Best,
Benchao Li

Re: [ANNOUNCE] New PMC member: Yuan Mei

[godfrey he]

Congratulations, Yuan!

Best,
Godfrey

Lijie Wang  于2022年3月15日周二 09:18写道：
>
> Congratulations, Yuan!
>
> Best,
> Lijie
>
> Benchao Li  于2022年3月15日周二 08:18写道：
>
> > Congratulations, Yuan!
> >
> > Yun Gao  于2022年3月15日周二 01:37写道：
> >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Yun Gao
> > >
> > >
> > >
> > > --
> > > From:Francesco Guardiani 
> > > Send Time:2022 Mar. 15 (Tue.) 00:21
> > > To:dev 
> > > Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei
> > >
> > > Congratulations, Yuan!
> > >
> > > On Mon, Mar 14, 2022 at 3:51 PM yanfei lei  wrote:
> > >
> > > > Congratulations, Yuan!
> > > >
> > > >
> > > >
> > > > Zhilong Hong  于2022年3月14日周一 19:31写道：
> > > >
> > > > > Congratulations, Yuan!
> > > > >
> > > > > Best,
> > > > > Zhilong
> > > > >
> > > > > On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> > > > > wrote:
> > > > >
> > > > > > Congratulations, Yuan!
> > > > > >
> > > > > > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> > > > > wrote:
> > > > > >
> > > > > > > Congratulations, Yuan!
> > > > > > >
> > > > > > > Best,
> > > > > > > Jing Zhang
> > > > > > >
> > > > > > > Jing Ge  于2022年3月14日周一 18:15写道：
> > > > > > >
> > > > > > > > Congrats! Very well deserved!
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Jing
> > > > > > > >
> > > > > > > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> > > > > pnowoj...@apache.org>
> > > > > > > > wrote:
> > > > > > > >
> > > > > > > > > Congratulations :)
> > > > > > > > >
> > > > > > > > > pon., 14 mar 2022 o 09:59 Yun Tang 
> > > > napisał(a):
> > > > > > > > >
> > > > > > > > > > Congratulations, Yuan!
> > > > > > > > > >
> > > > > > > > > > Best,
> > > > > > > > > > Yun Tang
> > > > > > > > > > 
> > > > > > > > > > From: Zakelly Lan 
> > > > > > > > > > Sent: Monday, March 14, 2022 16:55
> > > > > > > > > > To: dev@flink.apache.org 
> > > > > > > > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > > > > > > > >
> > > > > > > > > > Congratulations, Yuan!
> > > > > > > > > >
> > > > > > > > > > Best,
> > > > > > > > > > Zakelly
> > > > > > > > > >
> > > > > > > > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> > > > > j...@ververica.com>
> > > > > > > > > wrote:
> > > > > > > > > >
> > > > > > > > > > > Congrats Yuan.
> > > > > > > > > > >
> > > > > > > > > > > > On 14.03.2022, at 09:45, Arvid Heise  > >
> > > > > wrote:
> > > > > > > > > > > >
> > > > > > > > > > > > Congratulations and well deserved!
> > > > > > > > > > > >
> > > > > > > > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > > > > > map...@apache.org
> > > > > > > >
> > > > > > > > > > wrote:
> > > > > > > > > > > >
> > > > > > > > > > > >> Congratulations, Yuan.
> > > > > > > > > > > >>
> > > > > > > > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > > > > > njucs...@gmail.com>
> > > > > > > > > > wrote:
> > > > > > > > > > > >>
> > > > > > > > > > > >>> Congratulations, Yuan!
> > > > > > > > > > > >>>
> > > > > > > > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > > > > > > > > kaa@yandex.com>
> > > > > > > > > > > >>> wrote:
> > > > > > > > > > > >>>
> > > > > > > > > > >  Congratulations, Yuan!
> > > > > > > > > > > 
> > > > > > > > > > >  --
> > > > > > > > > > > 
> > > > > > > > > > >  Best regards,
> > > > > > > > > > >  Anton Kalashnikov
> > > > > > > > > > > 
> > > > > > > > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > > > > > > > Congratulations Yuan!
> > > > > > > > > > > >
> > > > > > > > > > > > Best,
> > > > > > > > > > > > Leonard
> > > > > > > > > > > >
> > > > > > > > > > > >> 2022年3月14日 下午4:09，Yangze Guo 
> > > 写道：
> > > > > > > > > > > >>
> > > > > > > > > > > >> Congratulations!
> > > > > > > > > > > >>
> > > > > > > > > > > >> Best,
> > > > > > > > > > > >> Yangze Guo
> > > > > > > > > > > >>
> > > > > > > > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > > > > > > > > >  martijnvis...@apache.org> wrote:
> > > > > > > > > > > >>> Congratulations Yuan!
> > > > > > > > > > > >>>
> > > > > > > > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li <
> > > > car...@gmail.com>
> > > > > > > > wrote:
> > > > > > > > > > > >>>
> > > > > > > > > > >  Hi all!
> > > > > > > > > > > 
> > > > > > > > > > >  I'm very happy to announce that Yuan Mei has
> > > joined
> > > > > the
> > > > > > > > Flink
> > > > > > > > > > PMC!
> > > > > > > > > > > 
> > > > > > > > > > >  Yuan is helping the community a lot with
> > creating
> > > > and
> > > > > > > > > validating
> > > > > > > > > > >  releases,
> > > > > > > > > > >  contributing to FLIP discussions and good code
> > > > > > > contributions
> > > > > > > > > to
> > > > > > > > > > > >> the
> > > > > > > > > > >  state backend and related components.
> > > > > > > > > > > 
> 

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Lijie Wang]

Congratulations, Yuan!

Best,
Lijie

Benchao Li  于2022年3月15日周二 08:18写道：

> Congratulations, Yuan!
>
> Yun Gao  于2022年3月15日周二 01:37写道：
>
> > Congratulations, Yuan!
> >
> > Best,
> > Yun Gao
> >
> >
> >
> > --
> > From:Francesco Guardiani 
> > Send Time:2022 Mar. 15 (Tue.) 00:21
> > To:dev 
> > Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei
> >
> > Congratulations, Yuan!
> >
> > On Mon, Mar 14, 2022 at 3:51 PM yanfei lei  wrote:
> >
> > > Congratulations, Yuan!
> > >
> > >
> > >
> > > Zhilong Hong  于2022年3月14日周一 19:31写道：
> > >
> > > > Congratulations, Yuan!
> > > >
> > > > Best,
> > > > Zhilong
> > > >
> > > > On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> > > > wrote:
> > > >
> > > > > Congratulations, Yuan!
> > > > >
> > > > > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> > > > wrote:
> > > > >
> > > > > > Congratulations, Yuan!
> > > > > >
> > > > > > Best,
> > > > > > Jing Zhang
> > > > > >
> > > > > > Jing Ge  于2022年3月14日周一 18:15写道：
> > > > > >
> > > > > > > Congrats! Very well deserved!
> > > > > > >
> > > > > > > Best,
> > > > > > > Jing
> > > > > > >
> > > > > > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> > > > pnowoj...@apache.org>
> > > > > > > wrote:
> > > > > > >
> > > > > > > > Congratulations :)
> > > > > > > >
> > > > > > > > pon., 14 mar 2022 o 09:59 Yun Tang 
> > > napisał(a):
> > > > > > > >
> > > > > > > > > Congratulations, Yuan!
> > > > > > > > >
> > > > > > > > > Best,
> > > > > > > > > Yun Tang
> > > > > > > > > 
> > > > > > > > > From: Zakelly Lan 
> > > > > > > > > Sent: Monday, March 14, 2022 16:55
> > > > > > > > > To: dev@flink.apache.org 
> > > > > > > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > > > > > > >
> > > > > > > > > Congratulations, Yuan!
> > > > > > > > >
> > > > > > > > > Best,
> > > > > > > > > Zakelly
> > > > > > > > >
> > > > > > > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> > > > j...@ververica.com>
> > > > > > > > wrote:
> > > > > > > > >
> > > > > > > > > > Congrats Yuan.
> > > > > > > > > >
> > > > > > > > > > > On 14.03.2022, at 09:45, Arvid Heise  >
> > > > wrote:
> > > > > > > > > > >
> > > > > > > > > > > Congratulations and well deserved!
> > > > > > > > > > >
> > > > > > > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > > > > map...@apache.org
> > > > > > >
> > > > > > > > > wrote:
> > > > > > > > > > >
> > > > > > > > > > >> Congratulations, Yuan.
> > > > > > > > > > >>
> > > > > > > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > > > > njucs...@gmail.com>
> > > > > > > > > wrote:
> > > > > > > > > > >>
> > > > > > > > > > >>> Congratulations, Yuan!
> > > > > > > > > > >>>
> > > > > > > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > > > > > > > kaa@yandex.com>
> > > > > > > > > > >>> wrote:
> > > > > > > > > > >>>
> > > > > > > > > >  Congratulations, Yuan!
> > > > > > > > > > 
> > > > > > > > > >  --
> > > > > > > > > > 
> > > > > > > > > >  Best regards,
> > > > > > > > > >  Anton Kalashnikov
> > > > > > > > > > 
> > > > > > > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > > > > > > Congratulations Yuan!
> > > > > > > > > > >
> > > > > > > > > > > Best,
> > > > > > > > > > > Leonard
> > > > > > > > > > >
> > > > > > > > > > >> 2022年3月14日 下午4:09，Yangze Guo 
> > 写道：
> > > > > > > > > > >>
> > > > > > > > > > >> Congratulations!
> > > > > > > > > > >>
> > > > > > > > > > >> Best,
> > > > > > > > > > >> Yangze Guo
> > > > > > > > > > >>
> > > > > > > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > > > > > > > >  martijnvis...@apache.org> wrote:
> > > > > > > > > > >>> Congratulations Yuan!
> > > > > > > > > > >>>
> > > > > > > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li <
> > > car...@gmail.com>
> > > > > > > wrote:
> > > > > > > > > > >>>
> > > > > > > > > >  Hi all!
> > > > > > > > > > 
> > > > > > > > > >  I'm very happy to announce that Yuan Mei has
> > joined
> > > > the
> > > > > > > Flink
> > > > > > > > > PMC!
> > > > > > > > > > 
> > > > > > > > > >  Yuan is helping the community a lot with
> creating
> > > and
> > > > > > > > validating
> > > > > > > > > >  releases,
> > > > > > > > > >  contributing to FLIP discussions and good code
> > > > > > contributions
> > > > > > > > to
> > > > > > > > > > >> the
> > > > > > > > > >  state backend and related components.
> > > > > > > > > > 
> > > > > > > > > >  Congratulations and welcome, Yuan!
> > > > > > > > > > 
> > > > > > > > > >  Best Regards,
> > > > > > > > > >  Yu (On behalf of the Apache Flink PMC)
> > > > > > > > > > 
> > > > > > > > > >  --
> > > > > > > > > > 
> > > > > > > > > >  Best regards,
> > > > > > > > > >  Anton Kalashnikov
> > > > > > > > > > 
> 

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Benchao Li]

Congratulations, Yuan!

Yun Gao  于2022年3月15日周二 01:37写道：

> Congratulations, Yuan!
>
> Best,
> Yun Gao
>
>
>
> --
> From:Francesco Guardiani 
> Send Time:2022 Mar. 15 (Tue.) 00:21
> To:dev 
> Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei
>
> Congratulations, Yuan!
>
> On Mon, Mar 14, 2022 at 3:51 PM yanfei lei  wrote:
>
> > Congratulations, Yuan!
> >
> >
> >
> > Zhilong Hong  于2022年3月14日周一 19:31写道：
> >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Zhilong
> > >
> > > On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> > > wrote:
> > >
> > > > Congratulations, Yuan!
> > > >
> > > > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> > > wrote:
> > > >
> > > > > Congratulations, Yuan!
> > > > >
> > > > > Best,
> > > > > Jing Zhang
> > > > >
> > > > > Jing Ge  于2022年3月14日周一 18:15写道：
> > > > >
> > > > > > Congrats! Very well deserved!
> > > > > >
> > > > > > Best,
> > > > > > Jing
> > > > > >
> > > > > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> > > pnowoj...@apache.org>
> > > > > > wrote:
> > > > > >
> > > > > > > Congratulations :)
> > > > > > >
> > > > > > > pon., 14 mar 2022 o 09:59 Yun Tang 
> > napisał(a):
> > > > > > >
> > > > > > > > Congratulations, Yuan!
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Yun Tang
> > > > > > > > 
> > > > > > > > From: Zakelly Lan 
> > > > > > > > Sent: Monday, March 14, 2022 16:55
> > > > > > > > To: dev@flink.apache.org 
> > > > > > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > > > > > >
> > > > > > > > Congratulations, Yuan!
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Zakelly
> > > > > > > >
> > > > > > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> > > j...@ververica.com>
> > > > > > > wrote:
> > > > > > > >
> > > > > > > > > Congrats Yuan.
> > > > > > > > >
> > > > > > > > > > On 14.03.2022, at 09:45, Arvid Heise 
> > > wrote:
> > > > > > > > > >
> > > > > > > > > > Congratulations and well deserved!
> > > > > > > > > >
> > > > > > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > > > map...@apache.org
> > > > > >
> > > > > > > > wrote:
> > > > > > > > > >
> > > > > > > > > >> Congratulations, Yuan.
> > > > > > > > > >>
> > > > > > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > > > njucs...@gmail.com>
> > > > > > > > wrote:
> > > > > > > > > >>
> > > > > > > > > >>> Congratulations, Yuan!
> > > > > > > > > >>>
> > > > > > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > > > > > > kaa@yandex.com>
> > > > > > > > > >>> wrote:
> > > > > > > > > >>>
> > > > > > > > >  Congratulations, Yuan!
> > > > > > > > > 
> > > > > > > > >  --
> > > > > > > > > 
> > > > > > > > >  Best regards,
> > > > > > > > >  Anton Kalashnikov
> > > > > > > > > 
> > > > > > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > > > > > Congratulations Yuan!
> > > > > > > > > >
> > > > > > > > > > Best,
> > > > > > > > > > Leonard
> > > > > > > > > >
> > > > > > > > > >> 2022年3月14日 下午4:09，Yangze Guo 
> 写道：
> > > > > > > > > >>
> > > > > > > > > >> Congratulations!
> > > > > > > > > >>
> > > > > > > > > >> Best,
> > > > > > > > > >> Yangze Guo
> > > > > > > > > >>
> > > > > > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > > > > > > >  martijnvis...@apache.org> wrote:
> > > > > > > > > >>> Congratulations Yuan!
> > > > > > > > > >>>
> > > > > > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li <
> > car...@gmail.com>
> > > > > > wrote:
> > > > > > > > > >>>
> > > > > > > > >  Hi all!
> > > > > > > > > 
> > > > > > > > >  I'm very happy to announce that Yuan Mei has
> joined
> > > the
> > > > > > Flink
> > > > > > > > PMC!
> > > > > > > > > 
> > > > > > > > >  Yuan is helping the community a lot with creating
> > and
> > > > > > > validating
> > > > > > > > >  releases,
> > > > > > > > >  contributing to FLIP discussions and good code
> > > > > contributions
> > > > > > > to
> > > > > > > > > >> the
> > > > > > > > >  state backend and related components.
> > > > > > > > > 
> > > > > > > > >  Congratulations and welcome, Yuan!
> > > > > > > > > 
> > > > > > > > >  Best Regards,
> > > > > > > > >  Yu (On behalf of the Apache Flink PMC)
> > > > > > > > > 
> > > > > > > > >  --
> > > > > > > > > 
> > > > > > > > >  Best regards,
> > > > > > > > >  Anton Kalashnikov
> > > > > > > > > 
> > > > > > > > > 
> > > > > > > > > >>
> > > > > > > > >
> > > > > > > > >
> > > > > > > >
> > > > > > >
> > > > > >
> > > > >
> > > >
> > > >
> > > > --
> > > >
> > > > Konstantin Knauf
> > > >
> > > > https://twitter.com/snntrable
> > > >
> > > > https://github.com/knaufk
> > > >
> > >
> >
>
>

-- 

Best,
Benchao Li

[jira] [Created] (FLINK-26640) Consider changing flinkVersion to enum type or removing it completely

[Gyula Fora (Jira)]

Gyula Fora created FLINK-26640:
--

 Summary: Consider changing flinkVersion to enum type or removing 
it completely
 Key: FLINK-26640
 URL: https://issues.apache.org/jira/browse/FLINK-26640
 Project: Flink
  Issue Type: Sub-task
Reporter: Gyula Fora


Currently the flinkVersion is a string field that we do not use anywhere. There 
might be some cases in the future where knowing the flink version might be 
valuable but an optional string field will not work.

We should either make this a required enum of the supported flink versions (I 
suggest only major.minor -> 1.14, 1.15...) or remove it completely for now.

 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Created] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts

[Thomas Weise (Jira)]

Thomas Weise created FLINK-26639:


 Summary: Publish flink-kubernetes-operator maven artifacts
 Key: FLINK-26639
 URL: https://issues.apache.org/jira/browse/FLINK-26639
 Project: Flink
  Issue Type: Sub-task
Reporter: Thomas Weise


We should publish the Maven artifacts in addition to the Docker images so that 
downstream Java projects can utilize the CRD classes directly.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Yun Gao]

Congratulations, Yuan!

Best,
Yun Gao



--
From:Francesco Guardiani 
Send Time:2022 Mar. 15 (Tue.) 00:21
To:dev 
Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei

Congratulations, Yuan!

On Mon, Mar 14, 2022 at 3:51 PM yanfei lei  wrote:

> Congratulations, Yuan!
>
>
>
> Zhilong Hong  于2022年3月14日周一 19:31写道：
>
> > Congratulations, Yuan!
> >
> > Best,
> > Zhilong
> >
> > On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> > wrote:
> >
> > > Congratulations, Yuan!
> > >
> > > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> > wrote:
> > >
> > > > Congratulations, Yuan!
> > > >
> > > > Best,
> > > > Jing Zhang
> > > >
> > > > Jing Ge  于2022年3月14日周一 18:15写道：
> > > >
> > > > > Congrats! Very well deserved!
> > > > >
> > > > > Best,
> > > > > Jing
> > > > >
> > > > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> > pnowoj...@apache.org>
> > > > > wrote:
> > > > >
> > > > > > Congratulations :)
> > > > > >
> > > > > > pon., 14 mar 2022 o 09:59 Yun Tang 
> napisał(a):
> > > > > >
> > > > > > > Congratulations, Yuan!
> > > > > > >
> > > > > > > Best,
> > > > > > > Yun Tang
> > > > > > > 
> > > > > > > From: Zakelly Lan 
> > > > > > > Sent: Monday, March 14, 2022 16:55
> > > > > > > To: dev@flink.apache.org 
> > > > > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > > > > >
> > > > > > > Congratulations, Yuan!
> > > > > > >
> > > > > > > Best,
> > > > > > > Zakelly
> > > > > > >
> > > > > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> > j...@ververica.com>
> > > > > > wrote:
> > > > > > >
> > > > > > > > Congrats Yuan.
> > > > > > > >
> > > > > > > > > On 14.03.2022, at 09:45, Arvid Heise 
> > wrote:
> > > > > > > > >
> > > > > > > > > Congratulations and well deserved!
> > > > > > > > >
> > > > > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > > map...@apache.org
> > > > >
> > > > > > > wrote:
> > > > > > > > >
> > > > > > > > >> Congratulations, Yuan.
> > > > > > > > >>
> > > > > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > > njucs...@gmail.com>
> > > > > > > wrote:
> > > > > > > > >>
> > > > > > > > >>> Congratulations, Yuan!
> > > > > > > > >>>
> > > > > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > > > > > kaa@yandex.com>
> > > > > > > > >>> wrote:
> > > > > > > > >>>
> > > > > > > >  Congratulations, Yuan!
> > > > > > > > 
> > > > > > > >  --
> > > > > > > > 
> > > > > > > >  Best regards,
> > > > > > > >  Anton Kalashnikov
> > > > > > > > 
> > > > > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > > > > Congratulations Yuan!
> > > > > > > > >
> > > > > > > > > Best,
> > > > > > > > > Leonard
> > > > > > > > >
> > > > > > > > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > > > > > > > >>
> > > > > > > > >> Congratulations!
> > > > > > > > >>
> > > > > > > > >> Best,
> > > > > > > > >> Yangze Guo
> > > > > > > > >>
> > > > > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > > > > > >  martijnvis...@apache.org> wrote:
> > > > > > > > >>> Congratulations Yuan!
> > > > > > > > >>>
> > > > > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li <
> car...@gmail.com>
> > > > > wrote:
> > > > > > > > >>>
> > > > > > > >  Hi all!
> > > > > > > > 
> > > > > > > >  I'm very happy to announce that Yuan Mei has joined
> > the
> > > > > Flink
> > > > > > > PMC!
> > > > > > > > 
> > > > > > > >  Yuan is helping the community a lot with creating
> and
> > > > > > validating
> > > > > > > >  releases,
> > > > > > > >  contributing to FLIP discussions and good code
> > > > contributions
> > > > > > to
> > > > > > > > >> the
> > > > > > > >  state backend and related components.
> > > > > > > > 
> > > > > > > >  Congratulations and welcome, Yuan!
> > > > > > > > 
> > > > > > > >  Best Regards,
> > > > > > > >  Yu (On behalf of the Apache Flink PMC)
> > > > > > > > 
> > > > > > > >  --
> > > > > > > > 
> > > > > > > >  Best regards,
> > > > > > > >  Anton Kalashnikov
> > > > > > > > 
> > > > > > > > 
> > > > > > > > >>
> > > > > > > >
> > > > > > > >
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> > >
> > > --
> > >
> > > Konstantin Knauf
> > >
> > > https://twitter.com/snntrable
> > >
> > > https://github.com/knaufk
> > >
> >
>

[ANNOUNCE] release-1.15 branch cut

[Yun Gao]

Hi devs,

The release-1.15 branch has been forked out from the master branch, at the 
commit 9c77f13e587d7cb52469cac934c6aaec28dcd17d. Also, the version 
on the master branch has been upgraded to 1.16-SNAPSHOT. 

 From now on, for PRs that should be presented in 1.15.0, please make sure: 
- Merge the PR into both master and release-1.15 branches 
- The JIRA ticket should be closed with the correct fix-versions (1.15.0 & 
1.16.0). 

 We are now creating the rc0, which is expected to be delivered soon. 

 Thank you~ 
Joe, Till & Yun Gao

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Francesco Guardiani]

Congratulations, Yuan!

On Mon, Mar 14, 2022 at 3:51 PM yanfei lei  wrote:

> Congratulations, Yuan!
>
>
>
> Zhilong Hong  于2022年3月14日周一 19:31写道：
>
> > Congratulations, Yuan!
> >
> > Best,
> > Zhilong
> >
> > On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> > wrote:
> >
> > > Congratulations, Yuan!
> > >
> > > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> > wrote:
> > >
> > > > Congratulations, Yuan!
> > > >
> > > > Best,
> > > > Jing Zhang
> > > >
> > > > Jing Ge  于2022年3月14日周一 18:15写道：
> > > >
> > > > > Congrats! Very well deserved!
> > > > >
> > > > > Best,
> > > > > Jing
> > > > >
> > > > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> > pnowoj...@apache.org>
> > > > > wrote:
> > > > >
> > > > > > Congratulations :)
> > > > > >
> > > > > > pon., 14 mar 2022 o 09:59 Yun Tang 
> napisał(a):
> > > > > >
> > > > > > > Congratulations, Yuan!
> > > > > > >
> > > > > > > Best,
> > > > > > > Yun Tang
> > > > > > > 
> > > > > > > From: Zakelly Lan 
> > > > > > > Sent: Monday, March 14, 2022 16:55
> > > > > > > To: dev@flink.apache.org 
> > > > > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > > > > >
> > > > > > > Congratulations, Yuan!
> > > > > > >
> > > > > > > Best,
> > > > > > > Zakelly
> > > > > > >
> > > > > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> > j...@ververica.com>
> > > > > > wrote:
> > > > > > >
> > > > > > > > Congrats Yuan.
> > > > > > > >
> > > > > > > > > On 14.03.2022, at 09:45, Arvid Heise 
> > wrote:
> > > > > > > > >
> > > > > > > > > Congratulations and well deserved!
> > > > > > > > >
> > > > > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > > map...@apache.org
> > > > >
> > > > > > > wrote:
> > > > > > > > >
> > > > > > > > >> Congratulations, Yuan.
> > > > > > > > >>
> > > > > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > > njucs...@gmail.com>
> > > > > > > wrote:
> > > > > > > > >>
> > > > > > > > >>> Congratulations, Yuan!
> > > > > > > > >>>
> > > > > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > > > > > kaa@yandex.com>
> > > > > > > > >>> wrote:
> > > > > > > > >>>
> > > > > > > >  Congratulations, Yuan!
> > > > > > > > 
> > > > > > > >  --
> > > > > > > > 
> > > > > > > >  Best regards,
> > > > > > > >  Anton Kalashnikov
> > > > > > > > 
> > > > > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > > > > Congratulations Yuan!
> > > > > > > > >
> > > > > > > > > Best,
> > > > > > > > > Leonard
> > > > > > > > >
> > > > > > > > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > > > > > > > >>
> > > > > > > > >> Congratulations!
> > > > > > > > >>
> > > > > > > > >> Best,
> > > > > > > > >> Yangze Guo
> > > > > > > > >>
> > > > > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > > > > > >  martijnvis...@apache.org> wrote:
> > > > > > > > >>> Congratulations Yuan!
> > > > > > > > >>>
> > > > > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li <
> car...@gmail.com>
> > > > > wrote:
> > > > > > > > >>>
> > > > > > > >  Hi all!
> > > > > > > > 
> > > > > > > >  I'm very happy to announce that Yuan Mei has joined
> > the
> > > > > Flink
> > > > > > > PMC!
> > > > > > > > 
> > > > > > > >  Yuan is helping the community a lot with creating
> and
> > > > > > validating
> > > > > > > >  releases,
> > > > > > > >  contributing to FLIP discussions and good code
> > > > contributions
> > > > > > to
> > > > > > > > >> the
> > > > > > > >  state backend and related components.
> > > > > > > > 
> > > > > > > >  Congratulations and welcome, Yuan!
> > > > > > > > 
> > > > > > > >  Best Regards,
> > > > > > > >  Yu (On behalf of the Apache Flink PMC)
> > > > > > > > 
> > > > > > > >  --
> > > > > > > > 
> > > > > > > >  Best regards,
> > > > > > > >  Anton Kalashnikov
> > > > > > > > 
> > > > > > > > 
> > > > > > > > >>
> > > > > > > >
> > > > > > > >
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> > >
> > > --
> > >
> > > Konstantin Knauf
> > >
> > > https://twitter.com/snntrable
> > >
> > > https://github.com/knaufk
> > >
> >
>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[yanfei lei]

Congratulations, Yuan!



Zhilong Hong  于2022年3月14日周一 19:31写道：

> Congratulations, Yuan!
>
> Best,
> Zhilong
>
> On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf 
> wrote:
>
> > Congratulations, Yuan!
> >
> > On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang 
> wrote:
> >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Jing Zhang
> > >
> > > Jing Ge  于2022年3月14日周一 18:15写道：
> > >
> > > > Congrats! Very well deserved!
> > > >
> > > > Best,
> > > > Jing
> > > >
> > > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski <
> pnowoj...@apache.org>
> > > > wrote:
> > > >
> > > > > Congratulations :)
> > > > >
> > > > > pon., 14 mar 2022 o 09:59 Yun Tang  napisał(a):
> > > > >
> > > > > > Congratulations, Yuan!
> > > > > >
> > > > > > Best,
> > > > > > Yun Tang
> > > > > > 
> > > > > > From: Zakelly Lan 
> > > > > > Sent: Monday, March 14, 2022 16:55
> > > > > > To: dev@flink.apache.org 
> > > > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > > > >
> > > > > > Congratulations, Yuan!
> > > > > >
> > > > > > Best,
> > > > > > Zakelly
> > > > > >
> > > > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser <
> j...@ververica.com>
> > > > > wrote:
> > > > > >
> > > > > > > Congrats Yuan.
> > > > > > >
> > > > > > > > On 14.03.2022, at 09:45, Arvid Heise 
> wrote:
> > > > > > > >
> > > > > > > > Congratulations and well deserved!
> > > > > > > >
> > > > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> > map...@apache.org
> > > >
> > > > > > wrote:
> > > > > > > >
> > > > > > > >> Congratulations, Yuan.
> > > > > > > >>
> > > > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> > njucs...@gmail.com>
> > > > > > wrote:
> > > > > > > >>
> > > > > > > >>> Congratulations, Yuan!
> > > > > > > >>>
> > > > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > > > > kaa@yandex.com>
> > > > > > > >>> wrote:
> > > > > > > >>>
> > > > > > >  Congratulations, Yuan!
> > > > > > > 
> > > > > > >  --
> > > > > > > 
> > > > > > >  Best regards,
> > > > > > >  Anton Kalashnikov
> > > > > > > 
> > > > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > > > Congratulations Yuan!
> > > > > > > >
> > > > > > > > Best,
> > > > > > > > Leonard
> > > > > > > >
> > > > > > > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > > > > > > >>
> > > > > > > >> Congratulations!
> > > > > > > >>
> > > > > > > >> Best,
> > > > > > > >> Yangze Guo
> > > > > > > >>
> > > > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > > > > >  martijnvis...@apache.org> wrote:
> > > > > > > >>> Congratulations Yuan!
> > > > > > > >>>
> > > > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li 
> > > > wrote:
> > > > > > > >>>
> > > > > > >  Hi all!
> > > > > > > 
> > > > > > >  I'm very happy to announce that Yuan Mei has joined
> the
> > > > Flink
> > > > > > PMC!
> > > > > > > 
> > > > > > >  Yuan is helping the community a lot with creating and
> > > > > validating
> > > > > > >  releases,
> > > > > > >  contributing to FLIP discussions and good code
> > > contributions
> > > > > to
> > > > > > > >> the
> > > > > > >  state backend and related components.
> > > > > > > 
> > > > > > >  Congratulations and welcome, Yuan!
> > > > > > > 
> > > > > > >  Best Regards,
> > > > > > >  Yu (On behalf of the Apache Flink PMC)
> > > > > > > 
> > > > > > >  --
> > > > > > > 
> > > > > > >  Best regards,
> > > > > > >  Anton Kalashnikov
> > > > > > > 
> > > > > > > 
> > > > > > > >>
> > > > > > >
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> >
> > --
> >
> > Konstantin Knauf
> >
> > https://twitter.com/snntrable
> >
> > https://github.com/knaufk
> >
>

[jira] [Created] (FLINK-26638) Reintroduce ActionFailureHandler for Elasticsearch sink connectors

[Alexander Preuss (Jira)]

Alexander Preuss created FLINK-26638:


 Summary: Reintroduce ActionFailureHandler for Elasticsearch sink 
connectors
 Key: FLINK-26638
 URL: https://issues.apache.org/jira/browse/FLINK-26638
 Project: Flink
  Issue Type: New Feature
  Components: Connectors / ElasticSearch
Affects Versions: 1.16.0
Reporter: Alexander Preuss


In FLINK-26281 we found out that users depend on the ActionFailureHandler that 
was not ported over to the new unified Sink. We not want to add the failure 
handler back.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Created] (FLINK-26637) Document Basic Concepts and Architecture

[Matyas Orhidi (Jira)]

Matyas Orhidi created FLINK-26637:
-

 Summary: Document Basic Concepts and Architecture
 Key: FLINK-26637
 URL: https://issues.apache.org/jira/browse/FLINK-26637
 Project: Flink
  Issue Type: Sub-task
Reporter: Matyas Orhidi






--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Zhilong Hong]

Congratulations, Yuan!

Best,
Zhilong

On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf  wrote:

> Congratulations, Yuan!
>
> On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang  wrote:
>
> > Congratulations, Yuan!
> >
> > Best,
> > Jing Zhang
> >
> > Jing Ge  于2022年3月14日周一 18:15写道：
> >
> > > Congrats! Very well deserved!
> > >
> > > Best,
> > > Jing
> > >
> > > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski 
> > > wrote:
> > >
> > > > Congratulations :)
> > > >
> > > > pon., 14 mar 2022 o 09:59 Yun Tang  napisał(a):
> > > >
> > > > > Congratulations, Yuan!
> > > > >
> > > > > Best,
> > > > > Yun Tang
> > > > > 
> > > > > From: Zakelly Lan 
> > > > > Sent: Monday, March 14, 2022 16:55
> > > > > To: dev@flink.apache.org 
> > > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > > >
> > > > > Congratulations, Yuan!
> > > > >
> > > > > Best,
> > > > > Zakelly
> > > > >
> > > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser 
> > > > wrote:
> > > > >
> > > > > > Congrats Yuan.
> > > > > >
> > > > > > > On 14.03.2022, at 09:45, Arvid Heise  wrote:
> > > > > > >
> > > > > > > Congratulations and well deserved!
> > > > > > >
> > > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl <
> map...@apache.org
> > >
> > > > > wrote:
> > > > > > >
> > > > > > >> Congratulations, Yuan.
> > > > > > >>
> > > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng <
> njucs...@gmail.com>
> > > > > wrote:
> > > > > > >>
> > > > > > >>> Congratulations, Yuan!
> > > > > > >>>
> > > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > > > kaa@yandex.com>
> > > > > > >>> wrote:
> > > > > > >>>
> > > > > >  Congratulations, Yuan!
> > > > > > 
> > > > > >  --
> > > > > > 
> > > > > >  Best regards,
> > > > > >  Anton Kalashnikov
> > > > > > 
> > > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > > Congratulations Yuan!
> > > > > > >
> > > > > > > Best,
> > > > > > > Leonard
> > > > > > >
> > > > > > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > > > > > >>
> > > > > > >> Congratulations!
> > > > > > >>
> > > > > > >> Best,
> > > > > > >> Yangze Guo
> > > > > > >>
> > > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > > > >  martijnvis...@apache.org> wrote:
> > > > > > >>> Congratulations Yuan!
> > > > > > >>>
> > > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li 
> > > wrote:
> > > > > > >>>
> > > > > >  Hi all!
> > > > > > 
> > > > > >  I'm very happy to announce that Yuan Mei has joined the
> > > Flink
> > > > > PMC!
> > > > > > 
> > > > > >  Yuan is helping the community a lot with creating and
> > > > validating
> > > > > >  releases,
> > > > > >  contributing to FLIP discussions and good code
> > contributions
> > > > to
> > > > > > >> the
> > > > > >  state backend and related components.
> > > > > > 
> > > > > >  Congratulations and welcome, Yuan!
> > > > > > 
> > > > > >  Best Regards,
> > > > > >  Yu (On behalf of the Apache Flink PMC)
> > > > > > 
> > > > > >  --
> > > > > > 
> > > > > >  Best regards,
> > > > > >  Anton Kalashnikov
> > > > > > 
> > > > > > 
> > > > > > >>
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
>
>
> --
>
> Konstantin Knauf
>
> https://twitter.com/snntrable
>
> https://github.com/knaufk
>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Konstantin Knauf]

Congratulations, Yuan!

On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang  wrote:

> Congratulations, Yuan!
>
> Best,
> Jing Zhang
>
> Jing Ge  于2022年3月14日周一 18:15写道：
>
> > Congrats! Very well deserved!
> >
> > Best,
> > Jing
> >
> > On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski 
> > wrote:
> >
> > > Congratulations :)
> > >
> > > pon., 14 mar 2022 o 09:59 Yun Tang  napisał(a):
> > >
> > > > Congratulations, Yuan!
> > > >
> > > > Best,
> > > > Yun Tang
> > > > 
> > > > From: Zakelly Lan 
> > > > Sent: Monday, March 14, 2022 16:55
> > > > To: dev@flink.apache.org 
> > > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > > >
> > > > Congratulations, Yuan!
> > > >
> > > > Best,
> > > > Zakelly
> > > >
> > > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser 
> > > wrote:
> > > >
> > > > > Congrats Yuan.
> > > > >
> > > > > > On 14.03.2022, at 09:45, Arvid Heise  wrote:
> > > > > >
> > > > > > Congratulations and well deserved!
> > > > > >
> > > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl  >
> > > > wrote:
> > > > > >
> > > > > >> Congratulations, Yuan.
> > > > > >>
> > > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng 
> > > > wrote:
> > > > > >>
> > > > > >>> Congratulations, Yuan!
> > > > > >>>
> > > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > > kaa@yandex.com>
> > > > > >>> wrote:
> > > > > >>>
> > > > >  Congratulations, Yuan!
> > > > > 
> > > > >  --
> > > > > 
> > > > >  Best regards,
> > > > >  Anton Kalashnikov
> > > > > 
> > > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > > Congratulations Yuan!
> > > > > >
> > > > > > Best,
> > > > > > Leonard
> > > > > >
> > > > > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > > > > >>
> > > > > >> Congratulations!
> > > > > >>
> > > > > >> Best,
> > > > > >> Yangze Guo
> > > > > >>
> > > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > > >  martijnvis...@apache.org> wrote:
> > > > > >>> Congratulations Yuan!
> > > > > >>>
> > > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li 
> > wrote:
> > > > > >>>
> > > > >  Hi all!
> > > > > 
> > > > >  I'm very happy to announce that Yuan Mei has joined the
> > Flink
> > > > PMC!
> > > > > 
> > > > >  Yuan is helping the community a lot with creating and
> > > validating
> > > > >  releases,
> > > > >  contributing to FLIP discussions and good code
> contributions
> > > to
> > > > > >> the
> > > > >  state backend and related components.
> > > > > 
> > > > >  Congratulations and welcome, Yuan!
> > > > > 
> > > > >  Best Regards,
> > > > >  Yu (On behalf of the Apache Flink PMC)
> > > > > 
> > > > >  --
> > > > > 
> > > > >  Best regards,
> > > > >  Anton Kalashnikov
> > > > > 
> > > > > 
> > > > > >>
> > > > >
> > > > >
> > > >
> > >
> >
>


-- 

Konstantin Knauf

https://twitter.com/snntrable

https://github.com/knaufk

[jira] [Created] (FLINK-26636) EmbeddedMultiThreadDependencyTests test_add_python_file failed on azure

[Roman Khachatryan (Jira)]

Roman Khachatryan created FLINK-26636:
-

 Summary: EmbeddedMultiThreadDependencyTests test_add_python_file 
failed on azure
 Key: FLINK-26636
 URL: https://issues.apache.org/jira/browse/FLINK-26636
 Project: Flink
  Issue Type: Bug
Reporter: Roman Khachatryan


https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32981=logs=e92ecf6d-e207-5a42-7ff7-528ff0c5b259=40fc352e-9b4c-5fd8-363f-628f24b01ec2=28024

{code}

2022-03-14T04:11:09.7985367Z Mar 14 04:11:09 
=== FAILURES ===
2022-03-14T04:11:09.7988965Z Mar 14 04:11:09 ___ 
EmbeddedMultiThreadDependencyTests.test_add_python_file 
2022-03-14T04:11:09.7989557Z Mar 14 04:11:09 
2022-03-14T04:11:09.7990098Z Mar 14 04:11:09 self = 

2022-03-14T04:11:09.7990644Z Mar 14 04:11:09 
2022-03-14T04:11:09.7991165Z Mar 14 04:11:09 def test_add_python_file(self):
2022-03-14T04:11:09.7991785Z Mar 14 04:11:09 python_file_dir = 
os.path.join(self.tempdir, "python_file_dir_" + str(uuid.uuid4()))
2022-03-14T04:11:09.7992318Z Mar 14 04:11:09 os.mkdir(python_file_dir)
2022-03-14T04:11:09.7993113Z Mar 14 04:11:09 python_file_path = 
os.path.join(python_file_dir, "test_dependency_manage_lib.py")
2022-03-14T04:11:09.7994443Z Mar 14 04:11:09 with 
open(python_file_path, 'w') as f:
2022-03-14T04:11:09.7995251Z Mar 14 04:11:09 f.write("def 
add_two(a):\nraise Exception('This function should not be called!')")
2022-03-14T04:11:09.7997796Z Mar 14 04:11:09 
self.t_env.add_python_file(python_file_path)
2022-03-14T04:11:09.7998592Z Mar 14 04:11:09 
2022-03-14T04:11:09.7999298Z Mar 14 04:11:09 
python_file_dir_with_higher_priority = os.path.join(
2022-03-14T04:11:09.8000146Z Mar 14 04:11:09 self.tempdir, 
"python_file_dir_" + str(uuid.uuid4()))
2022-03-14T04:11:09.8001027Z Mar 14 04:11:09 
os.mkdir(python_file_dir_with_higher_priority)
2022-03-14T04:11:09.8001891Z Mar 14 04:11:09 
python_file_path_higher_priority = 
os.path.join(python_file_dir_with_higher_priority,
2022-03-14T04:11:09.8002526Z Mar 14 04:11:09
 "test_dependency_manage_lib.py")
2022-03-14T04:11:09.8003945Z Mar 14 04:11:09 with 
open(python_file_path_higher_priority, 'w') as f:
2022-03-14T04:11:09.8004664Z Mar 14 04:11:09 f.write("def 
add_two(a):\nreturn a + 2")
2022-03-14T04:11:09.8005208Z Mar 14 04:11:09 
self.t_env.add_python_file(python_file_path_higher_priority)
2022-03-14T04:11:09.8005648Z Mar 14 04:11:09 
2022-03-14T04:11:09.8005992Z Mar 14 04:11:09 def plus_two(i):
2022-03-14T04:11:09.8006430Z Mar 14 04:11:09 from 
test_dependency_manage_lib import add_two
2022-03-14T04:11:09.8006857Z Mar 14 04:11:09 return add_two(i)
2022-03-14T04:11:09.8007204Z Mar 14 04:11:09 
2022-03-14T04:11:09.8007605Z Mar 14 04:11:09 
self.t_env.create_temporary_system_function(
2022-03-14T04:11:09.8008206Z Mar 14 04:11:09 "add_two", 
udf(plus_two, DataTypes.BIGINT(), DataTypes.BIGINT()))
2022-03-14T04:11:09.8008742Z Mar 14 04:11:09 table_sink = 
source_sink_utils.TestAppendSink(
2022-03-14T04:11:09.8009465Z Mar 14 04:11:09 ['a', 'b'], 
[DataTypes.BIGINT(), DataTypes.BIGINT()])
2022-03-14T04:11:09.8009993Z Mar 14 04:11:09 
self.t_env.register_table_sink("Results", table_sink)
2022-03-14T04:11:09.8010763Z Mar 14 04:11:09 t = 
self.t_env.from_elements([(1, 2), (2, 5), (3, 1)], ['a', 'b'])
2022-03-14T04:11:09.8011324Z Mar 14 04:11:09 >   
t.select(expr.call("add_two", t.a), t.a).execute_insert("Results").wait()
2022-03-14T04:11:09.8011779Z Mar 14 04:11:09 
2022-03-14T04:11:09.8012176Z Mar 14 04:11:09 
pyflink/table/tests/test_dependency.py:63: 
2022-03-14T04:11:09.8012677Z Mar 14 04:11:09 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
2022-03-14T04:11:09.8013574Z Mar 14 04:11:09 pyflink/table/table_result.py:76: 
in wait
2022-03-14T04:11:09.8014041Z Mar 14 04:11:09 
get_method(self._j_table_result, "await")()
2022-03-14T04:11:09.8014843Z Mar 14 04:11:09 
.tox/py38-cython/lib/python3.8/site-packages/py4j/java_gateway.py:1321: in 
__call__
2022-03-14T04:11:09.8015387Z Mar 14 04:11:09 return_value = 
get_return_value(
2022-03-14T04:11:09.8015843Z Mar 14 04:11:09 pyflink/util/exceptions.py:146: in 
deco
2022-03-14T04:11:09.8016267Z Mar 14 04:11:09 return f(*a, **kw)
2022-03-14T04:11:09.8016720Z Mar 14 04:11:09 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
2022-03-14T04:11:09.8017116Z Mar 14 04:11:09 
2022-03-14T04:11:09.8017626Z Mar 14 04:11:09 answer = 'xro2722'
2022-03-14T04:11:09.8018127Z Mar 14 04:11:09 gateway_client = 

2022-03-14T04:11:09.8018812Z Mar 14 04:11:09 

[jira] [Created] (FLINK-26635) KafkaSourceE2ECase.testMultipleSplits failed on azure with Correlation id for response does not match request

[Roman Khachatryan (Jira)]

Roman Khachatryan created FLINK-26635:
-

 Summary: KafkaSourceE2ECase.testMultipleSplits failed on azure 
with Correlation id for response does not match request
 Key: FLINK-26635
 URL: https://issues.apache.org/jira/browse/FLINK-26635
 Project: Flink
  Issue Type: Bug
  Components: Connectors / Kafka
Affects Versions: 1.15.0
Reporter: Roman Khachatryan


https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32981=logs=af184cdd-c6d8-5084-0b69-7e9c67b35f7a=160c9ae5-96fd-516e-1c91-deb81f59292a=14703

{code}
2022-03-14T03:35:34.8710354Z Mar 14 03:35:34 [ERROR] Tests run: 16, Failures: 
0, Errors: 1, Skipped: 0, Time elapsed: 184.49 s <<< FAILURE! - in 
org.apache.flink.tests.util.kafka.KafkaSourceE2ECase
2022-03-14T03:35:34.8881150Z Mar 14 03:35:34 [ERROR] 
org.apache.flink.tests.util.kafka.KafkaSourceE2ECase.testMultipleSplits(TestEnvironment,
 DataStreamSourceExternalContext, CheckpointingMode)[1]  Time elapsed: 3.769 s  
<<< ERROR!
2022-03-14T03:35:34.8882315Z Mar 14 03:35:34 java.lang.RuntimeException: Failed 
to fetch next result
2022-03-14T03:35:34.8886537Z Mar 14 03:35:34at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
2022-03-14T03:35:34.8887677Z Mar 14 03:35:34at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
2022-03-14T03:35:34.672Z Mar 14 03:35:34at 
org.apache.flink.connector.testframe.utils.CollectIteratorAssert.compareWithExactlyOnceSemantic(CollectIteratorAssert.java:116)
2022-03-14T03:35:34.8889715Z Mar 14 03:35:34at 
org.apache.flink.connector.testframe.utils.CollectIteratorAssert.matchesRecordsFromSource(CollectIteratorAssert.java:71)
2022-03-14T03:35:34.8890700Z Mar 14 03:35:34at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.checkResultWithSemantic(SourceTestSuiteBase.java:769)
2022-03-14T03:35:34.8891663Z Mar 14 03:35:34at 
org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testMultipleSplits(SourceTestSuiteBase.java:218)
2022-03-14T03:35:34.8892432Z Mar 14 03:35:34at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-03-14T03:35:34.8893159Z Mar 14 03:35:34at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-03-14T03:35:34.8893940Z Mar 14 03:35:34at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-03-14T03:35:34.8894691Z Mar 14 03:35:34at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-03-14T03:35:34.8895694Z Mar 14 03:35:34at 
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
2022-03-14T03:35:34.8896532Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-03-14T03:35:34.8897443Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-03-14T03:35:34.8898353Z Mar 14 03:35:34at 
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
2022-03-14T03:35:34.8899200Z Mar 14 03:35:34at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
2022-03-14T03:35:34.8901355Z Mar 14 03:35:34at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
2022-03-14T03:35:34.8902346Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
2022-03-14T03:35:34.8903536Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
2022-03-14T03:35:34.8904460Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-03-14T03:35:34.8905743Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-03-14T03:35:34.8906674Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-03-14T03:35:34.8907606Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-03-14T03:35:34.8908447Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
2022-03-14T03:35:34.8909283Z Mar 14 03:35:34at 
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
2022-03-14T03:35:34.8910366Z Mar 14 03:35:34at 

[jira] [Created] (FLINK-26634) Update Chinese version of Elasticsearch connector docs

[Alexander Preuss (Jira)]

Alexander Preuss created FLINK-26634:


 Summary: Update Chinese version of Elasticsearch connector docs
 Key: FLINK-26634
 URL: https://issues.apache.org/jira/browse/FLINK-26634
 Project: Flink
  Issue Type: Improvement
  Components: chinese-translation, Documentation
Affects Versions: 1.15.0
Reporter: Alexander Preuss


In [https://github.com/apache/flink/pull/19035] we made some smaller changes to 
the documentation for the Elasticsearch connector with regards to the delivery 
guarantee. These changes still not to be ported over to the chinese docs.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Created] (FLINK-26633) Elasticsearch connector does not report recordsSend metric

[Fabian Paul (Jira)]

Fabian Paul created FLINK-26633:
---

 Summary: Elasticsearch connector does not report recordsSend metric
 Key: FLINK-26633
 URL: https://issues.apache.org/jira/browse/FLINK-26633
 Project: Flink
  Issue Type: Bug
  Components: Connectors / ElasticSearch
Affects Versions: 1.15.0
Reporter: Fabian Paul
 Fix For: 1.15.0


As part of a unified sink, it is recommended to report a recordSend metric to 
let users track the number of outgoing records from Flink.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Created] (FLINK-26632) JobManagerHAProcessFailureRecoveryITCase failed due to JVM exits with code 239

[Roman Khachatryan (Jira)]

Roman Khachatryan created FLINK-26632:
-

 Summary: JobManagerHAProcessFailureRecoveryITCase failed due to 
JVM exits with code 239
 Key: FLINK-26632
 URL: https://issues.apache.org/jira/browse/FLINK-26632
 Project: Flink
  Issue Type: Bug
  Components: Tests
Affects Versions: 1.15.0
Reporter: Roman Khachatryan


[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32979=logs=5c8e7682-d68f-54d1-16a2-a09310218a49=86f654fa-ab48-5c1a-25f4-7e7f6afb9bba=5486]

 {code}
 Mar 14 02:32:25 [ERROR] Error occurred in starting fork, check output in log
 Mar 14 02:32:25 [ERROR] Process Exit Code: 239
 Mar 14 02:32:25 [ERROR] Crashed tests:
 Mar 14 02:32:25 [ERROR] 
org.apache.flink.test.recovery.JobManagerHAProcessFailureRecoveryITCase
 Mar 14 02:32:25 [ERROR] at 
org.apache.maven.plugin.surefire.booterclient.ForkStarter.fork(ForkStarter.java:669)
 Mar 14 02:32:25 [ERROR] at 
org.apache.maven.plugin.surefire.booterclient.ForkStarter.access$600(ForkStarter.java:115)
 Mar 14 02:32:25 [ERROR] at 
org.apache.maven.plugin.surefire.booterclient.ForkStarter$2.call(ForkStarter.java:444)
 Mar 14 02:32:25 [ERROR] at 
org.apache.maven.plugin.surefire.booterclient.ForkStarter$2.call(ForkStarter.java:420)
 Mar 14 02:32:25 [ERROR] at 
java.util.concurrent.FutureTask.run(FutureTask.java:266)
 Mar 14 02:32:25 [ERROR] at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
 Mar 14 02:32:25 [ERROR] at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
 Mar 14 02:32:25 [ERROR] at java.lang.Thread.run(Thread.java:748)
 Mar 14 02:32:25 [ERROR] -> [Help 1]

 {code}




--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Jing Zhang]

Congratulations, Yuan!

Best,
Jing Zhang

Jing Ge  于2022年3月14日周一 18:15写道：

> Congrats! Very well deserved!
>
> Best,
> Jing
>
> On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski 
> wrote:
>
> > Congratulations :)
> >
> > pon., 14 mar 2022 o 09:59 Yun Tang  napisał(a):
> >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Yun Tang
> > > 
> > > From: Zakelly Lan 
> > > Sent: Monday, March 14, 2022 16:55
> > > To: dev@flink.apache.org 
> > > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> > >
> > > Congratulations, Yuan!
> > >
> > > Best,
> > > Zakelly
> > >
> > > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser 
> > wrote:
> > >
> > > > Congrats Yuan.
> > > >
> > > > > On 14.03.2022, at 09:45, Arvid Heise  wrote:
> > > > >
> > > > > Congratulations and well deserved!
> > > > >
> > > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl 
> > > wrote:
> > > > >
> > > > >> Congratulations, Yuan.
> > > > >>
> > > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng 
> > > wrote:
> > > > >>
> > > > >>> Congratulations, Yuan!
> > > > >>>
> > > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > > kaa@yandex.com>
> > > > >>> wrote:
> > > > >>>
> > > >  Congratulations, Yuan!
> > > > 
> > > >  --
> > > > 
> > > >  Best regards,
> > > >  Anton Kalashnikov
> > > > 
> > > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > > Congratulations Yuan!
> > > > >
> > > > > Best,
> > > > > Leonard
> > > > >
> > > > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > > > >>
> > > > >> Congratulations!
> > > > >>
> > > > >> Best,
> > > > >> Yangze Guo
> > > > >>
> > > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > >  martijnvis...@apache.org> wrote:
> > > > >>> Congratulations Yuan!
> > > > >>>
> > > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li 
> wrote:
> > > > >>>
> > > >  Hi all!
> > > > 
> > > >  I'm very happy to announce that Yuan Mei has joined the
> Flink
> > > PMC!
> > > > 
> > > >  Yuan is helping the community a lot with creating and
> > validating
> > > >  releases,
> > > >  contributing to FLIP discussions and good code contributions
> > to
> > > > >> the
> > > >  state backend and related components.
> > > > 
> > > >  Congratulations and welcome, Yuan!
> > > > 
> > > >  Best Regards,
> > > >  Yu (On behalf of the Apache Flink PMC)
> > > > 
> > > >  --
> > > > 
> > > >  Best regards,
> > > >  Anton Kalashnikov
> > > > 
> > > > 
> > > > >>
> > > >
> > > >
> > >
> >
>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Jing Ge]

Congrats! Very well deserved!

Best,
Jing

On Mon, Mar 14, 2022 at 10:34 AM Piotr Nowojski 
wrote:

> Congratulations :)
>
> pon., 14 mar 2022 o 09:59 Yun Tang  napisał(a):
>
> > Congratulations, Yuan!
> >
> > Best,
> > Yun Tang
> > 
> > From: Zakelly Lan 
> > Sent: Monday, March 14, 2022 16:55
> > To: dev@flink.apache.org 
> > Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
> >
> > Congratulations, Yuan!
> >
> > Best,
> > Zakelly
> >
> > On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser 
> wrote:
> >
> > > Congrats Yuan.
> > >
> > > > On 14.03.2022, at 09:45, Arvid Heise  wrote:
> > > >
> > > > Congratulations and well deserved!
> > > >
> > > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl 
> > wrote:
> > > >
> > > >> Congratulations, Yuan.
> > > >>
> > > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng 
> > wrote:
> > > >>
> > > >>> Congratulations, Yuan!
> > > >>>
> > > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> > kaa@yandex.com>
> > > >>> wrote:
> > > >>>
> > >  Congratulations, Yuan!
> > > 
> > >  --
> > > 
> > >  Best regards,
> > >  Anton Kalashnikov
> > > 
> > >  14.03.2022 09:13, Leonard Xu пишет:
> > > > Congratulations Yuan!
> > > >
> > > > Best,
> > > > Leonard
> > > >
> > > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > > >>
> > > >> Congratulations!
> > > >>
> > > >> Best,
> > > >> Yangze Guo
> > > >>
> > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > >  martijnvis...@apache.org> wrote:
> > > >>> Congratulations Yuan!
> > > >>>
> > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
> > > >>>
> > >  Hi all!
> > > 
> > >  I'm very happy to announce that Yuan Mei has joined the Flink
> > PMC!
> > > 
> > >  Yuan is helping the community a lot with creating and
> validating
> > >  releases,
> > >  contributing to FLIP discussions and good code contributions
> to
> > > >> the
> > >  state backend and related components.
> > > 
> > >  Congratulations and welcome, Yuan!
> > > 
> > >  Best Regards,
> > >  Yu (On behalf of the Apache Flink PMC)
> > > 
> > >  --
> > > 
> > >  Best regards,
> > >  Anton Kalashnikov
> > > 
> > > 
> > > >>
> > >
> > >
> >
>

[jira] [Created] (FLINK-26631) The official website is unavailable

[Jira]

李伟高 created FLINK-26631:
---

 Summary: The official website is unavailable
 Key: FLINK-26631
 URL: https://issues.apache.org/jira/browse/FLINK-26631
 Project: Flink
  Issue Type: Bug
  Components: Project Website
Reporter: 李伟高
 Attachments: image-2022-03-14-17-39-49-898.png

!image-2022-03-14-17-39-49-898.png!



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Piotr Nowojski]

Congratulations :)

pon., 14 mar 2022 o 09:59 Yun Tang  napisał(a):

> Congratulations, Yuan!
>
> Best,
> Yun Tang
> 
> From: Zakelly Lan 
> Sent: Monday, March 14, 2022 16:55
> To: dev@flink.apache.org 
> Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei
>
> Congratulations, Yuan!
>
> Best,
> Zakelly
>
> On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser  wrote:
>
> > Congrats Yuan.
> >
> > > On 14.03.2022, at 09:45, Arvid Heise  wrote:
> > >
> > > Congratulations and well deserved!
> > >
> > > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl 
> wrote:
> > >
> > >> Congratulations, Yuan.
> > >>
> > >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng 
> wrote:
> > >>
> > >>> Congratulations, Yuan!
> > >>>
> > >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov <
> kaa@yandex.com>
> > >>> wrote:
> > >>>
> >  Congratulations, Yuan!
> > 
> >  --
> > 
> >  Best regards,
> >  Anton Kalashnikov
> > 
> >  14.03.2022 09:13, Leonard Xu пишет:
> > > Congratulations Yuan!
> > >
> > > Best,
> > > Leonard
> > >
> > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > >>
> > >> Congratulations!
> > >>
> > >> Best,
> > >> Yangze Guo
> > >>
> > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> >  martijnvis...@apache.org> wrote:
> > >>> Congratulations Yuan!
> > >>>
> > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
> > >>>
> >  Hi all!
> > 
> >  I'm very happy to announce that Yuan Mei has joined the Flink
> PMC!
> > 
> >  Yuan is helping the community a lot with creating and validating
> >  releases,
> >  contributing to FLIP discussions and good code contributions to
> > >> the
> >  state backend and related components.
> > 
> >  Congratulations and welcome, Yuan!
> > 
> >  Best Regards,
> >  Yu (On behalf of the Apache Flink PMC)
> > 
> >  --
> > 
> >  Best regards,
> >  Anton Kalashnikov
> > 
> > 
> > >>
> >
> >
>

[jira] [Created] (FLINK-26630) EmbeddedHaServices is not made for recovery on a single instance

[Matthias Pohl (Jira)]

Matthias Pohl created FLINK-26630:
-

 Summary: EmbeddedHaServices is not made for recovery on a single 
instance
 Key: FLINK-26630
 URL: https://issues.apache.org/jira/browse/FLINK-26630
 Project: Flink
  Issue Type: Bug
  Components: Runtime / Coordination
Affects Versions: 1.15.0
Reporter: Matthias Pohl


{{EmbeddedHaServices}} (and {{EmbeddedHaServicesWithLeadershipControl}}) 
provide leader election functionality to work on a single JVM. In FLINK-25235 
we introduced the re-instantiation of {{HighAvailabilityServices}} per 
{{JobManager}} (i.e. {{DispatcherResourceManagerComponent}}) to be able to 
close the HighAvailabilityServices during the shutdown of a JM and not only at 
the end of the HA cluster to get closer to a production environment where each 
JM has its own HAServices instance as well (that became crucial as part of the 
work of FLINK-24038 which revokes the leadership when it closes the HAServices 
during a JM shutdown).



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Re: [ANNOUNCE] New Apache Flink Committer - David Morávek

[Zakelly Lan]

Congratulations, David!

Best,
Zakelly

On Mon, Mar 14, 2022 at 4:53 PM Arvid Heise  wrote:

> Gratz!
>
> On Mon, Mar 14, 2022 at 9:24 AM Anton Kalashnikov 
> wrote:
>
> > Congratulations, David!
> >
> > --
> >
> > Best regards,
> > Anton Kalashnikov
> >
> > 14.03.2022 09:18, Matthias Pohl пишет:
> > > Congratulations, David!
> >
> >
>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Yun Tang]

Congratulations, Yuan!

Best,
Yun Tang

From: Zakelly Lan 
Sent: Monday, March 14, 2022 16:55
To: dev@flink.apache.org 
Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei

Congratulations, Yuan!

Best,
Zakelly

On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser  wrote:

> Congrats Yuan.
>
> > On 14.03.2022, at 09:45, Arvid Heise  wrote:
> >
> > Congratulations and well deserved!
> >
> > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl  wrote:
> >
> >> Congratulations, Yuan.
> >>
> >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng  wrote:
> >>
> >>> Congratulations, Yuan!
> >>>
> >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov 
> >>> wrote:
> >>>
>  Congratulations, Yuan!
> 
>  --
> 
>  Best regards,
>  Anton Kalashnikov
> 
>  14.03.2022 09:13, Leonard Xu пишет:
> > Congratulations Yuan!
> >
> > Best,
> > Leonard
> >
> >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> >>
> >> Congratulations!
> >>
> >> Best,
> >> Yangze Guo
> >>
> >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
>  martijnvis...@apache.org> wrote:
> >>> Congratulations Yuan!
> >>>
> >>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
> >>>
>  Hi all!
> 
>  I'm very happy to announce that Yuan Mei has joined the Flink PMC!
> 
>  Yuan is helping the community a lot with creating and validating
>  releases,
>  contributing to FLIP discussions and good code contributions to
> >> the
>  state backend and related components.
> 
>  Congratulations and welcome, Yuan!
> 
>  Best Regards,
>  Yu (On behalf of the Apache Flink PMC)
> 
>  --
> 
>  Best regards,
>  Anton Kalashnikov
> 
> 
> >>
>
>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Zakelly Lan]

Congratulations, Yuan!

Best,
Zakelly

On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser  wrote:

> Congrats Yuan.
>
> > On 14.03.2022, at 09:45, Arvid Heise  wrote:
> >
> > Congratulations and well deserved!
> >
> > On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl  wrote:
> >
> >> Congratulations, Yuan.
> >>
> >> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng  wrote:
> >>
> >>> Congratulations, Yuan!
> >>>
> >>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov 
> >>> wrote:
> >>>
>  Congratulations, Yuan!
> 
>  --
> 
>  Best regards,
>  Anton Kalashnikov
> 
>  14.03.2022 09:13, Leonard Xu пишет:
> > Congratulations Yuan!
> >
> > Best,
> > Leonard
> >
> >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> >>
> >> Congratulations!
> >>
> >> Best,
> >> Yangze Guo
> >>
> >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
>  martijnvis...@apache.org> wrote:
> >>> Congratulations Yuan!
> >>>
> >>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
> >>>
>  Hi all!
> 
>  I'm very happy to announce that Yuan Mei has joined the Flink PMC!
> 
>  Yuan is helping the community a lot with creating and validating
>  releases,
>  contributing to FLIP discussions and good code contributions to
> >> the
>  state backend and related components.
> 
>  Congratulations and welcome, Yuan!
> 
>  Best Regards,
>  Yu (On behalf of the Apache Flink PMC)
> 
>  --
> 
>  Best regards,
>  Anton Kalashnikov
> 
> 
> >>
>
>

Re: [ANNOUNCE] New Apache Flink Committer - David Morávek

[Arvid Heise]

Gratz!

On Mon, Mar 14, 2022 at 9:24 AM Anton Kalashnikov 
wrote:

> Congratulations, David!
>
> --
>
> Best regards,
> Anton Kalashnikov
>
> 14.03.2022 09:18, Matthias Pohl пишет:
> > Congratulations, David!
>
>

Re: [DISCUSS] Preview release for Flink Kubernetes Operator

[Gyula Fóra]

Hi Xintong!

Thank you for the valuable input, you are completely right we need to agree
and document these aspects.

Let me try to address some of the questions and others should chip in also
:)

1. Version convention:

I think we should adopt the 3 digit versioning scheme like other flink
projects (I think flink-shaded is a bit of an outlier here).
The preview release should be 0.1.0.

The supported Flink versions should be documented with the release, each
version of the operator should technically be able to support multiple
Flink versions at the same time.
For the preview release this should be Flink version >= 1.14. We should
later come up with a guarantee that we do not drop flink version support
within the same minor version.

The only public API here at the moment are the custom resource definitions.
We agreed to mark them all experimental for the preview release, and I
think for 1.0.0 we  should aim for public evolving.
Otherwise we should respect the Flink guarantees here. Practically this
means that for the preview release we do not guarantee anything in terms of
later compatibility.

2. Release process:
I agree that we should follow the official Flink process as much as
possible (and makes sense) with proper voting etc.

Cheers,
Gyula


On Mon, Mar 14, 2022 at 8:32 AM Xintong Song  wrote:

> How everyone,
>
> It's great to learn that we are approaching a preview release for
> the flink-kubernetes-operator. Thanks for the efforts.
>
> I have not been involved with any developing efforts in
> flink-kubernetes-operator, thus have no comment on end of March being the
> targeting date.
>
> However, based on my experiences being one of the Flink release managers, I
> see a few things that are still missing for creating an official release.
> (IIUC, the preview release is still an official release, just with weak
> functionality and compatibility guarantees.)
>
> 1. The version conventions:
> - How does a flink-kubernetes-operator version look like? E.g., flink /
> flink-statefun / flink-ml have three digits x.y.z, while flink-shaded has
> only two digits x.y.
> - What is the relationship between flink-kubernetes-operator and flink
> versions? E.g., flink-shaded x.* is only designed to support flink *.x.*.
> - What kind of compatibility guarantees do we provide? E.g., flink expects
> no Public API compatibility should be broken between minor releases (the
> 2nd digit) and no PublicEvolving APIs should be broken between bugfix
> releases (the 3rd digit).
> - What kind of support do we provide for old releases? E.g., flink provides
> bug fixes for the latest two minor releases (the 2nd digit).
>
> 2. Release process
> You may find the release process for all Flink artifacts in this wiki page
> [1]. Such a formal documented process would help us to reach consensus on
> what needs to be done and make sure it complies with the ASF regulations
> before creating a release. We probably don't need something as formal as a
> vote to approve the release process. But we definitely need a formal vote
> for the flink-kubernetes-operator release, and the release process would
> help making sure we are on the same page about what is a releasable state
> for this artifact.
>
> WDYT?
>
> Thank you~
>
> Xintong Song
>
>
> [1] https://cwiki.apache.org/confluence/display/FLINK/Releasing
>
> On Mon, Mar 14, 2022 at 11:34 AM Biao Geng  wrote:
>
> > Hi there,
> >
> > It is exciting to see the discussion of the release timeline! I agree
> that
> > the end of March is a proper date.
> > To make others easier get involved in this discussion, I think we may
> need
> > to provide a more straightforward feature list for the preview release.
> The
> > "Initial Feature Set" in FLIP-212
> > <
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-212:+Introduce+Flink+Kubernetes+Operator
> > >
> > is
> > almost complete. But some new features like webhook based validate and
> > flink operator metric are not added and they are only tracked in the long
> > JIRA list. If we can update the FLIP, it may be more convenient and can
> > also help us write release notes later. I also created a draft
> > <
> >
> https://github.com/bgeng777/flink-kubernetes-operator/blob/features/doc/features.md
> > >
> > for myself to track completed or in-plan features. Hope it can help.
> >
> > Best,
> > Biao Geng
> >
> > Gyula Fóra  于2022年3月14日周一 04:11写道：
> >
> > > @Konstantin: Yes I completely agree that for this release the API (CRD)
> > > should be marked experimental!
> > > I have opened a ticket to track this:
> > > https://issues.apache.org/jira/browse/FLINK-26620
> > >
> > > @Yang Wang  : I think we still have plenty of
> > time
> > > to work on features like the session job before the release, would be
> > nice
> > > to provide a complete story to the users.
> > >
> > > Gyula
> > >
> > > On Sun, Mar 13, 2022 at 5:17 PM Konstantin Knauf 
> > > wrote:
> > >
> > > > Hi everyone,
> > > >
> > > > can we mark all the APIs as experimental/alpha so 

Re: Flink 1.15 Stabilisation Sync skipped tomorrow

[Johannes Moser]

Hi Gabor,

We will cut the branch today.

Best,
Joe

> On 11.03.2022, at 13:19, Gabor Somogyi  wrote:
> 
> Any news on the branch cut? The listed jira-s are closed as I see.
> 
> G
> 
> 
> On Tue, Mar 8, 2022 at 3:02 PM Galen Warren  wrote:
> 
>> You're welcome. Fwiw, I've also run through testing steps on my
>> contribution -- [FLINK-26451] Test GCS FileSystem w/ RecoverableWriter
>> manually - ASF JIRA (apache.org)
>>  -- but I don't think
>> I'm supposed to be officially doing manually testing on my own stuff.
>> 
>> On Tue, Mar 8, 2022 at 3:46 AM Johannes Moser  wrote:
>> 
>>> Thanks so much Gabor and Galen.
>>> 
>>> Very much appreciated.
>>> 
 On 07.03.2022, at 19:00, Galen Warren  wrote:
 
 I just ran through the testing steps on [FLINK-26462] Release Testing:
 Running Python UDF in different Execution Mode - ASF JIRA (apache.org)
 .
 
 Everything worked but I think there might be a typo in the steps to set
>>> up
 the tests, I left a comment on the issue.
 
 On Mon, Mar 7, 2022 at 12:01 PM Gabor Somogyi <
>> gabor.g.somo...@gmail.com
 
 wrote:
 
> Since I know this area I help to test FLINK-26468
> .
> 
> G
> 
> On Mon, Mar 7, 2022 at 5:15 PM Johannes Moser 
>>> wrote:
> 
>> Hello,
>> 
>> We will skip tomorrows weekly stabilisation sync.
>> It looks like all blockers are assigned and worked on. A significant
>> number of contributors are on holiday tomorrow.
>> 
>> Currently we plan to cut off the 1.15 branch on Wednesday of Thursday
> this
>> week.
>> 
>> In case you want to contribute something to the release there are
>> some
>> features to perform manual tests:
>> * https://issues.apache.org/jira/browse/FLINK-26451 <
>> https://issues.apache.org/jira/browse/FLINK-26451>
>> * https://issues.apache.org/jira/browse/FLINK-26462 <
>> https://issues.apache.org/jira/browse/FLINK-26462>
>> * https://issues.apache.org/jira/browse/FLINK-26468 <
>> https://issues.apache.org/jira/browse/FLINK-26468>
>> 
>> 
>> Best, Yun Gao and Joe
> 
>>> 
>>> 
>> 

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Johannes Moser]

Congrats Yuan.

> On 14.03.2022, at 09:45, Arvid Heise  wrote:
> 
> Congratulations and well deserved!
> 
> On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl  wrote:
> 
>> Congratulations, Yuan.
>> 
>> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng  wrote:
>> 
>>> Congratulations, Yuan!
>>> 
>>> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov 
>>> wrote:
>>> 
 Congratulations, Yuan!
 
 --
 
 Best regards,
 Anton Kalashnikov
 
 14.03.2022 09:13, Leonard Xu пишет:
> Congratulations Yuan!
> 
> Best,
> Leonard
> 
>> 2022年3月14日 下午4:09，Yangze Guo  写道：
>> 
>> Congratulations!
>> 
>> Best,
>> Yangze Guo
>> 
>> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
 martijnvis...@apache.org> wrote:
>>> Congratulations Yuan!
>>> 
>>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
>>> 
 Hi all!
 
 I'm very happy to announce that Yuan Mei has joined the Flink PMC!
 
 Yuan is helping the community a lot with creating and validating
 releases,
 contributing to FLIP discussions and good code contributions to
>> the
 state backend and related components.
 
 Congratulations and welcome, Yuan!
 
 Best Regards,
 Yu (On behalf of the Apache Flink PMC)
 
 --
 
 Best regards,
 Anton Kalashnikov
 
 
>> 

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Arvid Heise]

Congratulations and well deserved!

On Mon, Mar 14, 2022 at 9:30 AM Matthias Pohl  wrote:

> Congratulations, Yuan.
>
> On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng  wrote:
>
> > Congratulations, Yuan!
> >
> > On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov 
> > wrote:
> >
> > > Congratulations, Yuan!
> > >
> > > --
> > >
> > > Best regards,
> > > Anton Kalashnikov
> > >
> > > 14.03.2022 09:13, Leonard Xu пишет:
> > > > Congratulations Yuan!
> > > >
> > > > Best,
> > > > Leonard
> > > >
> > > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > > >>
> > > >> Congratulations!
> > > >>
> > > >> Best,
> > > >> Yangze Guo
> > > >>
> > > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > > martijnvis...@apache.org> wrote:
> > > >>> Congratulations Yuan!
> > > >>>
> > > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
> > > >>>
> > >  Hi all!
> > > 
> > >  I'm very happy to announce that Yuan Mei has joined the Flink PMC!
> > > 
> > >  Yuan is helping the community a lot with creating and validating
> > > releases,
> > >  contributing to FLIP discussions and good code contributions to
> the
> > >  state backend and related components.
> > > 
> > >  Congratulations and welcome, Yuan!
> > > 
> > >  Best Regards,
> > >  Yu (On behalf of the Apache Flink PMC)
> > > 
> > > --
> > >
> > > Best regards,
> > > Anton Kalashnikov
> > >
> > >
>

[jira] [Created] (FLINK-26629) Error in code comment for SubtaskStateMapper.RANGE

[Shubin Ruan (Jira)]

Shubin Ruan created FLINK-26629:
---

 Summary: Error in code comment for SubtaskStateMapper.RANGE
 Key: FLINK-26629
 URL: https://issues.apache.org/jira/browse/FLINK-26629
 Project: Flink
  Issue Type: Bug
  Components: Runtime / Network
Affects Versions: 1.15.0
Reporter: Shubin Ruan


The code comments for SubtaskStateMapper.RANGE are as follows:
{code:java}
 * Example:
 * old assignment: 0 -> [0;43); 1 -> [43;87); 2 -> [87;128)
 * new assignment: 0 -> [0;64]; 1 -> [64;128)
 * subtask 0 recovers data from old subtask 0 + 1 and subtask 1 recovers data 
from old subtask 0
 * + 2{code}
The correct code comment should be：

 
{code:java}
 * Example:
 * old assignment: 0 -> [0;43); 1 -> [43;87); 2 -> [87;128)
 * new assignment: 0 -> [0;64]; 1 -> [64;128)
 * subtask 0 recovers data from old subtask 0 + 1 and subtask 1 recovers data 
from old subtask 1
 * + 2{code}
*subtask 1 should recovers data from old subtask 1 + 2，not from old subtask 0 + 
2*

 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Created] (FLINK-26628) Use REST program arguments in StatefulFunctionsJob

[Fil Karnicki (Jira)]

Fil Karnicki created FLINK-26628:


 Summary: Use REST program arguments in StatefulFunctionsJob
 Key: FLINK-26628
 URL: https://issues.apache.org/jira/browse/FLINK-26628
 Project: Flink
  Issue Type: Improvement
  Components: Stateful Functions
Reporter: Fil Karnicki


Currently the Program Arguments passed into the REST api don't get used by 
StreamingExecutionEnvironment in StatefulFunctionsJob (in this case the 
checkpointing will not be set)
{code:java}
--execution.checkpointing.interval 1000 --state.backend rocksdb 
--state.checkpoint-storage filesystem --state.checkpoints.dir file:///tmp/ 
--statefun.embedded true {code}
Conversely, Flink CLI params *do* get used by the StreamingExecutionEnvironment 
in statefun jobs
{code:java}
flink run -Dexecution.checkpointing.interval=1000 -Dstate.backend=rocksdb 
-Dstate.checkpoint-storage=filesystem -Dstate.checkpoints.dir=file:///tmp/ 
-Dstatefun.embedded=true myjar.jar{code}
 

To reproduce,
 # clone and run mvn package on 
[https://github.com/FilKarnicki/statefun-flinkjob/tree/argsNotUsedViaRest]
 # run docker-compose up in flinkjob/docker-compose
 # observe checkpointing happening for this job
 # go to [http://localhost:8081/#/submit] and submit flinkjob-1.0-SNAPSHOT.jar 
again manually from target with program arguments

{code:java}
 --execution.checkpointing.interval 1000 --state.backend rocksdb 
--state.checkpoint-storage filesystem --state.checkpoints.dir file:///tmp/ 
--statefun.embedded true   {code}
    5. observe no checkpointing happening for the second job



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Re: [ANNOUNCE] New Apache Flink Committer - David Morávek

[Anton Kalashnikov]

Congratulations, David!

--

Best regards,
Anton Kalashnikov

14.03.2022 09:18, Matthias Pohl пишет:

Congratulations, David!

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Shuo Cheng]

Congratulations, Yuan!

On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov 
wrote:

> Congratulations, Yuan!
>
> --
>
> Best regards,
> Anton Kalashnikov
>
> 14.03.2022 09:13, Leonard Xu пишет:
> > Congratulations Yuan!
> >
> > Best,
> > Leonard
> >
> >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> >>
> >> Congratulations!
> >>
> >> Best,
> >> Yangze Guo
> >>
> >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> martijnvis...@apache.org> wrote:
> >>> Congratulations Yuan!
> >>>
> >>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
> >>>
>  Hi all!
> 
>  I'm very happy to announce that Yuan Mei has joined the Flink PMC!
> 
>  Yuan is helping the community a lot with creating and validating
> releases,
>  contributing to FLIP discussions and good code contributions to the
>  state backend and related components.
> 
>  Congratulations and welcome, Yuan!
> 
>  Best Regards,
>  Yu (On behalf of the Apache Flink PMC)
> 
> --
>
> Best regards,
> Anton Kalashnikov
>
>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Matthias Pohl]

Congratulations, Yuan.

On Mon, Mar 14, 2022 at 9:25 AM Shuo Cheng  wrote:

> Congratulations, Yuan!
>
> On Mon, Mar 14, 2022 at 4:22 PM Anton Kalashnikov 
> wrote:
>
> > Congratulations, Yuan!
> >
> > --
> >
> > Best regards,
> > Anton Kalashnikov
> >
> > 14.03.2022 09:13, Leonard Xu пишет:
> > > Congratulations Yuan!
> > >
> > > Best,
> > > Leonard
> > >
> > >> 2022年3月14日 下午4:09，Yangze Guo  写道：
> > >>
> > >> Congratulations!
> > >>
> > >> Best,
> > >> Yangze Guo
> > >>
> > >> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser <
> > martijnvis...@apache.org> wrote:
> > >>> Congratulations Yuan!
> > >>>
> > >>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
> > >>>
> >  Hi all!
> > 
> >  I'm very happy to announce that Yuan Mei has joined the Flink PMC!
> > 
> >  Yuan is helping the community a lot with creating and validating
> > releases,
> >  contributing to FLIP discussions and good code contributions to the
> >  state backend and related components.
> > 
> >  Congratulations and welcome, Yuan!
> > 
> >  Best Regards,
> >  Yu (On behalf of the Apache Flink PMC)
> > 
> > --
> >
> > Best regards,
> > Anton Kalashnikov
> >
> >

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

[Matthias Pohl]

Congratulations, Martijn

On Mon, Mar 14, 2022 at 9:17 AM Anton Kalashnikov 
wrote:

> Congrats, Martijn!
>
> --
>
> Best regards,
> Anton Kalashnikov
>
> 13.03.2022 01:57, Guowei Ma пишет:
> > Congrats Martijn!
> > Best,
> > Guowei
> >
> >
> > On Fri, Mar 11, 2022 at 10:36 PM Marios Trivyzas 
> wrote:
> >
> >> Congrats Martijn!!
> >>
> >> Best,
> >> Marios
> >>
> >> On Thu, Mar 10, 2022 at 4:50 PM yu'an huang 
> wrote:
> >>
> >>> Congrats, Martijn!
> >>>
> >>>
> >>> Best
> >>> Yuan
> >>>
> >>>
>  On 3 Mar 2022, at 11:49 PM, Robert Metzger 
> >> wrote:
>  Hi everyone,
> 
>  On behalf of the PMC, I'm very happy to announce Martijn Visser as a
> >> new
>  Flink committer.
> 
>  Martijn is a very active Flink community member, driving a lot of
> >> efforts
>  on the dev@flink mailing list. He also pushes projects such as
> >> replacing
>  Google Analytics with Matomo, so that we can generate our web
> analytics
>  within the Apache Software Foundation.
> 
>  Please join me in congratulating Martijn for becoming a Flink
> >> committer!
>  Cheers,
>  Robert
> >>>
> >> --
> >> Marios
> >>

Re: [ANNOUNCE] New PMC member: Yuan Mei

[javaca...@163.com]

Congratulations, Yuan!

--

Best Regards
Yu



javaca...@163.com
 
From: Yu Li
Date: 2022-03-14 16:02
To: dev; yuanmei
Subject: [ANNOUNCE] New PMC member: Yuan Mei
Hi all!
 
I'm very happy to announce that Yuan Mei has joined the Flink PMC!
 
Yuan is helping the community a lot with creating and validating releases,
contributing to FLIP discussions and good code contributions to the
state backend and related components.
 
Congratulations and welcome, Yuan!
 
Best Regards,
Yu (On behalf of the Apache Flink PMC)

Re: [ANNOUNCE] New Apache Flink Committer - David Morávek

[Matthias Pohl]

Congratulations, David!

On Thu, Mar 10, 2022 at 3:48 PM yu'an huang  wrote:

> Congratulations, David!
>
> Best
> Yuan
>
>
>
>
> > On 9 Mar 2022, at 2:42 PM, Jiangang Liu 
> wrote:
> >
> > Congratulations, David.
> >
> > Best
> > Liu Jiangang
> >
> > Yu Li  于2022年3月9日周三 14:23写道：
> >
> >> Congrats, David!
> >>
> >> Best Regards,
> >> Yu
> >>
> >>
> >> On Tue, 8 Mar 2022 at 16:11, Johannes Moser  wrote:
> >>
> >>> Very well deserved.
> >>>
>  On 08.03.2022, at 05:43, Lincoln Lee  wrote:
> 
>  Congratulations David!
> 
>  Best,
>  Lincoln Lee
> 
> 
>  Yun Gao  于2022年3月8日周二 11:24写道：
> 
> > Congratulations David!
> >
> > Best,
> > Yun Gao
> >
> >
> > --
> > From:Jing Zhang 
> > Send Time:2022 Mar. 8 (Tue.) 11:10
> > To:dev 
> > Subject:Re: [ANNOUNCE] New Apache Flink Committer - David Morávek
> >
> > Congratulations David!
> >
> > Ryan Skraba  于2022年3月7日周一 22:18写道：
> >
> >> Congratulations David!
> >>
> >> On Mon, Mar 7, 2022 at 9:54 AM Jan Lukavský 
> wrote:
> >>
> >>> Congratulations David!
> >>>
> >>> Jan
> >>>
> >>> On 3/7/22 09:44, Etienne Chauchot wrote:
>  Congrats David !
> 
>  Well deserved !
> 
>  Etienne
> 
>  Le 07/03/2022 à 08:47, David Morávek a écrit :
> > Thanks everyone!
> >
> > Best,
> > D.
> >
> > On Sun 6. 3. 2022 at 9:07, Yuan Mei 
> >> wrote:
> >
> >> Congratulations, David!
> >>
> >> Best Regards,
> >> Yuan
> >>
> >> On Sat, Mar 5, 2022 at 8:13 PM Roman Khachatryan <
> >> ro...@apache.org
> >>
> >> wrote:
> >>
> >>> Congratulations, David!
> >>>
> >>> Regards,
> >>> Roman
> >>>
> >>> On Fri, Mar 4, 2022 at 7:54 PM Austin Cawley-Edwards
> >>>  wrote:
>  Congrats David!
> 
>  On Fri, Mar 4, 2022 at 12:18 PM Zhilong Hong <
> > zhlongh...@gmail.com
> >>>
> >>> wrote:
> > Congratulations, David!
> >
> > Best,
> > Zhilong
> >
> > On Sat, Mar 5, 2022 at 1:09 AM Piotr Nowojski <
> >> pnowoj...@apache.org
> 
> > wrote:
> >
> >> Congratulations :)
> >>
> >> pt., 4 mar 2022 o 16:04 Aitozi 
> >> napisał(a):
> >>
> >>> Congratulations David!
> >>>
> >>> Ingo Bürk  于2022年3月4日周五 22:56写道：
> >>>
>  Congrats, David!
> 
>  On 04.03.22 12:34, Robert Metzger wrote:
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy to announce David
> >> Morávek
> >>> as a
> >> new
> > Flink committer.
> >
> > His first contributions to Flink date back to 2019. He
> has
> >> been
> > increasingly active with reviews and driving major
> >> initiatives
> >>> in
> > the
> > community. David brings valuable experience from being a
> >>> committer
> > in
> >>> the
> > Apache Beam project to Flink.
> >
> >
> > Please join me in congratulating David for becoming a
> >> Flink
> >> committer!
> > Cheers,
> > Robert
> >
> >>>
> >>
> >
> >>>
> >>>
> >>
>

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

[Anton Kalashnikov]

Congrats, Martijn!

--

Best regards,
Anton Kalashnikov

13.03.2022 01:57, Guowei Ma пишет:

Congrats Martijn!
Best,
Guowei


On Fri, Mar 11, 2022 at 10:36 PM Marios Trivyzas  wrote:


Congrats Martijn!!

Best,
Marios

On Thu, Mar 10, 2022 at 4:50 PM yu'an huang  wrote:


Congrats, Martijn!


Best
Yuan



On 3 Mar 2022, at 11:49 PM, Robert Metzger 

wrote:

Hi everyone,

On behalf of the PMC, I'm very happy to announce Martijn Visser as a

new

Flink committer.

Martijn is a very active Flink community member, driving a lot of

efforts

on the dev@flink mailing list. He also pushes projects such as

replacing

Google Analytics with Matomo, so that we can generate our web analytics
within the Apache Software Foundation.

Please join me in congratulating Martijn for becoming a Flink

committer!

Cheers,
Robert



--
Marios

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Anton Kalashnikov]

Congratulations, Yuan!

--

Best regards,
Anton Kalashnikov

14.03.2022 09:13, Leonard Xu пишет:

Congratulations Yuan!

Best,
Leonard


2022年3月14日 下午4:09，Yangze Guo  写道：

Congratulations!

Best,
Yangze Guo

On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser  wrote:

Congratulations Yuan!

On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:


Hi all!

I'm very happy to announce that Yuan Mei has joined the Flink PMC!

Yuan is helping the community a lot with creating and validating releases,
contributing to FLIP discussions and good code contributions to the
state backend and related components.

Congratulations and welcome, Yuan!

Best Regards,
Yu (On behalf of the Apache Flink PMC)


--

Best regards,
Anton Kalashnikov

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Leonard Xu]

Congratulations Yuan!

Best,
Leonard

> 2022年3月14日 下午4:09，Yangze Guo  写道：
> 
> Congratulations!
> 
> Best,
> Yangze Guo
> 
> On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser  
> wrote:
>> 
>> Congratulations Yuan!
>> 
>> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
>> 
>>> Hi all!
>>> 
>>> I'm very happy to announce that Yuan Mei has joined the Flink PMC!
>>> 
>>> Yuan is helping the community a lot with creating and validating releases,
>>> contributing to FLIP discussions and good code contributions to the
>>> state backend and related components.
>>> 
>>> Congratulations and welcome, Yuan!
>>> 
>>> Best Regards,
>>> Yu (On behalf of the Apache Flink PMC)
>>> 

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Yangze Guo]

Congratulations!

Best,
Yangze Guo

On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser  wrote:
>
> Congratulations Yuan!
>
> On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:
>
> > Hi all!
> >
> > I'm very happy to announce that Yuan Mei has joined the Flink PMC!
> >
> > Yuan is helping the community a lot with creating and validating releases,
> > contributing to FLIP discussions and good code contributions to the
> > state backend and related components.
> >
> > Congratulations and welcome, Yuan!
> >
> > Best Regards,
> > Yu (On behalf of the Apache Flink PMC)
> >

Re: [ANNOUNCE] New PMC member: Yuan Mei

[Martijn Visser]

Congratulations Yuan!

On Mon, 14 Mar 2022 at 09:02, Yu Li  wrote:

> Hi all!
>
> I'm very happy to announce that Yuan Mei has joined the Flink PMC!
>
> Yuan is helping the community a lot with creating and validating releases,
> contributing to FLIP discussions and good code contributions to the
> state backend and related components.
>
> Congratulations and welcome, Yuan!
>
> Best Regards,
> Yu (On behalf of the Apache Flink PMC)
>

[ANNOUNCE] New PMC member: Yuan Mei

[Yu Li]

Hi all!

I'm very happy to announce that Yuan Mei has joined the Flink PMC!

Yuan is helping the community a lot with creating and validating releases,
contributing to FLIP discussions and good code contributions to the
state backend and related components.

Congratulations and welcome, Yuan!

Best Regards,
Yu (On behalf of the Apache Flink PMC)

Re: [DISCUSS] Preview release for Flink Kubernetes Operator

[Xintong Song]

How everyone,

It's great to learn that we are approaching a preview release for
the flink-kubernetes-operator. Thanks for the efforts.

I have not been involved with any developing efforts in
flink-kubernetes-operator, thus have no comment on end of March being the
targeting date.

However, based on my experiences being one of the Flink release managers, I
see a few things that are still missing for creating an official release.
(IIUC, the preview release is still an official release, just with weak
functionality and compatibility guarantees.)

1. The version conventions:
- How does a flink-kubernetes-operator version look like? E.g., flink /
flink-statefun / flink-ml have three digits x.y.z, while flink-shaded has
only two digits x.y.
- What is the relationship between flink-kubernetes-operator and flink
versions? E.g., flink-shaded x.* is only designed to support flink *.x.*.
- What kind of compatibility guarantees do we provide? E.g., flink expects
no Public API compatibility should be broken between minor releases (the
2nd digit) and no PublicEvolving APIs should be broken between bugfix
releases (the 3rd digit).
- What kind of support do we provide for old releases? E.g., flink provides
bug fixes for the latest two minor releases (the 2nd digit).

2. Release process
You may find the release process for all Flink artifacts in this wiki page
[1]. Such a formal documented process would help us to reach consensus on
what needs to be done and make sure it complies with the ASF regulations
before creating a release. We probably don't need something as formal as a
vote to approve the release process. But we definitely need a formal vote
for the flink-kubernetes-operator release, and the release process would
help making sure we are on the same page about what is a releasable state
for this artifact.

WDYT?

Thank you~

Xintong Song


[1] https://cwiki.apache.org/confluence/display/FLINK/Releasing

On Mon, Mar 14, 2022 at 11:34 AM Biao Geng  wrote:

> Hi there,
>
> It is exciting to see the discussion of the release timeline! I agree that
> the end of March is a proper date.
> To make others easier get involved in this discussion, I think we may need
> to provide a more straightforward feature list for the preview release. The
> "Initial Feature Set" in FLIP-212
> <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-212:+Introduce+Flink+Kubernetes+Operator
> >
> is
> almost complete. But some new features like webhook based validate and
> flink operator metric are not added and they are only tracked in the long
> JIRA list. If we can update the FLIP, it may be more convenient and can
> also help us write release notes later. I also created a draft
> <
> https://github.com/bgeng777/flink-kubernetes-operator/blob/features/doc/features.md
> >
> for myself to track completed or in-plan features. Hope it can help.
>
> Best,
> Biao Geng
>
> Gyula Fóra  于2022年3月14日周一 04:11写道：
>
> > @Konstantin: Yes I completely agree that for this release the API (CRD)
> > should be marked experimental!
> > I have opened a ticket to track this:
> > https://issues.apache.org/jira/browse/FLINK-26620
> >
> > @Yang Wang  : I think we still have plenty of
> time
> > to work on features like the session job before the release, would be
> nice
> > to provide a complete story to the users.
> >
> > Gyula
> >
> > On Sun, Mar 13, 2022 at 5:17 PM Konstantin Knauf 
> > wrote:
> >
> > > Hi everyone,
> > >
> > > can we mark all the APIs as experimental/alpha so that it is clear that
> > > these can be broken in future releases for now? I think this would be
> > very
> > > important given the early stage of the project. We want to be able to
> > > address shortcomings without worrying too much about backwards
> > > compatibility at this stage, I believe.
> > >
> > > Cheers,
> > >
> > > Konstantin
> > >
> > > On Sun, Mar 13, 2022 at 7:48 AM Yang Wang 
> wrote:
> > >
> > > > Thanks Gyula for starting this discussion.
> > > >
> > > > Given that the core functionality is closing to stable, I am in favor
> > of
> > > > having the MVP release at the end of March.
> > > > The first release will help us to collect more feedbacks from the
> > users.
> > > > Also it is a good chance to let the users know that the community is
> > > trying
> > > > to maintain an official Kubernetes operator :)
> > > > I hope that the companies could build their own production streaming
> > > > platform on top of the flink-kubernetes-operator in the future.
> > > >
> > > > FYI: @Wenjun Min is still working hard on supporting the Session Job
> in
> > > > Flink Kubernetes operator, It will be great if we could include it in
> > the
> > > > first release.
> > > > And I believe we have enough time.
> > > >
> > > > Moreover, I agree with you that we need to invest more time in the
> > > > documentation, e2e tests, helm install optimization, logging,
> > > > etc. before the release.
> > > >
> > > >
> > > > Best,
> > > > Yang
> > > >
> > > >
> > > > Gyula Fóra  于2022年3月12日周六 

[jira] [Created] (FLINK-26627) Allow user to config the init/max wait time in the ExponentialWaitStrategy of job submission

[Yangze Guo (Jira)]

Yangze Guo created FLINK-26627:
--

 Summary: Allow user to config the init/max wait time in the 
ExponentialWaitStrategy of job submission
 Key: FLINK-26627
 URL: https://issues.apache.org/jira/browse/FLINK-26627
 Project: Flink
  Issue Type: Improvement
  Components: Client / Job Submission
Reporter: Yangze Guo
Assignee: Yangze Guo
 Fix For: 1.16.0


Currently, in the job submission, the `JobClient` is available only when the 
job finishes its initialization. The client applies an exponential strategy 
waiting for it. However, the init/max wait time is arbitrarily set to 50/2000 
ms, which might not make sense for short OLAP queries.

We proposed to make them configurable.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Created] (FLINK-26626) Add Estimator and Transformer of StandardScaler in FlinkML

[Zhipeng Zhang (Jira)]

Zhipeng Zhang created FLINK-26626:
-

 Summary: Add Estimator and Transformer of StandardScaler in FlinkML
 Key: FLINK-26626
 URL: https://issues.apache.org/jira/browse/FLINK-26626
 Project: Flink
  Issue Type: New Feature
  Components: Library / Machine Learning
Reporter: Zhipeng Zhang






--
This message was sent by Atlassian Jira
(v8.20.1#820001)