Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-21 Thread Xintong Song
Congrats, Rui~! Thank you~ Xintong Song On Thu, Apr 22, 2021 at 11:52 AM Yun Gao wrote: > Congratulations Rui! > > Best, > Yun > > > -- > Sender:Nicholas Jiang > Date:2021/04/22 11:26:05 > Recipient: > Theme:Re: [ANNOUNCE] New

Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-21 Thread Yun Gao
Congratulations Rui! Best, Yun -- Sender:Nicholas Jiang Date:2021/04/22 11:26:05 Recipient: Theme:Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Congrats, Rui! Best, Nicholas Jiang -- Sent from:

Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-21 Thread Nicholas Jiang
Congrats, Rui! Best, Nicholas Jiang -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-21 Thread Paul Lam
Congrats, Rui! Well deserved. Best, Paul Lam > 2021年4月22日 11:20,Jark Wu 写道: > > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Rui Li as a new Flink > committer. > > Rui Li has been a very active contributor for more than two year, with 180+ > PRs and > more than 68,771

[ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-21 Thread Jark Wu
Hi everyone, On behalf of the PMC, I'm very happy to announce Rui Li as a new Flink committer. Rui Li has been a very active contributor for more than two year, with 180+ PRs and more than 68,771 lines and many PR reviews which is quite outstanding. Rui has paid essential effort on Flink + Hive

Re: [jira] [Created] (FLINK-22401) Python tests fail with "Slot ... is not allocated by job ..."

2021-04-21 Thread 火中琵琶
hi, can you share your parameters about the tm slots and job parallelism? best wishes liang ---Original--- From: "Dawid Wysakowicz (Jira)"https://issues.apache.org/jira/browse/FLINK-22401 Project: Flink Issue Type: Bug Components: API /

Re: [DISCUSS] Merge StreamTableEnvironment.to/fromChangelogStream to release-1.13

2021-04-21 Thread Arvid Heise
+1 from my side. The transition between DataStream and Table should be as smooth as possible. On Wed, Apr 21, 2021 at 5:00 PM Timo Walther wrote: > Thanks for the feedback. > > @Dawid: It should be merged by tomorrow. It has been reviewed already. I > will just wait a few hours to let this

Re: Task Local Recovery with mountable disks in the cloud

2021-04-21 Thread Stephan Ewen
/cc dev@flink On Tue, Apr 20, 2021 at 1:29 AM Sonam Mandal wrote: > Hello, > > We've been experimenting with Task-local recovery using Kubernetes. We > have a way to specify mounting the same disk across Task Manager > restarts/deletions for when the pods get recreated. In this scenario, we >

[jira] [Created] (FLINK-22401) Python tests fail with "Slot ... is not allocated by job ..."

2021-04-21 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22401: Summary: Python tests fail with "Slot ... is not allocated by job ..." Key: FLINK-22401 URL: https://issues.apache.org/jira/browse/FLINK-22401 Project: Flink

[jira] [Created] (FLINK-22400) NPE problem when call HiveInspectors.toFlinkObject for hive-exec 2.0.0

2021-04-21 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-22400: - Summary: NPE problem when call HiveInspectors.toFlinkObject for hive-exec 2.0.0 Key: FLINK-22400 URL: https://issues.apache.org/jira/browse/FLINK-22400 Project: Flink

Re: [DISCUSS] Merge StreamTableEnvironment.to/fromChangelogStream to release-1.13

2021-04-21 Thread Timo Walther
Thanks for the feedback. @Dawid: It should be merged by tomorrow. It has been reviewed already. I will just wait a few hours to let this discussion settle. Regards, Timo On 21.04.21 14:14, Jark Wu wrote: I also think this is an attractive feature which exposes Flink's CDC engine to wider

[jira] [Created] (FLINK-22399) KinesisTableApiITCase times out

2021-04-21 Thread Matthias (Jira)
Matthias created FLINK-22399: Summary: KinesisTableApiITCase times out Key: FLINK-22399 URL: https://issues.apache.org/jira/browse/FLINK-22399 Project: Flink Issue Type: Bug

Re: [DISCUSS] Merge StreamTableEnvironment.to/fromChangelogStream to release-1.13

2021-04-21 Thread Jark Wu
I also think this is an attractive feature which exposes Flink's CDC engine to wider users and wider usage scenarios. I'm also fine with merging it to release 1.13. Best, Jark On Wed, 21 Apr 2021 at 17:00, Dawid Wysakowicz wrote: > Hi Timo, > > First of all, thanks for giving a good example of

[jira] [Created] (FLINK-22398) The code comments in InputOutputFormatVertex are incorrect

2021-04-21 Thread Li (Jira)
Li created FLINK-22398: -- Summary: The code comments in InputOutputFormatVertex are incorrect Key: FLINK-22398 URL: https://issues.apache.org/jira/browse/FLINK-22398 Project: Flink Issue Type:

[jira] [Created] (FLINK-22397) OrcFileSystemITCase fails on Azure

2021-04-21 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22397: Summary: OrcFileSystemITCase fails on Azure Key: FLINK-22397 URL: https://issues.apache.org/jira/browse/FLINK-22397 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22396) Unnecessary entries in sql hbase-1.4 connector NOTICE file

2021-04-21 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22396: Summary: Unnecessary entries in sql hbase-1.4 connector NOTICE file Key: FLINK-22396 URL: https://issues.apache.org/jira/browse/FLINK-22396 Project: Flink

来自窦永鹏的邮件

2021-04-21 Thread 窦永鹏
退订

[jira] [Created] (FLINK-22395) Extend RetryRule to allow class-wide defaults

2021-04-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22395: Summary: Extend RetryRule to allow class-wide defaults Key: FLINK-22395 URL: https://issues.apache.org/jira/browse/FLINK-22395 Project: Flink Issue

[jira] [Created] (FLINK-22394) Auto Close issues with resolution "Auto Closed" instead of "Fixed"

2021-04-21 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22394: Summary: Auto Close issues with resolution "Auto Closed" instead of "Fixed" Key: FLINK-22394 URL: https://issues.apache.org/jira/browse/FLINK-22394 Project:

Re: [DISCUSS] Merge StreamTableEnvironment.to/fromChangelogStream to release-1.13

2021-04-21 Thread Dawid Wysakowicz
Hi Timo, First of all, thanks for giving a good example of following the community agreements ;) Do you have an ETA for when the feature can be merged? Given that as you are saying, it mostly about adding a new API that would be marked as experimental and is rather well isolated from the rest

[jira] [Created] (FLINK-22393) Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

2021-04-21 Thread Jianzhang Chen (Jira)
Jianzhang Chen created FLINK-22393: -- Summary: Translate the page of "Execution Mode (Batch/Streaming)" into Chinese Key: FLINK-22393 URL: https://issues.apache.org/jira/browse/FLINK-22393 Project:

[DISCUSS] Merge StreamTableEnvironment.to/fromChangelogStream to release-1.13

2021-04-21 Thread Timo Walther
Hi everyone, sorry for being so late with this request, but fixing a couple of down stream bugs had higher priority than this issue and were also blocking it. Nevertheless, I would like to ask for permission to merge the FLINK-19980[1] to the 1.13 branch as an experimental feature to add the

[jira] [Created] (FLINK-22392) Check 1.13 licensing

2021-04-21 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22392: Summary: Check 1.13 licensing Key: FLINK-22392 URL: https://issues.apache.org/jira/browse/FLINK-22392 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-22391) Support State Introspection

2021-04-21 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22391: Summary: Support State Introspection Key: FLINK-22391 URL: https://issues.apache.org/jira/browse/FLINK-22391 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-22390) Support for OpenTracing

2021-04-21 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22390: Summary: Support for OpenTracing Key: FLINK-22390 URL: https://issues.apache.org/jira/browse/FLINK-22390 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-22389) Expose Message Batches to SDKs

2021-04-21 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22389: Summary: Expose Message Batches to SDKs Key: FLINK-22389 URL: https://issues.apache.org/jira/browse/FLINK-22389 Project: Flink Issue Type: New

[jira] [Created] (FLINK-22388) KafkaITCase.testMetricsAndEndOfStream times out on topic creation

2021-04-21 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22388: Summary: KafkaITCase.testMetricsAndEndOfStream times out on topic creation Key: FLINK-22388 URL: https://issues.apache.org/jira/browse/FLINK-22388 Project:

[jira] [Created] (FLINK-22387) UpsertKafkaTableITCase hangs

2021-04-21 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22387: Summary: UpsertKafkaTableITCase hangs Key: FLINK-22387 URL: https://issues.apache.org/jira/browse/FLINK-22387 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22386) Introduce cache for docker images

2021-04-21 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22386: Summary: Introduce cache for docker images Key: FLINK-22386 URL: https://issues.apache.org/jira/browse/FLINK-22386 Project: Flink Issue Type: Task