[jira] [Created] (FLINK-29103) FileNotFoundException: No such file or directory: s3://

[hehetown (Jira)]

hehetown created FLINK-29103:


 Summary: FileNotFoundException: No such file or directory: s3://
 Key: FLINK-29103
 URL: https://issues.apache.org/jira/browse/FLINK-29103
 Project: Flink
  Issue Type: Bug
  Components: Connectors / FileSystem
Affects Versions: 1.15.1
 Environment: docker images: flink 1.15

minio+k8s
Reporter: hehetown
 Fix For: 1.14.4


The following error is reported when the application is released on k8s, but it 
is normal in 1.14.4.

2022-08-25 11:09:40,008 INFO  
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - 
Stopping SessionDispatcherLeaderProcess.
2022-08-25 11:09:40,078 INFO  
org.apache.flink.runtime.jobmanager.DefaultJobGraphStore     [] - Stopping 
DefaultJobGraphStore.
2022-08-25 11:09:40,081 ERROR 
org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Fatal error 
occurred in the cluster entrypoint.
java.util.concurrent.CompletionException: 
org.apache.flink.util.FlinkRuntimeException: Could not retrieve JobResults of 
globally-terminated jobs from JobResultStore
    at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
 ~[?:1.8.0_342]
    at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
 [?:1.8.0_342]
    at 
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606)
 [?:1.8.0_342]
    at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:1.8.0_342]
    at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:1.8.0_342]
    at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
Caused by: org.apache.flink.util.FlinkRuntimeException: Could not retrieve 
JobResults of globally-terminated jobs from JobResultStore
    at 
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess.getDirtyJobResults(SessionDispatcherLeaderProcess.java:192)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.supplyUnsynchronizedIfRunning(AbstractDispatcherLeaderProcess.java:198)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess.getDirtyJobResultsIfRunning(SessionDispatcherLeaderProcess.java:184)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
 ~[?:1.8.0_342]
    ... 3 more
Caused by: java.io.FileNotFoundException: No such file or directory: 
s3://flink/ods/rdemo/recovery/job-result-store/ods-cs-192
    at 
org.apache.hadoop.fs.s3a.S3AFileSystem.s3GetFileStatus(S3AFileSystem.java:2344) 
~[?:?]
    at 
org.apache.hadoop.fs.s3a.S3AFileSystem.innerGetFileStatus(S3AFileSystem.java:2226)
 ~[?:?]
    at 
org.apache.hadoop.fs.s3a.S3AFileSystem.getFileStatus(S3AFileSystem.java:2160) 
~[?:?]
    at 
org.apache.hadoop.fs.s3a.S3AFileSystem.innerListStatus(S3AFileSystem.java:1961) 
~[?:?]
    at 
org.apache.hadoop.fs.s3a.S3AFileSystem.lambda$listStatus$9(S3AFileSystem.java:1940)
 ~[?:?]
    at org.apache.hadoop.fs.s3a.Invoker.once(Invoker.java:109) ~[?:?]
    at 
org.apache.hadoop.fs.s3a.S3AFileSystem.listStatus(S3AFileSystem.java:1940) 
~[?:?]
    at 
org.apache.flink.fs.s3hadoop.common.HadoopFileSystem.listStatus(HadoopFileSystem.java:170)
 ~[?:?]
    at 
org.apache.flink.core.fs.PluginFileSystemFactory$ClassLoaderFixingFileSystem.listStatus(PluginFileSystemFactory.java:141)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
org.apache.flink.runtime.highavailability.FileSystemJobResultStore.getDirtyResultsInternal(FileSystemJobResultStore.java:179)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
org.apache.flink.runtime.highavailability.AbstractThreadsafeJobResultStore.withReadLock(AbstractThreadsafeJobResultStore.java:118)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
org.apache.flink.runtime.highavailability.AbstractThreadsafeJobResultStore.getDirtyResults(AbstractThreadsafeJobResultStore.java:100)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess.getDirtyJobResults(SessionDispatcherLeaderProcess.java:190)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess.supplyUnsynchronizedIfRunning(AbstractDispatcherLeaderProcess.java:198)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess.getDirtyJobResultsIfRunning(SessionDispatcherLeaderProcess.java:184)
 ~[flink-dist-1.15.1.jar:1.15.1]
    at 
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
 ~[?:1.8.0_342]
    ... 3 more
2022-08-25 11:09:40,180 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: high-availability.cluster-id, 



--
This message was 

Re: [VOTE] Apache Flink Table Store 0.2.0, release candidate #3

[Yu Li]

+1 (binding)

- Checked release notes: *OK*
- Checked sums and signatures: *OK*
- Checked the jars in the staging repo: *OK*
- Checked source distribution doesn't include binaries: *OK*
- Maven clean install from source: *OK*
- Checked version consistency in pom files: *OK*
- Went through the quick start: *OK*
  * Verified with both flink 1.14.5 and 1.15.1
- Checked the website updates: *OK*

Thanks all for the efforts!

Best Regards,
Yu


On Wed, 24 Aug 2022 at 19:24, Nicholas Jiang 
wrote:

> Hi all!
>
> +1 for the release (non-binding). I've verified the jar with SQL client
> and listed the check items as follows:
>
> * Compiled the sources and built the source distribution - PASSED
> * Ran through Quick Start Guide - PASSED
> * Checked Spark 2.3.4&3.3.0 reader and catalog with table store jar -
> PASSED
> * Checked all NOTICE files - PASSED
> * Checked the website updates - PASSED
>
> Regards,
> Nicholas Jiang
>
> On 2022/08/24 07:46:00 Jingsong Li wrote:
> > Hi everyone,
> >
> > Please review and vote on the release candidate #3 for the version 0.2.0
> of
> > Apache Flink Table Store, as follows:
> >
> > [ ] +1, Approve the release
> > [ ] -1, Do not approve the release (please provide specific comments)
> >
> > **Release Overview**
> >
> > As an overview, the release consists of the following:
> > a) Table Store canonical source distribution to be deployed to the
> > release repository at dist.apache.org
> > b) Table Store binary convenience releases to be deployed to the
> > release repository at dist.apache.org
> > c) Maven artifacts to be deployed to the Maven Central Repository
> >
> > **Staging Areas to Review**
> >
> > The staging areas containing the above mentioned artifacts are as
> follows,
> > for your review:
> > * All artifacts for a) and b) can be found in the corresponding dev
> > repository at dist.apache.org [2]
> > * All artifacts for c) can be found at the Apache Nexus Repository [3]
> >
> > All artifacts are signed with the key
> > 2C2B6A653B07086B65E4369F7C76245E0A318150 [4]
> >
> > Other links for your review:
> > * JIRA release notes [5]
> > * source code tag "release-0.2.0-rc3" [6]
> > * PR to update the website Downloads page to include Table Store links
> [7]
> >
> > **Vote Duration**
> >
> > The voting time will run for at least 72 hours.
> > It is adopted by majority approval, with at least 3 PMC affirmative
> votes.
> >
> > Best,
> > Jingsong Lee
> >
> > [1]
> https://cwiki.apache.org/confluence/display/FLINK/Verifying+a+Flink+Table+Store+Release
> > [2]
> https://dist.apache.org/repos/dist/dev/flink/flink-table-store-0.2.0-rc3/
> > [3]
> https://repository.apache.org/content/repositories/orgapacheflink-1526/
> > [4] https://dist.apache.org/repos/dist/release/flink/KEYS
> > [5]
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351570
> > [6] https://github.com/apache/flink-table-store/tree/release-0.2.0-rc3
> > [7] https://github.com/apache/flink-web/pull/562
> >
>

Re: [ANNOUNCE] Apache Flink 1.15.2 released

[Xingbo Huang]

Thanks Danny for driving this release

Best,
Xingbo

Jing Ge  于2022年8月25日周四 05:50写道：

> Thanks Danny for your effort!
>
> Best regards,
> Jing
>
> On Wed, Aug 24, 2022 at 11:43 PM Danny Cranmer 
> wrote:
>
>> The Apache Flink community is very happy to announce the release of
>> Apache Flink 1.15.2, which is the second bugfix release for the Apache
>> Flink 1.15 series.
>>
>> Apache Flink® is an open-source stream processing framework for
>> distributed, high-performing, always-available, and accurate data streaming
>> applications.
>>
>> The release is available for download at:
>> https://flink.apache.org/downloads.html
>>
>> Please check out the release blog post for an overview of the
>> improvements for this bugfix release:
>> https://flink.apache.org/news/2022/08/25/release-1.15.2.html
>>
>> The full release notes are available in Jira:
>>
>> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351829
>>
>> We would like to thank all contributors of the Apache Flink community who
>> made this release possible!
>>
>> Regards,
>> Danny Cranmer
>>
>

[jira] [Created] (FLINK-29102) ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError

[Xingbo Huang (Jira)]

Xingbo Huang created FLINK-29102:


 Summary: ChangelogLocalRecoveryITCase.testRestartTM failed with 
AssertionFailedError
 Key: FLINK-29102
 URL: https://issues.apache.org/jira/browse/FLINK-29102
 Project: Flink
  Issue Type: Bug
  Components: Runtime / State Backends
Affects Versions: 1.16.0
Reporter: Xingbo Huang
 Fix For: 1.16.0


{code:java}
2022-08-25T02:10:19.1407131Z Aug 25 02:10:19 [ERROR] Tests run: 3, Failures: 1, 
Errors: 0, Skipped: 0, Time elapsed: 20.126 s <<< FAILURE! - in 
org.apache.flink.test.checkpointing.ChangelogLocalRecoveryITCase
2022-08-25T02:10:19.1410088Z Aug 25 02:10:19 [ERROR] 
ChangelogLocalRecoveryITCase.testRestartTM  Time elapsed: 12.501 s  <<< FAILURE!
2022-08-25T02:10:19.1411734Z Aug 25 02:10:19 
org.opentest4j.AssertionFailedError: Graph is in globally terminal state 
(FAILED)
2022-08-25T02:10:19.1413028Z Aug 25 02:10:19at 
org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:43)
2022-08-25T02:10:19.1414753Z Aug 25 02:10:19at 
org.junit.jupiter.api.Assertions.fail(Assertions.java:146)
2022-08-25T02:10:19.1416077Z Aug 25 02:10:19at 
org.apache.flink.runtime.testutils.CommonTestUtils.lambda$waitForAllTaskRunning$3(CommonTestUtils.java:213)
2022-08-25T02:10:19.1417807Z Aug 25 02:10:19at 
org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:150)
2022-08-25T02:10:19.1419455Z Aug 25 02:10:19at 
org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:144)
2022-08-25T02:10:19.1421184Z Aug 25 02:10:19at 
org.apache.flink.runtime.testutils.CommonTestUtils.waitForAllTaskRunning(CommonTestUtils.java:208)
2022-08-25T02:10:19.1422893Z Aug 25 02:10:19at 
org.apache.flink.test.checkpointing.ChangelogLocalRecoveryITCase.testRestartTM(ChangelogLocalRecoveryITCase.java:149)
2022-08-25T02:10:19.1424381Z Aug 25 02:10:19at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-08-25T02:10:19.1425730Z Aug 25 02:10:19at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-08-25T02:10:19.1427428Z Aug 25 02:10:19at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-08-25T02:10:19.1428842Z Aug 25 02:10:19at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-08-25T02:10:19.1430173Z Aug 25 02:10:19at 
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2022-08-25T02:10:19.1431683Z Aug 25 02:10:19at 
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2022-08-25T02:10:19.1433150Z Aug 25 02:10:19at 
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2022-08-25T02:10:19.1434760Z Aug 25 02:10:19at 
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2022-08-25T02:10:19.1436296Z Aug 25 02:10:19at 
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2022-08-25T02:10:19.1437704Z Aug 25 02:10:19at 
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2022-08-25T02:10:19.1439268Z Aug 25 02:10:19at 
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2022-08-25T02:10:19.1441412Z Aug 25 02:10:19at 
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
2022-08-25T02:10:19.1442792Z Aug 25 02:10:19at 
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-08-25T02:10:19.1444190Z Aug 25 02:10:19at 
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
2022-08-25T02:10:19.1445593Z Aug 25 02:10:19at 
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
2022-08-25T02:10:19.1446946Z Aug 25 02:10:19at 
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
2022-08-25T02:10:19.1448568Z Aug 25 02:10:19at 
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
2022-08-25T02:10:19.1449909Z Aug 25 02:10:19at 
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-08-25T02:10:19.1451376Z Aug 25 02:10:19at 
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-08-25T02:10:19.1452655Z Aug 25 02:10:19at 
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-08-25T02:10:19.1454003Z Aug 25 02:10:19at 
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-08-25T02:10:19.1455239Z Aug 25 02:10:19at 
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-08-25T02:10:19.1456511Z Aug 25 02:10:19at 
org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-08-25T02:10:19.1458149Z Aug 25 02:10:19at 
org.junit.runners.Suite.runChild(Suite.java:128)
2022-08-25T02:10:19.1460189Z Aug 25 02:10:19at 

[jira] [Created] (FLINK-29101) PipelinedRegionSchedulingStrategy benchmark shows performance degradation

[Weijie Guo (Jira)]

Weijie Guo created FLINK-29101:
--

 Summary: PipelinedRegionSchedulingStrategy benchmark shows 
performance degradation
 Key: FLINK-29101
 URL: https://issues.apache.org/jira/browse/FLINK-29101
 Project: Flink
  Issue Type: Bug
  Components: Runtime / Coordination
Affects Versions: 1.16.0
Reporter: Weijie Guo
 Fix For: 1.16.0


Throw TPC-DS and flink-benchmark testing, we found that 
PipelinedRegionSchedulingStrategy has performance degradation. By 
investigation, I can confirm that this was introduced by FLINK-28799 which 
introduce HYBRID type edge support for scheduling strategy.

The key to the problem is for blocking ALL_TO_ALL type edges should only enter 
the scheduling method when the last execution becomes finished, but the current 
implementation ignores this fact, resulting in the complexity of O(n ^ 2) in 
this case.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

RE: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

[区启晟]

+1, Lgtm, this proposal may helps me to manage the job more conveniently

On 2022/08/15 10:06:18 zhengyu chen wrote:
> Hi all,
> 
> 
> We would like to start a discussion thread on FLIP-256 Support Job Dynamic
> Parameter With Flink Rest Api
> 
> [1]
> 
> After the user submits the jar package, running a job through restapi
> (/jars/:jarid/run) [2] can only pass in (allowNonRestoredState,
> savepointPath, programArg, entry-class, parallelism) parameters, which is
> obvious with the diversification of job parameters  (eg Checkpoint address)
> 
> This solves the problem that the user can pass in other parameters when
> submitting a job, avoiding the user to define these job parameters in the
> code, resulting in the need to repackage the job for each modification
> 
> There was some interest from users [3] from a meetup and the mailing list.
> Looking forward to comments and feedback, thanks!
> 
> 
> [1]
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-256+Support+Job+Dynamic+Parameter+With+Flink+Rest+Api
> 
> 
> [2]
> https://nightlies.apache.org/flink/flink-docs-master/docs/ops/rest_api/#jars-jarid-run
> 
> [3] https://issues.apache.org/jira/browse/FLINK-27060
> 
> 
> 
> 
> -- 
> Best
> 
> ConradJam
> 

Re: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

[Yu Li]

Congratulations, Junhan!

Best Regards,
Yu


On Thu, 25 Aug 2022 at 10:07, Yun Gao  wrote:

> Congratulations Junhan!
>
>
> Best,
> Yun Gao
>
>
> --
> Sender:Yangze Guo
> Date:2022/08/25 10:04:14
> Recipient:dev
> Cc:
> Theme:Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang
>
> Congrats!
>
> Jark Wu  于 2022年8月24日周三 下午3:46写道：
>
> > Congrats Junhan!
> >
> > Best,
> > Jark
> >
> > On Wed, 24 Aug 2022 at 15:05, Qingsheng Ren  wrote:
> >
> > > Congratulations Junhan!
> > >
> > > Best regards,
> > > Qingsheng
> > >
> > > > On Aug 22, 2022, at 16:30, Yang Wang  wrote:
> > > >
> > > > Congrats Junhan!
> > > >
> > > >
> > > > Best,
> > > > Yang
> > > >
> > > > Matthias Pohl  于2022年8月22日周一
> 15:35写道：
> > > >
> > > >> Congratulations & welcome! :-)
> > > >>
> > > >> Matthias
> > > >>
> > > >> On Sun, Aug 21, 2022 at 5:42 AM Yuan Mei 
> > > wrote:
> > > >>
> > > >>> Congratulations Junhan!
> > > >>>
> > > >>> Best,
> > > >>> Yuan
> > > >>>
> > > >>> On Sat, Aug 20, 2022 at 2:11 PM Danny Cranmer <
> > dannycran...@apache.org
> > > >
> > > >>> wrote:
> > > >>>
> > >  Congratulations Junhan! Welcome to the team.
> > > 
> > >  On Sat, 20 Aug 2022, 03:01 yuxia, 
> > > wrote:
> > > 
> > > > Congratulations, Junhan!
> > > >
> > > > Best regards,
> > > > Yuxia
> > > >
> > > > - 原始邮件 -
> > > > 发件人: "Aitozi" 
> > > > 收件人: "dev" 
> > > > 发送时间: 星期六, 2022年 8 月 20日 上午 12:18:29
> > > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang
> > > >
> > > > Congratulations, Junhan!
> > > > Best,
> > > > Aitozi
> > > >
> > > > Guowei Ma  于2022年8月19日周五 13:18写道：
> > > >
> > > >> Congratulations, Junhan!
> > > >> Best,
> > > >> Guowei
> > > >>
> > > >>
> > > >> On Fri, Aug 19, 2022 at 6:01 AM Jing Ge 
> > > >> wrote:
> > > >>
> > > >>> Congrats Junhan!
> > > >>>
> > > >>> Best regards,
> > > >>> Jing
> > > >>>
> > > >>> On Thu, Aug 18, 2022 at 12:05 PM Jark Wu 
> > > >> wrote:
> > > >>>
> > >  Congrats and welcome Junhan!
> > > 
> > >  Cheers,
> > >  Jark
> > > 
> > > > 2022年8月18日 17:59，Timo Walther  写道：
> > > >
> > > > Congratulations and welcome to the committer team :-)
> > > >
> > > > Regards,
> > > > Timo
> > > >
> > > > On 18.08.22 07:19, Lijie Wang wrote:
> > > >> Congratulations, Junhan!
> > > >> Best,
> > > >> Lijie
> > > >> Leonard Xu  于2022年8月18日周四 11:31写道：
> > > >>> Congratulations, Junhan!
> > > >>>
> > > >>> Best,
> > > >>>
> > >  2022年8月18日 上午11:27，Zhipeng Zhang  > > >>>
> > >  写道：
> > > 
> > >  Congratulations, Junhan!
> > > 
> > >  Xintong Song  于2022年8月18日周四 11:21写道：
> > > >
> > > > Hi everyone,
> > > >
> > > > On behalf of the PMC, I'm very happy to announce Junhan
> > > >>> Yang
> > > > as a
> > > >>> new
> > > >>> Flink
> > > > committer.
> > > >
> > > > Junhan has been contributing to the Flink project for
> > > >> more
> > > > than 1
> > >  year.
> > > >>> His
> > > > contributions are mostly identified in the web frontend,
> > > >> including
> > > > FLIP-241, FLIP-249 and various maintenance efforts of
> > > >>> Flink's
> > >  frontend
> > > > frameworks.
> > > >
> > > > Please join me in congratulating Junhan for becoming a
> > > >>> Flink
> > >  committer!
> > > >
> > > > Best,
> > > > Xintong
> > > 
> > > 
> > > 
> > >  --
> > >  best,
> > >  Zhipeng
> > > >>>
> > > >>>
> > > >
> > > 
> > > 
> > > >>>
> > > >>
> > > >
> > > 
> > > >>>
> > > >>
> > >
> > >
> >
>
>

Re: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

[Yu Li]

Congratulations, Lijie!

Best Regards,
Yu


On Thu, 25 Aug 2022 at 10:07, Yun Gao  wrote:

> Congratulations Lijie!
>
> Best,
> Yun Gao
>
>
> --
> Sender:Yangze Guo
> Date:2022/08/25 10:04:35
> Recipient:dev
> Cc:Lijie Wang
> Theme:Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
>
> Congrats!
>
> Jark Wu  于 2022年8月24日周三 下午3:47写道：
>
> > Congrats Lijie!
> >
> > Best,
> > Jark
> >
> > On Wed, 24 Aug 2022 at 15:06, Qingsheng Ren  wrote:
> >
> > > Congratulations Lijie!
> > >
> > > Best regards,
> > > Qingsheng
> > >
> > > > On Aug 22, 2022, at 16:29, Yang Wang  wrote:
> > > >
> > > > Congrats Lijie!
> > > >
> > > > Best,
> > > > Yang
> > > >
> > > > Matthias Pohl  于2022年8月22日周一
> 15:34写道：
> > > >
> > > >> Congrats & welcome to the team! :-)
> > > >>
> > > >> Matthias
> > > >>
> > > >> On Sun, Aug 21, 2022 at 5:41 AM Yuan Mei 
> > > wrote:
> > > >>
> > > >>> Congratulations, Lijie!
> > > >>>
> > > >>> Best,
> > > >>> Yuan
> > > >>>
> > > >>> On Sat, Aug 20, 2022 at 2:12 PM Danny Cranmer <
> > dannycran...@apache.org
> > > >
> > > >>> wrote:
> > > >>>
> > >  Congratulations Lijie! Welcome to the team.
> > > 
> > >  On Sat, 20 Aug 2022, 03:25 Yun Tang,  wrote:
> > > 
> > > > Congratulations, Lijie!
> > > >
> > > >
> > > > Best
> > > > Yun Tang
> > > > 
> > > > From: Geng Biao 
> > > > Sent: Saturday, August 20, 2022 10:03
> > > > To: dev@flink.apache.org 
> > > > Subject: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > > >
> > > > Congratulations Lijie!
> > > > Best,
> > > > Biao Geng
> > > >
> > > > 获取 Outlook for iOS
> > > > 
> > > > 发件人: yuxia 
> > > > 发送时间: Saturday, August 20, 2022 9:54:29 AM
> > > > 收件人: dev 
> > > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > > >
> > > > Congrats Lijie!
> > > >
> > > > Best regards,
> > > > Yuxia
> > > >
> > > > - 原始邮件 -
> > > > 发件人: "Aitozi" 
> > > > 收件人: "dev" 
> > > > 发送时间: 星期六, 2022年 8 月 20日 上午 12:19:27
> > > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > > >
> > > > Congrats Lijie!
> > > >
> > > > Best regards,
> > > > Aitozi
> > > >
> > > > Jing Ge  于2022年8月19日周五 06:02写道：
> > > >
> > > >> Congrats Lijie!
> > > >>
> > > >> Best regards,
> > > >> Jing
> > > >>
> > > >> On Thu, Aug 18, 2022 at 8:40 AM Terry Wang 
> > > >>> wrote:
> > > >>
> > > >>> Congratulations, Lijie!
> > > >>>
> > > >>> On Thu, Aug 18, 2022 at 11:31 AM Leonard Xu  >
> > >  wrote:
> > > >>>
> > >  Congratulations, Lijie!
> > > 
> > >  Best,
> > >  Leonard
> > > 
> > > > 2022年8月18日 上午11:26，Zhipeng Zhang 
> > > >> 写道：
> > > >
> > > > Congratulations, Lijie!
> > > >
> > > > Xintong Song  于2022年8月18日周四 11:23写道：
> > > >>
> > > >> Congratulations Lijie, and welcome~!
> > > >>
> > > >> Best,
> > > >>
> > > >> Xintong
> > > >>
> > > >>
> > > >>
> > > >> On Thu, Aug 18, 2022 at 11:12 AM Xingbo Huang <
> > >  hxbks...@gmail.com
> > > >>
> > >  wrote:
> > > >>
> > > >>> Congrats, Lijie
> > > >>>
> > > >>> Best,
> > > >>> Xingbo
> > > >>>
> > > >>> Lincoln Lee  于2022年8月18日周四
> > > >> 11:01写道：
> > > >>>
> > >  Congratulations, Lijie!
> > > 
> > >  Best,
> > >  Lincoln Lee
> > > 
> > > 
> > >  Benchao Li  于2022年8月18日周四 10:51写道：
> > > 
> > > > Congratulations Lijie!
> > > >
> > > > yanfei lei  于2022年8月18日周四 10:44写道：
> > > >
> > > >> Congratulations, Lijie!
> > > >>
> > > >> Best,
> > > >> Yanfei
> > > >>
> > > >> JunRui Lee  于2022年8月18日周四 10:35写道：
> > > >>
> > > >>> Congratulations, Lijie!
> > > >>>
> > > >>> Best,
> > > >>> JunRui
> > > >>>
> > > >>> Timo Walther  于2022年8月17日周三
> > > >> 19:30写道：
> > > >>>
> > >  Congratulations and welcome to the committer team :-)
> > > 
> > >  Regards,
> > >  Timo
> > > 
> > > 
> > >  On 17.08.22 12:50, Yuxin Tan wrote:
> > > > Congratulations, Lijie!
> > > >
> > > > Best,
> > > > Yuxin
> > > >
> > > >
> > > > Guowei Ma  于2022年8月17日周三
> > > >>> 18:42写道：
> > > >
> > > 

Re: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

[Yun Gao]

Congratulations Junhan!


Best,
Yun Gao


--
Sender:Yangze Guo
Date:2022/08/25 10:04:14
Recipient:dev
Cc:
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

Congrats!

Jark Wu  于 2022年8月24日周三 下午3:46写道：

> Congrats Junhan!
>
> Best,
> Jark
>
> On Wed, 24 Aug 2022 at 15:05, Qingsheng Ren  wrote:
>
> > Congratulations Junhan!
> >
> > Best regards,
> > Qingsheng
> >
> > > On Aug 22, 2022, at 16:30, Yang Wang  wrote:
> > >
> > > Congrats Junhan!
> > >
> > >
> > > Best,
> > > Yang
> > >
> > > Matthias Pohl  于2022年8月22日周一 15:35写道：
> > >
> > >> Congratulations & welcome! :-)
> > >>
> > >> Matthias
> > >>
> > >> On Sun, Aug 21, 2022 at 5:42 AM Yuan Mei 
> > wrote:
> > >>
> > >>> Congratulations Junhan!
> > >>>
> > >>> Best,
> > >>> Yuan
> > >>>
> > >>> On Sat, Aug 20, 2022 at 2:11 PM Danny Cranmer <
> dannycran...@apache.org
> > >
> > >>> wrote:
> > >>>
> >  Congratulations Junhan! Welcome to the team.
> > 
> >  On Sat, 20 Aug 2022, 03:01 yuxia, 
> > wrote:
> > 
> > > Congratulations, Junhan!
> > >
> > > Best regards,
> > > Yuxia
> > >
> > > - 原始邮件 -
> > > 发件人: "Aitozi" 
> > > 收件人: "dev" 
> > > 发送时间: 星期六, 2022年 8 月 20日 上午 12:18:29
> > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang
> > >
> > > Congratulations, Junhan!
> > > Best,
> > > Aitozi
> > >
> > > Guowei Ma  于2022年8月19日周五 13:18写道：
> > >
> > >> Congratulations, Junhan!
> > >> Best,
> > >> Guowei
> > >>
> > >>
> > >> On Fri, Aug 19, 2022 at 6:01 AM Jing Ge 
> > >> wrote:
> > >>
> > >>> Congrats Junhan!
> > >>>
> > >>> Best regards,
> > >>> Jing
> > >>>
> > >>> On Thu, Aug 18, 2022 at 12:05 PM Jark Wu 
> > >> wrote:
> > >>>
> >  Congrats and welcome Junhan!
> > 
> >  Cheers,
> >  Jark
> > 
> > > 2022年8月18日 17:59，Timo Walther  写道：
> > >
> > > Congratulations and welcome to the committer team :-)
> > >
> > > Regards,
> > > Timo
> > >
> > > On 18.08.22 07:19, Lijie Wang wrote:
> > >> Congratulations, Junhan!
> > >> Best,
> > >> Lijie
> > >> Leonard Xu  于2022年8月18日周四 11:31写道：
> > >>> Congratulations, Junhan!
> > >>>
> > >>> Best,
> > >>>
> >  2022年8月18日 上午11:27，Zhipeng Zhang  > >>>
> >  写道：
> > 
> >  Congratulations, Junhan!
> > 
> >  Xintong Song  于2022年8月18日周四 11:21写道：
> > >
> > > Hi everyone,
> > >
> > > On behalf of the PMC, I'm very happy to announce Junhan
> > >>> Yang
> > > as a
> > >>> new
> > >>> Flink
> > > committer.
> > >
> > > Junhan has been contributing to the Flink project for
> > >> more
> > > than 1
> >  year.
> > >>> His
> > > contributions are mostly identified in the web frontend,
> > >> including
> > > FLIP-241, FLIP-249 and various maintenance efforts of
> > >>> Flink's
> >  frontend
> > > frameworks.
> > >
> > > Please join me in congratulating Junhan for becoming a
> > >>> Flink
> >  committer!
> > >
> > > Best,
> > > Xintong
> > 
> > 
> > 
> >  --
> >  best,
> >  Zhipeng
> > >>>
> > >>>
> > >
> > 
> > 
> > >>>
> > >>
> > >
> > 
> > >>>
> > >>
> >
> >
>

Re: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

[Yun Gao]

Congratulations Lijie!

Best,
Yun Gao


--
Sender:Yangze Guo
Date:2022/08/25 10:04:35
Recipient:dev
Cc:Lijie Wang
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

Congrats!

Jark Wu  于 2022年8月24日周三 下午3:47写道：

> Congrats Lijie!
>
> Best,
> Jark
>
> On Wed, 24 Aug 2022 at 15:06, Qingsheng Ren  wrote:
>
> > Congratulations Lijie!
> >
> > Best regards,
> > Qingsheng
> >
> > > On Aug 22, 2022, at 16:29, Yang Wang  wrote:
> > >
> > > Congrats Lijie!
> > >
> > > Best,
> > > Yang
> > >
> > > Matthias Pohl  于2022年8月22日周一 15:34写道：
> > >
> > >> Congrats & welcome to the team! :-)
> > >>
> > >> Matthias
> > >>
> > >> On Sun, Aug 21, 2022 at 5:41 AM Yuan Mei 
> > wrote:
> > >>
> > >>> Congratulations, Lijie!
> > >>>
> > >>> Best,
> > >>> Yuan
> > >>>
> > >>> On Sat, Aug 20, 2022 at 2:12 PM Danny Cranmer <
> dannycran...@apache.org
> > >
> > >>> wrote:
> > >>>
> >  Congratulations Lijie! Welcome to the team.
> > 
> >  On Sat, 20 Aug 2022, 03:25 Yun Tang,  wrote:
> > 
> > > Congratulations, Lijie!
> > >
> > >
> > > Best
> > > Yun Tang
> > > 
> > > From: Geng Biao 
> > > Sent: Saturday, August 20, 2022 10:03
> > > To: dev@flink.apache.org 
> > > Subject: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > >
> > > Congratulations Lijie!
> > > Best,
> > > Biao Geng
> > >
> > > 获取 Outlook for iOS
> > > 
> > > 发件人: yuxia 
> > > 发送时间: Saturday, August 20, 2022 9:54:29 AM
> > > 收件人: dev 
> > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > >
> > > Congrats Lijie!
> > >
> > > Best regards,
> > > Yuxia
> > >
> > > - 原始邮件 -
> > > 发件人: "Aitozi" 
> > > 收件人: "dev" 
> > > 发送时间: 星期六, 2022年 8 月 20日 上午 12:19:27
> > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > >
> > > Congrats Lijie!
> > >
> > > Best regards,
> > > Aitozi
> > >
> > > Jing Ge  于2022年8月19日周五 06:02写道：
> > >
> > >> Congrats Lijie!
> > >>
> > >> Best regards,
> > >> Jing
> > >>
> > >> On Thu, Aug 18, 2022 at 8:40 AM Terry Wang 
> > >>> wrote:
> > >>
> > >>> Congratulations, Lijie!
> > >>>
> > >>> On Thu, Aug 18, 2022 at 11:31 AM Leonard Xu 
> >  wrote:
> > >>>
> >  Congratulations, Lijie!
> > 
> >  Best,
> >  Leonard
> > 
> > > 2022年8月18日 上午11:26，Zhipeng Zhang 
> > >> 写道：
> > >
> > > Congratulations, Lijie!
> > >
> > > Xintong Song  于2022年8月18日周四 11:23写道：
> > >>
> > >> Congratulations Lijie, and welcome~!
> > >>
> > >> Best,
> > >>
> > >> Xintong
> > >>
> > >>
> > >>
> > >> On Thu, Aug 18, 2022 at 11:12 AM Xingbo Huang <
> >  hxbks...@gmail.com
> > >>
> >  wrote:
> > >>
> > >>> Congrats, Lijie
> > >>>
> > >>> Best,
> > >>> Xingbo
> > >>>
> > >>> Lincoln Lee  于2022年8月18日周四
> > >> 11:01写道：
> > >>>
> >  Congratulations, Lijie!
> > 
> >  Best,
> >  Lincoln Lee
> > 
> > 
> >  Benchao Li  于2022年8月18日周四 10:51写道：
> > 
> > > Congratulations Lijie!
> > >
> > > yanfei lei  于2022年8月18日周四 10:44写道：
> > >
> > >> Congratulations, Lijie!
> > >>
> > >> Best,
> > >> Yanfei
> > >>
> > >> JunRui Lee  于2022年8月18日周四 10:35写道：
> > >>
> > >>> Congratulations, Lijie!
> > >>>
> > >>> Best,
> > >>> JunRui
> > >>>
> > >>> Timo Walther  于2022年8月17日周三
> > >> 19:30写道：
> > >>>
> >  Congratulations and welcome to the committer team :-)
> > 
> >  Regards,
> >  Timo
> > 
> > 
> >  On 17.08.22 12:50, Yuxin Tan wrote:
> > > Congratulations, Lijie!
> > >
> > > Best,
> > > Yuxin
> > >
> > >
> > > Guowei Ma  于2022年8月17日周三
> > >>> 18:42写道：
> > >
> > >> Congratulations, Lijie. Welcome on board~!
> > >> Best,
> > >> Guowei
> > >>
> > >>
> > >> On Wed, Aug 17, 2022 at 6:25 PM Zhu Zhu <
> >  zh...@apache.org
> > >>
> >  wrote:
> > >>
> > >>> Hi everyone,
> > >>>
> > >>> On behalf of the PMC, I'm very happy to announce
> > >>> Lijie
> > 

Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

[Yangze Guo]

Congrats!

Jark Wu  于 2022年8月24日周三 下午3:47写道：

> Congrats Lijie!
>
> Best,
> Jark
>
> On Wed, 24 Aug 2022 at 15:06, Qingsheng Ren  wrote:
>
> > Congratulations Lijie!
> >
> > Best regards,
> > Qingsheng
> >
> > > On Aug 22, 2022, at 16:29, Yang Wang  wrote:
> > >
> > > Congrats Lijie!
> > >
> > > Best,
> > > Yang
> > >
> > > Matthias Pohl  于2022年8月22日周一 15:34写道：
> > >
> > >> Congrats & welcome to the team! :-)
> > >>
> > >> Matthias
> > >>
> > >> On Sun, Aug 21, 2022 at 5:41 AM Yuan Mei 
> > wrote:
> > >>
> > >>> Congratulations, Lijie!
> > >>>
> > >>> Best,
> > >>> Yuan
> > >>>
> > >>> On Sat, Aug 20, 2022 at 2:12 PM Danny Cranmer <
> dannycran...@apache.org
> > >
> > >>> wrote:
> > >>>
> >  Congratulations Lijie! Welcome to the team.
> > 
> >  On Sat, 20 Aug 2022, 03:25 Yun Tang,  wrote:
> > 
> > > Congratulations, Lijie!
> > >
> > >
> > > Best
> > > Yun Tang
> > > 
> > > From: Geng Biao 
> > > Sent: Saturday, August 20, 2022 10:03
> > > To: dev@flink.apache.org 
> > > Subject: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > >
> > > Congratulations  Lijie!
> > > Best,
> > > Biao Geng
> > >
> > > 获取 Outlook for iOS
> > > 
> > > 发件人: yuxia 
> > > 发送时间: Saturday, August 20, 2022 9:54:29 AM
> > > 收件人: dev 
> > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > >
> > > Congrats Lijie!
> > >
> > > Best regards,
> > > Yuxia
> > >
> > > - 原始邮件 -
> > > 发件人: "Aitozi" 
> > > 收件人: "dev" 
> > > 发送时间: 星期六, 2022年 8 月 20日 上午 12:19:27
> > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> > >
> > > Congrats Lijie!
> > >
> > > Best regards,
> > > Aitozi
> > >
> > > Jing Ge  于2022年8月19日周五 06:02写道：
> > >
> > >> Congrats Lijie!
> > >>
> > >> Best regards,
> > >> Jing
> > >>
> > >> On Thu, Aug 18, 2022 at 8:40 AM Terry Wang 
> > >>> wrote:
> > >>
> > >>> Congratulations, Lijie!
> > >>>
> > >>> On Thu, Aug 18, 2022 at 11:31 AM Leonard Xu 
> >  wrote:
> > >>>
> >  Congratulations, Lijie!
> > 
> >  Best,
> >  Leonard
> > 
> > > 2022年8月18日 上午11:26，Zhipeng Zhang 
> > >> 写道：
> > >
> > > Congratulations, Lijie!
> > >
> > > Xintong Song  于2022年8月18日周四 11:23写道：
> > >>
> > >> Congratulations Lijie, and welcome~!
> > >>
> > >> Best,
> > >>
> > >> Xintong
> > >>
> > >>
> > >>
> > >> On Thu, Aug 18, 2022 at 11:12 AM Xingbo Huang <
> >  hxbks...@gmail.com
> > >>
> >  wrote:
> > >>
> > >>> Congrats, Lijie
> > >>>
> > >>> Best,
> > >>> Xingbo
> > >>>
> > >>> Lincoln Lee  于2022年8月18日周四
> > >> 11:01写道：
> > >>>
> >  Congratulations, Lijie!
> > 
> >  Best,
> >  Lincoln Lee
> > 
> > 
> >  Benchao Li  于2022年8月18日周四 10:51写道：
> > 
> > > Congratulations Lijie!
> > >
> > > yanfei lei  于2022年8月18日周四 10:44写道：
> > >
> > >> Congratulations, Lijie!
> > >>
> > >> Best,
> > >> Yanfei
> > >>
> > >> JunRui Lee  于2022年8月18日周四 10:35写道：
> > >>
> > >>> Congratulations, Lijie!
> > >>>
> > >>> Best,
> > >>> JunRui
> > >>>
> > >>> Timo Walther  于2022年8月17日周三
> > >> 19:30写道：
> > >>>
> >  Congratulations and welcome to the committer team :-)
> > 
> >  Regards,
> >  Timo
> > 
> > 
> >  On 17.08.22 12:50, Yuxin Tan wrote:
> > > Congratulations, Lijie!
> > >
> > > Best,
> > > Yuxin
> > >
> > >
> > > Guowei Ma  于2022年8月17日周三
> > >>> 18:42写道：
> > >
> > >> Congratulations, Lijie. Welcome on board~!
> > >> Best,
> > >> Guowei
> > >>
> > >>
> > >> On Wed, Aug 17, 2022 at 6:25 PM Zhu Zhu <
> >  zh...@apache.org
> > >>
> >  wrote:
> > >>
> > >>> Hi everyone,
> > >>>
> > >>> On behalf of the PMC, I'm very happy to announce
> > >>> Lijie
> > > Wang
> > >>> as
> > >>> a new Flink committer.
> > >>>
> > >>> Lijie has been contributing to Flink project for
> > >> more
> > > than
> > >> 2
> > > years.
> 

Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

[Yangze Guo]

Congrats!

Jark Wu  于 2022年8月24日周三 下午3:46写道：

> Congrats Junhan!
>
> Best,
> Jark
>
> On Wed, 24 Aug 2022 at 15:05, Qingsheng Ren  wrote:
>
> > Congratulations Junhan!
> >
> > Best regards,
> > Qingsheng
> >
> > > On Aug 22, 2022, at 16:30, Yang Wang  wrote:
> > >
> > > Congrats Junhan!
> > >
> > >
> > > Best,
> > > Yang
> > >
> > > Matthias Pohl  于2022年8月22日周一 15:35写道：
> > >
> > >> Congratulations & welcome! :-)
> > >>
> > >> Matthias
> > >>
> > >> On Sun, Aug 21, 2022 at 5:42 AM Yuan Mei 
> > wrote:
> > >>
> > >>> Congratulations Junhan!
> > >>>
> > >>> Best,
> > >>> Yuan
> > >>>
> > >>> On Sat, Aug 20, 2022 at 2:11 PM Danny Cranmer <
> dannycran...@apache.org
> > >
> > >>> wrote:
> > >>>
> >  Congratulations Junhan! Welcome to the team.
> > 
> >  On Sat, 20 Aug 2022, 03:01 yuxia, 
> > wrote:
> > 
> > > Congratulations, Junhan!
> > >
> > > Best regards,
> > > Yuxia
> > >
> > > - 原始邮件 -
> > > 发件人: "Aitozi" 
> > > 收件人: "dev" 
> > > 发送时间: 星期六, 2022年 8 月 20日 上午 12:18:29
> > > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang
> > >
> > > Congratulations, Junhan!
> > > Best,
> > > Aitozi
> > >
> > > Guowei Ma  于2022年8月19日周五 13:18写道：
> > >
> > >> Congratulations, Junhan!
> > >> Best,
> > >> Guowei
> > >>
> > >>
> > >> On Fri, Aug 19, 2022 at 6:01 AM Jing Ge 
> > >> wrote:
> > >>
> > >>> Congrats Junhan!
> > >>>
> > >>> Best regards,
> > >>> Jing
> > >>>
> > >>> On Thu, Aug 18, 2022 at 12:05 PM Jark Wu 
> > >> wrote:
> > >>>
> >  Congrats and welcome Junhan!
> > 
> >  Cheers,
> >  Jark
> > 
> > > 2022年8月18日 17:59，Timo Walther  写道：
> > >
> > > Congratulations and welcome to the committer team :-)
> > >
> > > Regards,
> > > Timo
> > >
> > > On 18.08.22 07:19, Lijie Wang wrote:
> > >> Congratulations, Junhan!
> > >> Best,
> > >> Lijie
> > >> Leonard Xu  于2022年8月18日周四 11:31写道：
> > >>> Congratulations, Junhan!
> > >>>
> > >>> Best,
> > >>>
> >  2022年8月18日 上午11:27，Zhipeng Zhang  > >>>
> >  写道：
> > 
> >  Congratulations, Junhan!
> > 
> >  Xintong Song  于2022年8月18日周四 11:21写道：
> > >
> > > Hi everyone,
> > >
> > > On behalf of the PMC, I'm very happy to announce Junhan
> > >>> Yang
> > > as a
> > >>> new
> > >>> Flink
> > > committer.
> > >
> > > Junhan has been contributing to the Flink project for
> > >> more
> > > than 1
> >  year.
> > >>> His
> > > contributions are mostly identified in the web frontend,
> > >> including
> > > FLIP-241, FLIP-249 and various maintenance efforts of
> > >>> Flink's
> >  frontend
> > > frameworks.
> > >
> > > Please join me in congratulating Junhan for becoming a
> > >>> Flink
> >  committer!
> > >
> > > Best,
> > > Xintong
> > 
> > 
> > 
> >  --
> >  best,
> >  Zhipeng
> > >>>
> > >>>
> > >
> > 
> > 
> > >>>
> > >>
> > >
> > 
> > >>>
> > >>
> >
> >
>

[jira] [Created] (FLINK-29100) Deployment with last-state upgrade mode stuck after initial error

[Thomas Weise (Jira)]

Thomas Weise created FLINK-29100:


 Summary: Deployment with last-state upgrade mode stuck after 
initial error
 Key: FLINK-29100
 URL: https://issues.apache.org/jira/browse/FLINK-29100
 Project: Flink
  Issue Type: Bug
  Components: Kubernetes Operator
Affects Versions: kubernetes-operator-1.1.0
Reporter: Thomas Weise
Assignee: Thomas Weise


A deployment with last_state upgrade mode that never succeeds will be stuck in 
deploying state because no HA data exists. This can be reproduced by creating a 
deployment with invalid image or exception in entry point. Update to the CR 
that corrects the issue won't be reconciled due to 
"o.a.f.k.o.r.d.ApplicationReconciler [INFO ] 
[default.basic-checkpoint-ha-example] Job is not running yet and HA metadata is 
not available, waiting for upgradeable state". This forces manual intervention 
to delete the CR.

Instead,  operator should check if this is the initial deployment and if so 
skip the HA metadata check.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Re: [DISCUSS] ARM support for Flink

[bo zhaobo]

Hi Flink,
Any idea about this? ;-)

bo zhaobo  于2022年8月23日周二 19:28写道：

> Hi Flinkers,
>
> In 2019, we raised an discussion in Flink about "ARM support for
> Flink"[1]. And we got so many helps and supports from Flink community about
> introducing a ARM CI system into Flink community, which is named
> "OpenLab"[2], and finally we create a full stack regression Flink tests on
> OpenLab ARM resources, then post a email to Flink Maillist about test
> result every day. We've been doing that for almost 2 years.
>
> But now, we are so apologized that OpenLab had been reached its EOL. We
> had to close it last month. So for sustaining the existing ARM CI still
> work on Flink Community and helping contributors to verify their code on
> ARM. We decide that we *will donate some ARM resources(Virtual Machines) *into
> Flink community to make this happen.
>
> And considering the existing Flink CICD had been moved to Azure Pipeline,
> and doesn't use github action.
>
> Now what we can provide are *ONLY *ARM resources(Virtual Machines) from
> us, so we think *Flink community is the right role to decide how to use
> them.*
> We only give several suggestions here:
> 1. Github action self-hosted Machines(Integrated with our ARM resources)
> 2. Azure Pipeline self-hosted Machines(Integrated with our ARM resources)
> 3. Any ideas from Flinkers?
>
> If community accepts our ARM resources and want to integrate with existing
> CICD in any way, please feel free to ping me about the quota(CPU nums,
> Memory size and so on) of VM we need to donate.
>
> Thank you very much.
>
> BR
>
> Bo Zhao
>
> [1] https://www.mail-archive.com/dev@flink.apache.org/msg27054.html
> [2] https://openlabtesting.org/
>

Re: [ANNOUNCE] Apache Flink 1.15.2 released

[Jing Ge]

Thanks Danny for your effort!

Best regards,
Jing

On Wed, Aug 24, 2022 at 11:43 PM Danny Cranmer 
wrote:

> The Apache Flink community is very happy to announce the release of Apache
> Flink 1.15.2, which is the second bugfix release for the Apache Flink 1.15
> series.
>
> Apache Flink® is an open-source stream processing framework for
> distributed, high-performing, always-available, and accurate data streaming
> applications.
>
> The release is available for download at:
> https://flink.apache.org/downloads.html
>
> Please check out the release blog post for an overview of the improvements
> for this bugfix release:
> https://flink.apache.org/news/2022/08/25/release-1.15.2.html
>
> The full release notes are available in Jira:
>
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351829
>
> We would like to thank all contributors of the Apache Flink community who
> made this release possible!
>
> Regards,
> Danny Cranmer
>

[ANNOUNCE] Apache Flink 1.15.2 released

[Danny Cranmer]

The Apache Flink community is very happy to announce the release of Apache
Flink 1.15.2, which is the second bugfix release for the Apache Flink 1.15
series.

Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.

The release is available for download at:
https://flink.apache.org/downloads.html

Please check out the release blog post for an overview of the improvements
for this bugfix release:
https://flink.apache.org/news/2022/08/25/release-1.15.2.html

The full release notes are available in Jira:
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351829

We would like to thank all contributors of the Apache Flink community who
made this release possible!

Regards,
Danny Cranmer

[jira] [Created] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

[seth saperstein (Jira)]

seth saperstein created FLINK-29099:
---

 Summary: Deadlock for Single Subtask in Kinesis Consumer
 Key: FLINK-29099
 URL: https://issues.apache.org/jira/browse/FLINK-29099
 Project: Flink
  Issue Type: Bug
  Components: Connectors / Kinesis
Affects Versions: 1.15.2, 1.14.5, 1.13.6, 1.12.7, 1.11.6, 1.10.3, 1.9.3
Reporter: seth saperstein


Deadlock is reached as the result of:
 * max lookahead reached for local watermark
 * idle state for subtask

The lookahead prevents the RecordEmitter from emitting a new record. The idle 
state prevents the global watermark from being updated.

To exit this deadlock state, we need to complete the [TODO 
here|https://github.com/apache/flink/blob/221d70d9930f72147422ea24b399f006ebbfb8d7/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java#L1268]
 which updates the global watermark while the subtask is marked idle, which 
will then allow us to emit a record again as the lookahead is no longer reached.

 

*Context:*

We reached this scenario at Lyft as a result of prolonged CPU throttling on all 
FlinkKinesisConsumer threads for multiple minutes.

Walking through the series of events:
 * prolonged CPU throttling occurs and no logs are seen from any 
FlinkKinesisConsumer thread for up to 15 minutes
 * after CPU throttling the subtask is marked idle
 * the subtask has reached the lookahead for its local watermark relative to 
the global watermark
 * WatermarkSyncCallback indicates the subtask as idle and does not update the 
global watermark
 * emitQueue fills to max
 * RecordEmitter cannot emit records due to the max lookahead
 * Deadlock on subtask

At this point, we had not realized what had happened and processing of all 
other shards/subtasks had continued for multiple days. When we finally 
restarted the application, we saw the following behavior:
 * global watermark recalculated after all subtasks consumed data based on the 
last kinesis record sequence number
 * global watermark moved back in time multiple days, to when the subtask was 
first marked idle
 * the single subtask processed data while all others remained idle due to the 
lookahead

This would have continued until the subtask had caught up to the others and 
thus the global watermark is within reach of the lookahead for other subtasks.

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (FLINK-29098) StoreWriteOperator#prepareCommit should let logSinkFunction flush first before fetching offset

[Jane Chan (Jira)]

Jane Chan created FLINK-29098:
-

 Summary: StoreWriteOperator#prepareCommit should let 
logSinkFunction flush first before fetching offset
 Key: FLINK-29098
 URL: https://issues.apache.org/jira/browse/FLINK-29098
 Project: Flink
  Issue Type: Bug
  Components: Table Store
Affects Versions: table-store-0.3.0
Reporter: Jane Chan
 Fix For: table-store-0.3.0






--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (FLINK-29097) Moving json se/deserializers from sql-gateway-api to sql-gateway

[Wencong Liu (Jira)]

Wencong Liu created FLINK-29097:
---

 Summary: Moving json se/deserializers from sql-gateway-api to 
sql-gateway
 Key: FLINK-29097
 URL: https://issues.apache.org/jira/browse/FLINK-29097
 Project: Flink
  Issue Type: Technical Debt
  Components: Table SQL / Gateway
Affects Versions: 1.16.0
Reporter: Wencong Liu


Considering that the current json se/deserialization rules for results returned 
by SqlGateway are only used in Rest Endpoint, we migrated the serialization 
related tools from the flink-sql-gateway-api to the flink-sql-gateway package.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (FLINK-29096) json_value when the path has blank, the result is not right

[jackylau (Jira)]

jackylau created FLINK-29096:


 Summary: json_value when the path has blank, the result is not 
right
 Key: FLINK-29096
 URL: https://issues.apache.org/jira/browse/FLINK-29096
 Project: Flink
  Issue Type: Bug
  Components: Table SQL / Planner
Affects Versions: 1.16.0
Reporter: jackylau
 Fix For: 1.16.0


!https://aone.alipay.com/v2/api/workitem/adapter/file/url?fileIdentifier=workitem%2Falipay%2Fdefault%2F1661334308971image.png!

 

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Re: [VOTE] Apache Flink Table Store 0.2.0, release candidate #3

[Nicholas Jiang]

Hi all!

+1 for the release (non-binding). I've verified the jar with SQL client and 
listed the check items as follows:

* Compiled the sources and built the source distribution - PASSED
* Ran through Quick Start Guide - PASSED
* Checked Spark 2.3.4&3.3.0 reader and catalog with table store jar - PASSED
* Checked all NOTICE files - PASSED
* Checked the website updates - PASSED

Regards,
Nicholas Jiang

On 2022/08/24 07:46:00 Jingsong Li wrote:
> Hi everyone,
> 
> Please review and vote on the release candidate #3 for the version 0.2.0 of
> Apache Flink Table Store, as follows:
> 
> [ ] +1, Approve the release
> [ ] -1, Do not approve the release (please provide specific comments)
> 
> **Release Overview**
> 
> As an overview, the release consists of the following:
> a) Table Store canonical source distribution to be deployed to the
> release repository at dist.apache.org
> b) Table Store binary convenience releases to be deployed to the
> release repository at dist.apache.org
> c) Maven artifacts to be deployed to the Maven Central Repository
> 
> **Staging Areas to Review**
> 
> The staging areas containing the above mentioned artifacts are as follows,
> for your review:
> * All artifacts for a) and b) can be found in the corresponding dev
> repository at dist.apache.org [2]
> * All artifacts for c) can be found at the Apache Nexus Repository [3]
> 
> All artifacts are signed with the key
> 2C2B6A653B07086B65E4369F7C76245E0A318150 [4]
> 
> Other links for your review:
> * JIRA release notes [5]
> * source code tag "release-0.2.0-rc3" [6]
> * PR to update the website Downloads page to include Table Store links [7]
> 
> **Vote Duration**
> 
> The voting time will run for at least 72 hours.
> It is adopted by majority approval, with at least 3 PMC affirmative votes.
> 
> Best,
> Jingsong Lee
> 
> [1] 
> https://cwiki.apache.org/confluence/display/FLINK/Verifying+a+Flink+Table+Store+Release
> [2] https://dist.apache.org/repos/dist/dev/flink/flink-table-store-0.2.0-rc3/
> [3] https://repository.apache.org/content/repositories/orgapacheflink-1526/
> [4] https://dist.apache.org/repos/dist/release/flink/KEYS
> [5] 
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351570
> [6] https://github.com/apache/flink-table-store/tree/release-0.2.0-rc3
> [7] https://github.com/apache/flink-web/pull/562
> 

[jira] [Created] (FLINK-29095) logging state file deletion

[Jing Ge (Jira)]

Jing Ge created FLINK-29095:
---

 Summary: logging state file deletion
 Key: FLINK-29095
 URL: https://issues.apache.org/jira/browse/FLINK-29095
 Project: Flink
  Issue Type: New Feature
  Components: Runtime / State Backends
Affects Versions: 1.16.0
Reporter: Jing Ge


with the incremental checkpoint, conceptually, state files that are never used 
by any checkpoint will be deleted/GC . In practices, state files might be 
deleted when they are still somehow required by the failover which will lead to 
Flink job fails.

We should add the log for trouble shooting.  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (FLINK-29094) Cannot stop Python job with savepoint when using Kafka Consumer

[Bartosz Mikulski (Jira)]

Bartosz Mikulski created FLINK-29094:


 Summary: Cannot stop Python job with savepoint when using Kafka 
Consumer
 Key: FLINK-29094
 URL: https://issues.apache.org/jira/browse/FLINK-29094
 Project: Flink
  Issue Type: Bug
  Components: API / Python
Affects Versions: 1.15.1
 Environment: Local Environment
 * OS: Ubuntu 20.04
 * Java: openjdk version "11.0.12" 2021-07-20
 * Flink: 1.15.1 (clean instalation)
 * Kafka: kafka_2.13-2.8.1
Reporter: Bartosz Mikulski


We want to gracefully stop a Python job reading from Kafka. However, running 
`flink stop --savepointPath` causes an exception to be thrown and the job 
fails. Find the exception in the 
[Gist|https://gist.github.com/BartMiki/6eab470a49d8a935ed3e7e544c3f278f#file-exception-txt].
 The type of savepoint also doesn't matter both canonical and native fail. This 
Stack Overflow [answer|https://stackoverflow.com/a/68280329] also does not 
work. 

However, checkpoints work fine. This leads to weird scenarios when you want to 
stop a Python job, stopping fails with an exception, and the job is restarted 
from the latest checkpoint.

The setup was tested in fresh default Flink 1.15.1 installation (however we 
also tried 1.15.0 with the same error).  The error occurred regardless of the 
amount of data processed from Kafka (could be even none). [Gist with minimal 
code required to trigger the 
exception|https://gist.github.com/BartMiki/6eab470a49d8a935ed3e7e544c3f278f].



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Re: [upsert-kafka][SQL] Why Upsert-Kafka SQL connector is a different connector from the Kafka SQL Connector

[Yufei Zhang]

Thanks~ Will take a look.

Cheers,
Yufei

On Wed, Aug 24, 2022 at 3:45 PM Jark Wu  wrote:

> There was a long discussion about this. You can read the thread[1].
>
> Best,
> Jark
>
> [1]: https://lists.apache.org/thread/sr6on0cq52ns4y3zh6j0x899by80n5zw
>
> On Wed, 24 Aug 2022 at 13:20, Yufei Zhang  wrote:
>
> > Hi all,
> >
> > I noticed there is a Upsert-Kafka SQL Connector[1] and the Kafka SQL
> > Connector[2], my question is why do we implement them as two different
> > connectors? For example, why not add a `upsert` config option in the
> Kafka
> > SQL connector to specify whether the table enables upsert mode or not. Is
> > there a special consideration that we have to use a different connector
> > name like `upsert-kafka` and implement a different
> > DynamicSource/SinkFactory  ?
> >
> > Thank you in advance~
> >
> > Cheers,
> > Yufei
> >
> >
> >
> >
> >
> >
> >
> > - [1] :
> >
> >
> https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/upsert-kafka/
> >
> > - [2]:
> >
> >
> https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/kafka
> >
>

Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

[Jark Wu]

Congrats Lijie!

Best,
Jark

On Wed, 24 Aug 2022 at 15:06, Qingsheng Ren  wrote:

> Congratulations Lijie!
>
> Best regards,
> Qingsheng
>
> > On Aug 22, 2022, at 16:29, Yang Wang  wrote:
> >
> > Congrats Lijie!
> >
> > Best,
> > Yang
> >
> > Matthias Pohl  于2022年8月22日周一 15:34写道：
> >
> >> Congrats & welcome to the team! :-)
> >>
> >> Matthias
> >>
> >> On Sun, Aug 21, 2022 at 5:41 AM Yuan Mei 
> wrote:
> >>
> >>> Congratulations, Lijie!
> >>>
> >>> Best,
> >>> Yuan
> >>>
> >>> On Sat, Aug 20, 2022 at 2:12 PM Danny Cranmer  >
> >>> wrote:
> >>>
>  Congratulations Lijie! Welcome to the team.
> 
>  On Sat, 20 Aug 2022, 03:25 Yun Tang,  wrote:
> 
> > Congratulations, Lijie!
> >
> >
> > Best
> > Yun Tang
> > 
> > From: Geng Biao 
> > Sent: Saturday, August 20, 2022 10:03
> > To: dev@flink.apache.org 
> > Subject: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> >
> > Congratulations  Lijie!
> > Best,
> > Biao Geng
> >
> > 获取 Outlook for iOS
> > 
> > 发件人: yuxia 
> > 发送时间: Saturday, August 20, 2022 9:54:29 AM
> > 收件人: dev 
> > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> >
> > Congrats Lijie!
> >
> > Best regards,
> > Yuxia
> >
> > - 原始邮件 -
> > 发件人: "Aitozi" 
> > 收件人: "dev" 
> > 发送时间: 星期六, 2022年 8 月 20日 上午 12:19:27
> > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> >
> > Congrats Lijie!
> >
> > Best regards,
> > Aitozi
> >
> > Jing Ge  于2022年8月19日周五 06:02写道：
> >
> >> Congrats Lijie!
> >>
> >> Best regards,
> >> Jing
> >>
> >> On Thu, Aug 18, 2022 at 8:40 AM Terry Wang 
> >>> wrote:
> >>
> >>> Congratulations, Lijie!
> >>>
> >>> On Thu, Aug 18, 2022 at 11:31 AM Leonard Xu 
>  wrote:
> >>>
>  Congratulations, Lijie!
> 
>  Best,
>  Leonard
> 
> > 2022年8月18日 上午11:26，Zhipeng Zhang 
> >> 写道：
> >
> > Congratulations, Lijie!
> >
> > Xintong Song  于2022年8月18日周四 11:23写道：
> >>
> >> Congratulations Lijie, and welcome~!
> >>
> >> Best,
> >>
> >> Xintong
> >>
> >>
> >>
> >> On Thu, Aug 18, 2022 at 11:12 AM Xingbo Huang <
>  hxbks...@gmail.com
> >>
>  wrote:
> >>
> >>> Congrats, Lijie
> >>>
> >>> Best,
> >>> Xingbo
> >>>
> >>> Lincoln Lee  于2022年8月18日周四
> >> 11:01写道：
> >>>
>  Congratulations, Lijie!
> 
>  Best,
>  Lincoln Lee
> 
> 
>  Benchao Li  于2022年8月18日周四 10:51写道：
> 
> > Congratulations Lijie!
> >
> > yanfei lei  于2022年8月18日周四 10:44写道：
> >
> >> Congratulations, Lijie!
> >>
> >> Best,
> >> Yanfei
> >>
> >> JunRui Lee  于2022年8月18日周四 10:35写道：
> >>
> >>> Congratulations, Lijie!
> >>>
> >>> Best,
> >>> JunRui
> >>>
> >>> Timo Walther  于2022年8月17日周三
> >> 19:30写道：
> >>>
>  Congratulations and welcome to the committer team :-)
> 
>  Regards,
>  Timo
> 
> 
>  On 17.08.22 12:50, Yuxin Tan wrote:
> > Congratulations, Lijie!
> >
> > Best,
> > Yuxin
> >
> >
> > Guowei Ma  于2022年8月17日周三
> >>> 18:42写道：
> >
> >> Congratulations, Lijie. Welcome on board~!
> >> Best,
> >> Guowei
> >>
> >>
> >> On Wed, Aug 17, 2022 at 6:25 PM Zhu Zhu <
>  zh...@apache.org
> >>
>  wrote:
> >>
> >>> Hi everyone,
> >>>
> >>> On behalf of the PMC, I'm very happy to announce
> >>> Lijie
> > Wang
> >>> as
> >>> a new Flink committer.
> >>>
> >>> Lijie has been contributing to Flink project for
> >> more
> > than
> >> 2
> > years.
> >>> He mainly works on the runtime/coordination part,
> >>> doing
> >>> feature
> >>> development, problem debugging and code reviews. He
> >>> has
> >> also
> >>> driven the work of FLIP-187(Adaptive Batch
> >> Scheduler)
>  and
> >>> FLIP-224(Blocklist for Speculative Execution),
> >> which
>  are
> > important
> >>> to run batch jobs.
> 

[VOTE] Apache Flink Table Store 0.2.0, release candidate #3

[Jingsong Li]

Hi everyone,

Please review and vote on the release candidate #3 for the version 0.2.0 of
Apache Flink Table Store, as follows:

[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)

**Release Overview**

As an overview, the release consists of the following:
a) Table Store canonical source distribution to be deployed to the
release repository at dist.apache.org
b) Table Store binary convenience releases to be deployed to the
release repository at dist.apache.org
c) Maven artifacts to be deployed to the Maven Central Repository

**Staging Areas to Review**

The staging areas containing the above mentioned artifacts are as follows,
for your review:
* All artifacts for a) and b) can be found in the corresponding dev
repository at dist.apache.org [2]
* All artifacts for c) can be found at the Apache Nexus Repository [3]

All artifacts are signed with the key
2C2B6A653B07086B65E4369F7C76245E0A318150 [4]

Other links for your review:
* JIRA release notes [5]
* source code tag "release-0.2.0-rc3" [6]
* PR to update the website Downloads page to include Table Store links [7]

**Vote Duration**

The voting time will run for at least 72 hours.
It is adopted by majority approval, with at least 3 PMC affirmative votes.

Best,
Jingsong Lee

[1] 
https://cwiki.apache.org/confluence/display/FLINK/Verifying+a+Flink+Table+Store+Release
[2] https://dist.apache.org/repos/dist/dev/flink/flink-table-store-0.2.0-rc3/
[3] https://repository.apache.org/content/repositories/orgapacheflink-1526/
[4] https://dist.apache.org/repos/dist/release/flink/KEYS
[5] 
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351570
[6] https://github.com/apache/flink-table-store/tree/release-0.2.0-rc3
[7] https://github.com/apache/flink-web/pull/562

Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

[Jark Wu]

Congrats Junhan!

Best,
Jark

On Wed, 24 Aug 2022 at 15:05, Qingsheng Ren  wrote:

> Congratulations Junhan!
>
> Best regards,
> Qingsheng
>
> > On Aug 22, 2022, at 16:30, Yang Wang  wrote:
> >
> > Congrats Junhan!
> >
> >
> > Best,
> > Yang
> >
> > Matthias Pohl  于2022年8月22日周一 15:35写道：
> >
> >> Congratulations & welcome! :-)
> >>
> >> Matthias
> >>
> >> On Sun, Aug 21, 2022 at 5:42 AM Yuan Mei 
> wrote:
> >>
> >>> Congratulations Junhan!
> >>>
> >>> Best,
> >>> Yuan
> >>>
> >>> On Sat, Aug 20, 2022 at 2:11 PM Danny Cranmer  >
> >>> wrote:
> >>>
>  Congratulations Junhan! Welcome to the team.
> 
>  On Sat, 20 Aug 2022, 03:01 yuxia, 
> wrote:
> 
> > Congratulations, Junhan!
> >
> > Best regards,
> > Yuxia
> >
> > - 原始邮件 -
> > 发件人: "Aitozi" 
> > 收件人: "dev" 
> > 发送时间: 星期六, 2022年 8 月 20日 上午 12:18:29
> > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang
> >
> > Congratulations, Junhan!
> > Best,
> > Aitozi
> >
> > Guowei Ma  于2022年8月19日周五 13:18写道：
> >
> >> Congratulations, Junhan!
> >> Best,
> >> Guowei
> >>
> >>
> >> On Fri, Aug 19, 2022 at 6:01 AM Jing Ge 
> >> wrote:
> >>
> >>> Congrats Junhan!
> >>>
> >>> Best regards,
> >>> Jing
> >>>
> >>> On Thu, Aug 18, 2022 at 12:05 PM Jark Wu 
> >> wrote:
> >>>
>  Congrats and welcome Junhan!
> 
>  Cheers,
>  Jark
> 
> > 2022年8月18日 17:59，Timo Walther  写道：
> >
> > Congratulations and welcome to the committer team :-)
> >
> > Regards,
> > Timo
> >
> > On 18.08.22 07:19, Lijie Wang wrote:
> >> Congratulations, Junhan!
> >> Best,
> >> Lijie
> >> Leonard Xu  于2022年8月18日周四 11:31写道：
> >>> Congratulations, Junhan!
> >>>
> >>> Best,
> >>>
>  2022年8月18日 上午11:27，Zhipeng Zhang  >>>
>  写道：
> 
>  Congratulations, Junhan!
> 
>  Xintong Song  于2022年8月18日周四 11:21写道：
> >
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy to announce Junhan
> >>> Yang
> > as a
> >>> new
> >>> Flink
> > committer.
> >
> > Junhan has been contributing to the Flink project for
> >> more
> > than 1
>  year.
> >>> His
> > contributions are mostly identified in the web frontend,
> >> including
> > FLIP-241, FLIP-249 and various maintenance efforts of
> >>> Flink's
>  frontend
> > frameworks.
> >
> > Please join me in congratulating Junhan for becoming a
> >>> Flink
>  committer!
> >
> > Best,
> > Xintong
> 
> 
> 
>  --
>  best,
>  Zhipeng
> >>>
> >>>
> >
> 
> 
> >>>
> >>
> >
> 
> >>>
> >>
>
>

Re: [upsert-kafka][SQL] Why Upsert-Kafka SQL connector is a different connector from the Kafka SQL Connector

[Jark Wu]

There was a long discussion about this. You can read the thread[1].

Best,
Jark

[1]: https://lists.apache.org/thread/sr6on0cq52ns4y3zh6j0x899by80n5zw

On Wed, 24 Aug 2022 at 13:20, Yufei Zhang  wrote:

> Hi all,
>
> I noticed there is a Upsert-Kafka SQL Connector[1] and the Kafka SQL
> Connector[2], my question is why do we implement them as two different
> connectors? For example, why not add a `upsert` config option in the Kafka
> SQL connector to specify whether the table enables upsert mode or not. Is
> there a special consideration that we have to use a different connector
> name like `upsert-kafka` and implement a different
> DynamicSource/SinkFactory  ?
>
> Thank you in advance~
>
> Cheers,
> Yufei
>
>
>
>
>
>
>
> - [1] :
>
> https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/upsert-kafka/
>
> - [2]:
>
> https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/kafka
>

[jira] [Created] (FLINK-29093) LookupJoinITCase failed with InternalCompilerException

[Xingbo Huang (Jira)]

Xingbo Huang created FLINK-29093:


 Summary: LookupJoinITCase failed with InternalCompilerException
 Key: FLINK-29093
 URL: https://issues.apache.org/jira/browse/FLINK-29093
 Project: Flink
  Issue Type: Bug
  Components: Table SQL / Runtime
Affects Versions: 1.16.0
Reporter: Xingbo Huang
 Fix For: 1.16.0


{code:java}
2022-08-24T03:45:02.5915521Z Aug 24 03:45:02 
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-08-24T03:45:02.5916823Z Aug 24 03:45:02at 
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-08-24T03:45:02.5919320Z Aug 24 03:45:02at 
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
2022-08-24T03:45:02.5920833Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-08-24T03:45:02.5922361Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-08-24T03:45:02.5923733Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-08-24T03:45:02.5924922Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-08-24T03:45:02.5926191Z Aug 24 03:45:02at 
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:268)
2022-08-24T03:45:02.5927677Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-08-24T03:45:02.5929091Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-08-24T03:45:02.5930430Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-08-24T03:45:02.5931966Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-08-24T03:45:02.5933293Z Aug 24 03:45:02at 
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1277)
2022-08-24T03:45:02.5934708Z Aug 24 03:45:02at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
2022-08-24T03:45:02.5936228Z Aug 24 03:45:02at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2022-08-24T03:45:02.5937998Z Aug 24 03:45:02at 
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2022-08-24T03:45:02.5939627Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-08-24T03:45:02.5941051Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-08-24T03:45:02.5942650Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-08-24T03:45:02.5944203Z Aug 24 03:45:02at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-08-24T03:45:02.5945740Z Aug 24 03:45:02at 
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
2022-08-24T03:45:02.5947020Z Aug 24 03:45:02at 
akka.dispatch.OnComplete.internal(Future.scala:300)
2022-08-24T03:45:02.5948130Z Aug 24 03:45:02at 
akka.dispatch.OnComplete.internal(Future.scala:297)
2022-08-24T03:45:02.5949255Z Aug 24 03:45:02at 
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2022-08-24T03:45:02.5950405Z Aug 24 03:45:02at 
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2022-08-24T03:45:02.5951638Z Aug 24 03:45:02at 
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-08-24T03:45:02.5953564Z Aug 24 03:45:02at 
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2022-08-24T03:45:02.5955214Z Aug 24 03:45:02at 
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2022-08-24T03:45:02.5956587Z Aug 24 03:45:02at 
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2022-08-24T03:45:02.5958037Z Aug 24 03:45:02at 
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2022-08-24T03:45:02.5959448Z Aug 24 03:45:02at 
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2022-08-24T03:45:02.5960679Z Aug 24 03:45:02at 
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2022-08-24T03:45:02.5962183Z Aug 24 03:45:02at 
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
2022-08-24T03:45:02.5963694Z Aug 24 03:45:02at 

[jira] [Created] (FLINK-29092) HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError

[Xingbo Huang (Jira)]

Xingbo Huang created FLINK-29092:


 Summary: HadoopPathBasedPartFileWriterTest.testWriteFile failed 
with AssertionError
 Key: FLINK-29092
 URL: https://issues.apache.org/jira/browse/FLINK-29092
 Project: Flink
  Issue Type: Bug
  Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Affects Versions: 1.16.0
Reporter: Xingbo Huang
 Fix For: 1.16.0


{code:java}
2022-08-24T02:00:01.1670618Z Aug 24 02:00:01 [ERROR] 
org.apache.flink.formats.hadoop.bulk.HadoopPathBasedPartFileWriterTest.testWriteFile
  Time elapsed: 2.311 s  <<< FAILURE!
2022-08-24T02:00:01.1671250Z Aug 24 02:00:01 java.lang.AssertionError: 
2022-08-24T02:00:01.1671626Z Aug 24 02:00:01 
2022-08-24T02:00:01.1672001Z Aug 24 02:00:01 Expected size: 1 but was: 2 in:
2022-08-24T02:00:01.1673656Z Aug 24 02:00:01 
[DeprecatedRawLocalFileStatus{path=file:/tmp/junit3893779198554813459/junit1595046776902782406/2022-08-24--02;
 isDirectory=true; modification_time=166130640; access_time=1661306400396; 
owner=; group=; permission=rwxrwxrwx; isSymlink=false; hasAcl=false; 
isEncrypted=false; isErasureCoded=false},
2022-08-24T02:00:01.1676131Z Aug 24 02:00:01 
DeprecatedRawLocalFileStatus{path=file:/tmp/junit3893779198554813459/junit1595046776902782406/2022-08-24--01;
 isDirectory=true; modification_time=166130640; access_time=1661306400326; 
owner=; group=; permission=rwxrwxrwx; isSymlink=false; hasAcl=false; 
isEncrypted=false; isErasureCoded=false}]
2022-08-24T02:00:01.1677339Z Aug 24 02:00:01at 
org.apache.flink.formats.hadoop.bulk.HadoopPathBasedPartFileWriterTest.validateResult(HadoopPathBasedPartFileWriterTest.java:107)
2022-08-24T02:00:01.1678274Z Aug 24 02:00:01at 
org.apache.flink.formats.hadoop.bulk.HadoopPathBasedPartFileWriterTest.testWriteFile(HadoopPathBasedPartFileWriterTest.java:97)
2022-08-24T02:00:01.1679017Z Aug 24 02:00:01at 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-08-24T02:00:01.1679666Z Aug 24 02:00:01at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-08-24T02:00:01.1680369Z Aug 24 02:00:01at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-08-24T02:00:01.1681019Z Aug 24 02:00:01at 
java.lang.reflect.Method.invoke(Method.java:498)
2022-08-24T02:00:01.1681666Z Aug 24 02:00:01at 
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2022-08-24T02:00:01.1682385Z Aug 24 02:00:01at 
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2022-08-24T02:00:01.1683094Z Aug 24 02:00:01at 
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2022-08-24T02:00:01.1683965Z Aug 24 02:00:01at 
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2022-08-24T02:00:01.1684713Z Aug 24 02:00:01at 
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2022-08-24T02:00:01.1685956Z Aug 24 02:00:01at 
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:299)
2022-08-24T02:00:01.1687185Z Aug 24 02:00:01at 
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:293)
2022-08-24T02:00:01.1688347Z Aug 24 02:00:01at 
java.util.concurrent.FutureTask.run(FutureTask.java:266)
2022-08-24T02:00:01.1689324Z Aug 24 02:00:01at 
java.lang.Thread.run(Thread.java:748)
2022-08-24T02:00:01.1690062Z Aug 24 02:00:01 
2022-08-24T02:00:03.4727706Z Aug 24 02:00:03 Formatting using clusterid: 
testClusterID
2022-08-24T02:00:07.9860626Z Aug 24 02:00:07 [INFO] Tests run: 12, Failures: 0, 
Errors: 0, Skipped: 0, Time elapsed: 13.712 s - in 
org.apache.flink.formats.hadoop.bulk.committer.HadoopRenameCommitterHDFSTest
2022-08-24T02:00:08.4139747Z Aug 24 02:00:08 [INFO] 
2022-08-24T02:00:08.4140678Z Aug 24 02:00:08 [INFO] Results:
2022-08-24T02:00:08.4141326Z Aug 24 02:00:08 [INFO] 
2022-08-24T02:00:08.4142008Z Aug 24 02:00:08 [ERROR] Failures: 
2022-08-24T02:00:08.4144242Z Aug 24 02:00:08 [ERROR]   
HadoopPathBasedPartFileWriterTest.testWriteFile:97->validateResult:107 
2022-08-24T02:00:08.4145317Z Aug 24 02:00:08 Expected size: 1 but was: 2 in:
2022-08-24T02:00:08.4147711Z Aug 24 02:00:08 
[DeprecatedRawLocalFileStatus{path=file:/tmp/junit3893779198554813459/junit1595046776902782406/2022-08-24--02;
 isDirectory=true; modification_time=166130640; access_time=1661306400396; 
owner=; group=; permission=rwxrwxrwx; isSymlink=false; hasAcl=false; 
isEncrypted=false; isErasureCoded=false},
2022-08-24T02:00:08.4150885Z Aug 24 02:00:08 
DeprecatedRawLocalFileStatus{path=file:/tmp/junit3893779198554813459/junit1595046776902782406/2022-08-24--01;
 isDirectory=true; modification_time=166130640; access_time=1661306400326; 
owner=; group=; 

Re: [VOTE] Apache Flink Table Store 0.2.0, release candidate #2

[Caizhi Weng]

Hi all!

-1 for this release candidate as Hive catalog and Hive connector fail to
support Hive CDH.

See https://issues.apache.org/jira/browse/FLINK-29071 for more detail.

Yu Li  于2022年8月23日周二 17:31写道：

> +1 (binding)
>
> - Checked release notes: *Action Required*
>   - Minor: there're still 25 open issues with fix version marked as 0.2.0
> and need to be updated [1]
> - Checked sums and signatures: *OK*
> - Checked the jars in the staging repo: *OK*
> - Checked source distribution doesn't include binaries: *OK*
> - Maven clean install from source: *OK*
> - Checked version consistency in pom files: *OK*
> - Went through the quick start: *OK*
> - Checked the website updates: *OK*
>   - Minor: left some suggestions, please check.
>
> Thanks for driving this release, Jingsong!
>
> Best Regards,
> Yu
>
> [1]
>
> https://issues.apache.org/jira/issues/?jql=project%20%3D%20FLINK%20AND%20status%20in%20(Open%2C%20%22In%20Progress%22%2C%20Reopened)%20AND%20fixVersion%20%3D%20table-store-0.2.0%20AND%20component%20%3D%20%22Table%20Store%22
>
>
> On Thu, 18 Aug 2022 at 15:30, Nicholas Jiang 
> wrote:
>
> > Hi all!
> >
> > +1 for the release (non-binding). I've verified the jar with SQL client
> > and listed the check items as follows:
> >
> > * Compiled the sources and built the source distribution - PASSED
> > * Ran through Quick Start Guide - PASSED
> > * Checked Spark 2.3.4&3.3.0 reader and catalog with table store jar -
> > PASSED
> > * Checked all NOTICE files - PASSED
> >
> > Regards,
> > Nicholas Jiang
> >
> > On 2022/08/17 10:16:54 Jingsong Li wrote:
> > > Hi everyone,
> > >
> > > Please review and vote on the release candidate #2 for the version
> 0.2.0
> > of
> > > Apache Flink Table Store, as follows:
> > >
> > > [ ] +1, Approve the release
> > > [ ] -1, Do not approve the release (please provide specific comments)
> > >
> > > **Release Overview**
> > >
> > > As an overview, the release consists of the following:
> > > a) Table Store canonical source distribution to be deployed to the
> > > release repository at dist.apache.org
> > > b) Table Store binary convenience releases to be deployed to the
> > > release repository at dist.apache.org
> > > c) Maven artifacts to be deployed to the Maven Central Repository
> > >
> > > **Staging Areas to Review**
> > >
> > > The staging areas containing the above mentioned artifacts are as
> > follows,
> > > for your review:
> > > * All artifacts for a) and b) can be found in the corresponding dev
> > > repository at dist.apache.org [2]
> > > * All artifacts for c) can be found at the Apache Nexus Repository [3]
> > >
> > > All artifacts are signed with the key
> > > 2C2B6A653B07086B65E4369F7C76245E0A318150 [4]
> > >
> > > Other links for your review:
> > > * JIRA release notes [5]
> > > * source code tag "release-0.2.0-rc2" [6]
> > > * PR to update the website Downloads page to include Table Store links
> > [7]
> > >
> > > **Vote Duration**
> > >
> > > The voting time will run for at least 72 hours.
> > > It is adopted by majority approval, with at least 3 PMC affirmative
> > votes.
> > >
> > > Best,
> > > Jingsong Lee
> > >
> > > [1]
> >
> https://cwiki.apache.org/confluence/display/FLINK/Verifying+a+Flink+Table+Store+Release
> > > [2]
> >
> https://dist.apache.org/repos/dist/dev/flink/flink-table-store-0.2.0-rc2/
> > > [3]
> > https://repository.apache.org/content/repositories/orgapacheflink-1523/
> > > [4] https://dist.apache.org/repos/dist/release/flink/KEYS
> > > [5]
> >
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351570
> > > [6] https://github.com/apache/flink-table-store/tree/release-0.2.0-rc2
> > > [7] https://github.com/apache/flink-web/pull/562
> > >
> >
>

Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

[Qingsheng Ren]

Congratulations Lijie!

Best regards,
Qingsheng

> On Aug 22, 2022, at 16:29, Yang Wang  wrote:
> 
> Congrats Lijie!
> 
> Best,
> Yang
> 
> Matthias Pohl  于2022年8月22日周一 15:34写道：
> 
>> Congrats & welcome to the team! :-)
>> 
>> Matthias
>> 
>> On Sun, Aug 21, 2022 at 5:41 AM Yuan Mei  wrote:
>> 
>>> Congratulations, Lijie!
>>> 
>>> Best,
>>> Yuan
>>> 
>>> On Sat, Aug 20, 2022 at 2:12 PM Danny Cranmer 
>>> wrote:
>>> 
 Congratulations Lijie! Welcome to the team.
 
 On Sat, 20 Aug 2022, 03:25 Yun Tang,  wrote:
 
> Congratulations, Lijie!
> 
> 
> Best
> Yun Tang
> 
> From: Geng Biao 
> Sent: Saturday, August 20, 2022 10:03
> To: dev@flink.apache.org 
> Subject: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> 
> Congratulations  Lijie!
> Best,
> Biao Geng
> 
> 获取 Outlook for iOS
> 
> 发件人: yuxia 
> 发送时间: Saturday, August 20, 2022 9:54:29 AM
> 收件人: dev 
> 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> 
> Congrats Lijie!
> 
> Best regards,
> Yuxia
> 
> - 原始邮件 -
> 发件人: "Aitozi" 
> 收件人: "dev" 
> 发送时间: 星期六, 2022年 8 月 20日 上午 12:19:27
> 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang
> 
> Congrats Lijie!
> 
> Best regards,
> Aitozi
> 
> Jing Ge  于2022年8月19日周五 06:02写道：
> 
>> Congrats Lijie!
>> 
>> Best regards,
>> Jing
>> 
>> On Thu, Aug 18, 2022 at 8:40 AM Terry Wang 
>>> wrote:
>> 
>>> Congratulations, Lijie!
>>> 
>>> On Thu, Aug 18, 2022 at 11:31 AM Leonard Xu 
 wrote:
>>> 
 Congratulations, Lijie!
 
 Best,
 Leonard
 
> 2022年8月18日 上午11:26，Zhipeng Zhang 
>> 写道：
> 
> Congratulations, Lijie!
> 
> Xintong Song  于2022年8月18日周四 11:23写道：
>> 
>> Congratulations Lijie, and welcome~!
>> 
>> Best,
>> 
>> Xintong
>> 
>> 
>> 
>> On Thu, Aug 18, 2022 at 11:12 AM Xingbo Huang <
 hxbks...@gmail.com
>> 
 wrote:
>> 
>>> Congrats, Lijie
>>> 
>>> Best,
>>> Xingbo
>>> 
>>> Lincoln Lee  于2022年8月18日周四
>> 11:01写道：
>>> 
 Congratulations, Lijie!
 
 Best,
 Lincoln Lee
 
 
 Benchao Li  于2022年8月18日周四 10:51写道：
 
> Congratulations Lijie!
> 
> yanfei lei  于2022年8月18日周四 10:44写道：
> 
>> Congratulations, Lijie!
>> 
>> Best,
>> Yanfei
>> 
>> JunRui Lee  于2022年8月18日周四 10:35写道：
>> 
>>> Congratulations, Lijie!
>>> 
>>> Best,
>>> JunRui
>>> 
>>> Timo Walther  于2022年8月17日周三
>> 19:30写道：
>>> 
 Congratulations and welcome to the committer team :-)
 
 Regards,
 Timo
 
 
 On 17.08.22 12:50, Yuxin Tan wrote:
> Congratulations, Lijie!
> 
> Best,
> Yuxin
> 
> 
> Guowei Ma  于2022年8月17日周三
>>> 18:42写道：
> 
>> Congratulations, Lijie. Welcome on board~!
>> Best,
>> Guowei
>> 
>> 
>> On Wed, Aug 17, 2022 at 6:25 PM Zhu Zhu <
 zh...@apache.org
>> 
 wrote:
>> 
>>> Hi everyone,
>>> 
>>> On behalf of the PMC, I'm very happy to announce
>>> Lijie
> Wang
>>> as
>>> a new Flink committer.
>>> 
>>> Lijie has been contributing to Flink project for
>> more
> than
>> 2
> years.
>>> He mainly works on the runtime/coordination part,
>>> doing
>>> feature
>>> development, problem debugging and code reviews. He
>>> has
>> also
>>> driven the work of FLIP-187(Adaptive Batch
>> Scheduler)
 and
>>> FLIP-224(Blocklist for Speculative Execution),
>> which
 are
> important
>>> to run batch jobs.
>>> 
>>> Please join me in congratulating Lijie for
>> becoming a
> Flink
>>> committer!
>>> 
>>> Cheers,
>>> Zhu
>>> 
>> 
> 
 
 
>>> 
>> 
> 
> 
> --
> 
> 

Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

[Qingsheng Ren]

Congratulations Junhan!

Best regards,
Qingsheng

> On Aug 22, 2022, at 16:30, Yang Wang  wrote:
> 
> Congrats Junhan!
> 
> 
> Best,
> Yang
> 
> Matthias Pohl  于2022年8月22日周一 15:35写道：
> 
>> Congratulations & welcome! :-)
>> 
>> Matthias
>> 
>> On Sun, Aug 21, 2022 at 5:42 AM Yuan Mei  wrote:
>> 
>>> Congratulations Junhan!
>>> 
>>> Best,
>>> Yuan
>>> 
>>> On Sat, Aug 20, 2022 at 2:11 PM Danny Cranmer 
>>> wrote:
>>> 
 Congratulations Junhan! Welcome to the team.
 
 On Sat, 20 Aug 2022, 03:01 yuxia,  wrote:
 
> Congratulations, Junhan!
> 
> Best regards,
> Yuxia
> 
> - 原始邮件 -
> 发件人: "Aitozi" 
> 收件人: "dev" 
> 发送时间: 星期六, 2022年 8 月 20日 上午 12:18:29
> 主题: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang
> 
> Congratulations, Junhan!
> Best,
> Aitozi
> 
> Guowei Ma  于2022年8月19日周五 13:18写道：
> 
>> Congratulations, Junhan!
>> Best,
>> Guowei
>> 
>> 
>> On Fri, Aug 19, 2022 at 6:01 AM Jing Ge 
>> wrote:
>> 
>>> Congrats Junhan!
>>> 
>>> Best regards,
>>> Jing
>>> 
>>> On Thu, Aug 18, 2022 at 12:05 PM Jark Wu 
>> wrote:
>>> 
 Congrats and welcome Junhan!
 
 Cheers,
 Jark
 
> 2022年8月18日 17:59，Timo Walther  写道：
> 
> Congratulations and welcome to the committer team :-)
> 
> Regards,
> Timo
> 
> On 18.08.22 07:19, Lijie Wang wrote:
>> Congratulations, Junhan!
>> Best,
>> Lijie
>> Leonard Xu  于2022年8月18日周四 11:31写道：
>>> Congratulations, Junhan!
>>> 
>>> Best,
>>> 
 2022年8月18日 上午11:27，Zhipeng Zhang >> 
 写道：
 
 Congratulations, Junhan!
 
 Xintong Song  于2022年8月18日周四 11:21写道：
> 
> Hi everyone,
> 
> On behalf of the PMC, I'm very happy to announce Junhan
>>> Yang
> as a
>>> new
>>> Flink
> committer.
> 
> Junhan has been contributing to the Flink project for
>> more
> than 1
 year.
>>> His
> contributions are mostly identified in the web frontend,
>> including
> FLIP-241, FLIP-249 and various maintenance efforts of
>>> Flink's
 frontend
> frameworks.
> 
> Please join me in congratulating Junhan for becoming a
>>> Flink
 committer!
> 
> Best,
> Xintong
 
 
 
 --
 best,
 Zhipeng
>>> 
>>> 
> 
 
 
>>> 
>> 
> 
 
>>> 
>>