[jira] [Created] (FLINK-19501) Missing state in enum type

2020-10-05 Thread goutham (Jira) 
goutham created FLINK-19501:
---

 Summary: Missing state in enum type
 Key: FLINK-19501
 URL: https://issues.apache.org/jira/browse/FLINK-19501
 Project: Flink
  Issue Type: Bug
  Components: API / Core
Affects Versions: 1.11.2
Reporter: goutham
 Fix For: 1.12.0


INITIALIZING state is missing for one of enums api snapshot document 

 

"enum" : [ "INITIALIZING", "CREATED", "RUNNING", "FAILING", "FAILED", 
"CANCELLING", "CANCELED", "FINISHED", "RESTARTING", "SUSPENDED", "RECONCILING" ]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-05 Thread Till Rohrmann 
Congrats and welcome Zhu Zhu!

Cheers,
Till

On Mon, Oct 5, 2020 at 7:32 AM Robert Metzger  wrote:

> Hi all!
>
> I'm very happy to announce that Zhu Zhu has joined the Flink PMC!
>
> Zhu is helping the community a lot with creating and validating releases,
> contributing to FLIP discussions and good code contributions to the
> scheduler and related components.
>
> Congratulations and welcome Zhu Zhu!
>
> Regards,
> Robert
>

Re: Dynamic Scaling: State Sharding

2020-10-05 Thread Till Rohrmann 
Hi Mazen,

Flink does not support automatic scaling yet. Hence, the recommended way is
to monitor a Flink job and to trigger rescaling by stopping the job with a
savepoint and then to resume it with the adjusted parallelism. The
community is working on auto scaling but there is no concrete date yet when
it will be available.

Cheers,
Till

On Mon, Oct 5, 2020 at 8:47 AM Mazen Ezzeddine 
wrote:

> So what is the state of dynamic scaling (non static, set by the user in the
> code) for SLA gurantees now, is it already included in FLink, and is it
> still necessaru to stop/restart the job for dynamic scaling.
>
> Thanks.
>
>
>
> --
> Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
>

Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-05 Thread Arvid Heise 
Congratulations Zhu Zhu!

On Mon, Oct 5, 2020 at 9:28 AM Till Rohrmann  wrote:

> Congrats and welcome Zhu Zhu!
>
> Cheers,
> Till
>
> On Mon, Oct 5, 2020 at 7:32 AM Robert Metzger  wrote:
>
> > Hi all!
> >
> > I'm very happy to announce that Zhu Zhu has joined the Flink PMC!
> >
> > Zhu is helping the community a lot with creating and validating releases,
> > contributing to FLIP discussions and good code contributions to the
> > scheduler and related components.
> >
> > Congratulations and welcome Zhu Zhu!
> >
> > Regards,
> > Robert
> >
>


-- 

Arvid Heise | Senior Java Developer



Follow us @VervericaData

--

Join Flink Forward  - The Apache Flink
Conference

Stream Processing | Event Driven | Real Time

--

Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany

--
Ververica GmbH
Registered at Amtsgericht Charlottenburg: HRB 158244 B
Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji
(Toni) Cheng

[jira] [Created] (FLINK-19502) Flink docker images: allow specifying arbitrary configuration values through environment

2020-10-05 Thread Julius Michaelis (Jira) 
Julius Michaelis created FLINK-19502:


 Summary: Flink docker images: allow specifying arbitrary 
configuration values through environment
 Key: FLINK-19502
 URL: https://issues.apache.org/jira/browse/FLINK-19502
 Project: Flink
  Issue Type: Bug
  Components: Deployment / Kubernetes
Reporter: Julius Michaelis
 Attachments: set_options_from_env.patch

It would be nice if arbitrary values in flink-conf.yaml could be overwritten 
from the environment, especially since this can be used to override config 
comfortably from kubernetes' kustomizations.

(The attached patch to https://github.com/apache/flink-docker achieves that. 
Should I go ahead and create a PR?)



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Re: [VOTE] Release flink-shaded 12.0

2020-10-05 Thread Chesnay Schepler 

+1

Checked signatures, license files, and that the listed changes are in 
the release.


On 9/30/2020 4:55 PM, Robert Metzger wrote:

Hi everyone,

Please review and vote on the release candidate #1 for the version 12.0, as
follows:

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


The complete staging area is available for your review, which includes:
* JIRA release notes [1],
* the official Apache source release to be deployed to dist.apache.org [2],
which are signed with the key with fingerprint D9839159 [3],
* all artifacts to be deployed to the Maven Central Repository [4],
* source code tag "release-12.0-rc1" [5],
* website pull request listing the new release [6].

The vote will be open for at least 72 hours. It is adopted by majority
approval, with at least 3 PMC affirmative votes.

Thanks,
Robert Metzger

[1]
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12348339
[2] https://dist.apache.org/repos/dist/dev/flink/flink-shaded-12.0-rc1/
[3] https://dist.apache.org/repos/dist/release/flink/KEYS
[4] https://repository.apache.org/content/repositories/orgapacheflink-1400
[5] https://github.com/apache/flink-shaded/releases/tag/release-12.0-rc1
[6] https://github.com/apache/flink-web/pull/380

Re: [VOTE] Release flink-shaded 12.0

2020-10-05 Thread Tzu-Li (Gordon) Tai 
+1

- Checked signatures
- Source archives contain no binaries
- Built from source (mvn clean verify)

Cheers,
Gordon

On Mon, Oct 5, 2020, 4:33 PM Chesnay Schepler  wrote:

> +1
>
> Checked signatures, license files, and that the listed changes are in
> the release.
>
> On 9/30/2020 4:55 PM, Robert Metzger wrote:
> > Hi everyone,
> >
> > Please review and vote on the release candidate #1 for the version 12.0,
> as
> > follows:
> >
> > [ ] +1, Approve the release
> > [ ] -1, Do not approve the release (please provide specific comments)
> >
> >
> > The complete staging area is available for your review, which includes:
> > * JIRA release notes [1],
> > * the official Apache source release to be deployed to dist.apache.org
> [2],
> > which are signed with the key with fingerprint D9839159 [3],
> > * all artifacts to be deployed to the Maven Central Repository [4],
> > * source code tag "release-12.0-rc1" [5],
> > * website pull request listing the new release [6].
> >
> > The vote will be open for at least 72 hours. It is adopted by majority
> > approval, with at least 3 PMC affirmative votes.
> >
> > Thanks,
> > Robert Metzger
> >
> > [1]
> >
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12348339
> > [2] https://dist.apache.org/repos/dist/dev/flink/flink-shaded-12.0-rc1/
> > [3] https://dist.apache.org/repos/dist/release/flink/KEYS
> > [4]
> https://repository.apache.org/content/repositories/orgapacheflink-1400
> > [5] https://github.com/apache/flink-shaded/releases/tag/release-12.0-rc1
> > [6] https://github.com/apache/flink-web/pull/380
> >
>
>

[jira] [Created] (FLINK-19503) Add DSTL interface and its in-memory implementation for testing

2020-10-05 Thread Roman Khachatryan (Jira) 
Roman Khachatryan created FLINK-19503:
-

 Summary: Add DSTL interface and its in-memory implementation for 
testing
 Key: FLINK-19503
 URL: https://issues.apache.org/jira/browse/FLINK-19503
 Project: Flink
  Issue Type: New Feature
  Components: Runtime / Checkpointing, Runtime / Task
Reporter: Roman Khachatryan
Assignee: Roman Khachatryan
 Fix For: 1.12.0


Durable Short-term Log is a proposed component to store state changes and later 
output.

The goal of this issue is to allow:
 # Integration with changes to the state backends
 # Implementation first production DSTL version

The code should include interfaces, test implementations, means to access from 
state backends, tests.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (FLINK-19504) Implement persistence for DSTL via DFS

2020-10-05 Thread Roman Khachatryan (Jira) 
Roman Khachatryan created FLINK-19504:
-

 Summary: Implement persistence for DSTL via DFS
 Key: FLINK-19504
 URL: https://issues.apache.org/jira/browse/FLINK-19504
 Project: Flink
  Issue Type: New Feature
  Components: Runtime / Checkpointing, Runtime / Task
Reporter: Roman Khachatryan
Assignee: Roman Khachatryan
 Fix For: 1.12.0


Durable Short-term Log is a proposed component to store state changes and later 
output.

The goal of this issue is to add a persistent version of FLINK-19503 (backed by 
DFS).

No scheduling and RPC.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (FLINK-19505) Implement distributed DSTL (DFS-based)

2020-10-05 Thread Roman Khachatryan (Jira) 
Roman Khachatryan created FLINK-19505:
-

 Summary: Implement distributed DSTL (DFS-based)
 Key: FLINK-19505
 URL: https://issues.apache.org/jira/browse/FLINK-19505
 Project: Flink
  Issue Type: New Feature
  Components: Runtime / Checkpointing, Runtime / Task
Reporter: Roman Khachatryan
Assignee: Roman Khachatryan
 Fix For: 1.12.0


Sub-tasks:
 # Implement scheduling and deployment (no rescaling)
 # Implement RPC between the tasks and DSTL (including load balancing)
 # Implement re-scaling
 # Implement filtering of records on replay to support up-scaling



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Re: [VOTE] Release flink-shaded 12.0

2020-10-05 Thread Robert Metzger 
+1

- Checked diffs between 1.11 and 1.12:
https://github.com/apache/flink-shaded/compare/release-11.0...release-12.0-rc1
- staging repository looks good


On Mon, Oct 5, 2020 at 11:12 AM Tzu-Li (Gordon) Tai 
wrote:

> +1
>
> - Checked signatures
> - Source archives contain no binaries
> - Built from source (mvn clean verify)
>
> Cheers,
> Gordon
>
> On Mon, Oct 5, 2020, 4:33 PM Chesnay Schepler  wrote:
>
>> +1
>>
>> Checked signatures, license files, and that the listed changes are in
>> the release.
>>
>> On 9/30/2020 4:55 PM, Robert Metzger wrote:
>> > Hi everyone,
>> >
>> > Please review and vote on the release candidate #1 for the version
>> 12.0, as
>> > follows:
>> >
>> > [ ] +1, Approve the release
>> > [ ] -1, Do not approve the release (please provide specific comments)
>> >
>> >
>> > The complete staging area is available for your review, which includes:
>> > * JIRA release notes [1],
>> > * the official Apache source release to be deployed to dist.apache.org
>> [2],
>> > which are signed with the key with fingerprint D9839159 [3],
>> > * all artifacts to be deployed to the Maven Central Repository [4],
>> > * source code tag "release-12.0-rc1" [5],
>> > * website pull request listing the new release [6].
>> >
>> > The vote will be open for at least 72 hours. It is adopted by majority
>> > approval, with at least 3 PMC affirmative votes.
>> >
>> > Thanks,
>> > Robert Metzger
>> >
>> > [1]
>> >
>> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12348339
>> > [2] https://dist.apache.org/repos/dist/dev/flink/flink-shaded-12.0-rc1/
>> > [3] https://dist.apache.org/repos/dist/release/flink/KEYS
>> > [4]
>> https://repository.apache.org/content/repositories/orgapacheflink-1400
>> > [5]
>> https://github.com/apache/flink-shaded/releases/tag/release-12.0-rc1
>> > [6] https://github.com/apache/flink-web/pull/380
>> >
>>
>>

Re: [VOTE] FLIP-144: Native Kubernetes HA for Flink

2020-10-05 Thread Xintong Song 
+1 (binding)

Thank you~

Xintong Song



On Sun, Oct 4, 2020 at 8:14 PM tison  wrote:

> +1
>
> Best,
> tison.
>
>
> Till Rohrmann  于2020年10月2日周五 下午6:27写道：
>
> > +1 (binding)
> >
> > Cheers,
> > Till
> >
> > On Fri, Oct 2, 2020 at 3:13 AM Yang Wang  wrote:
> >
> > >  Hi, all
> > >
> > >
> > > After the discussion in [1], I would like to open a voting thread for
> > > FLIP-144 [2],
> > > which proposes to add a new native Kubernetes HA service.
> > >
> > >
> > > The vote will be open until October 6th (72h + weekend), unless there
> is
> > > an objection or not enough votes.
> > >
> > >
> > > [1].
> > >
> > >
> >
> https://lists.apache.org/thread.html/r466ad059dda1276fba4fa9a710cbfdfeab6b8a24c4047c6ed5d619e8%40%3Cdev.flink.apache.org%3E
> > > [2].
> > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-144%3A+Native+Kubernetes+HA+for+Flink
> > >
> > >
> > > Best,
> > > Yang
> > >
> >
>

Re: Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-05 Thread Yun Gao 
Congratulations Zhu!

Best,
Yun--
Sender:Arvid Heise
Date:2020/10/05 15:53:01
Recipient:dev
Cc:
Theme:Re: [ANNOUNCE] New PMC member: Zhu Zhu

Congratulations Zhu Zhu!

On Mon, Oct 5, 2020 at 9:28 AM Till Rohrmann  wrote:

> Congrats and welcome Zhu Zhu!
>
> Cheers,
> Till
>
> On Mon, Oct 5, 2020 at 7:32 AM Robert Metzger  wrote:
>
> > Hi all!
> >
> > I'm very happy to announce that Zhu Zhu has joined the Flink PMC!
> >
> > Zhu is helping the community a lot with creating and validating releases,
> > contributing to FLIP discussions and good code contributions to the
> > scheduler and related components.
> >
> > Congratulations and welcome Zhu Zhu!
> >
> > Regards,
> > Robert
> >
>


-- 

Arvid Heise | Senior Java Developer



Follow us @VervericaData

--

Join Flink Forward  - The Apache Flink
Conference

Stream Processing | Event Driven | Real Time

--

Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany

--
Ververica GmbH
Registered at Amtsgericht Charlottenburg: HRB 158244 B
Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji
(Toni) Cheng

[jira] [Created] (FLINK-19506) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonParallelLocalChannel: "Exceeded checkpoint tolerable failure threshold"

2020-10-05 Thread Robert Metzger (Jira) 
Robert Metzger created FLINK-19506:
--

 Summary: 
UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonParallelLocalChannel:
 "Exceeded checkpoint tolerable failure threshold"
 Key: FLINK-19506
 URL: https://issues.apache.org/jira/browse/FLINK-19506
 Project: Flink
  Issue Type: Bug
  Components: Runtime / Checkpointing
Affects Versions: 1.12.0
Reporter: Robert Metzger


https://dev.azure.com/rmetzger/Flink/_build/results?buildId=8433&view=logs&j=584fa981-f71a-5840-1c49-f800c954fe4b&t=532bf1f8-8c75-59c3-eaad-8c773769bc3a

{code}
2020-10-05T12:30:11.4979736Z [ERROR] Tests run: 6, Failures: 0, Errors: 1, 
Skipped: 0, Time elapsed: 97.533 s <<< FAILURE! - in 
org.apache.flink.test.checkpointing.UnalignedCheckpointITCase
2020-10-05T12:30:11.4980464Z [ERROR] 
shouldPerformUnalignedCheckpointOnNonParallelLocalChannel(org.apache.flink.test.checkpointing.UnalignedCheckpointITCase)
  Time elapsed: 32.406 s  <<< ERROR!
2020-10-05T12:30:11.4980971Z 
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2020-10-05T12:30:11.4988360Zat 
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
2020-10-05T12:30:11.4989659Zat 
org.apache.flink.client.program.PerJobMiniClusterFactory$PerJobMiniClusterJobClient.lambda$getJobExecutionResult$2(PerJobMiniClusterFactory.java:196)
2020-10-05T12:30:11.4990584Zat 
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2020-10-05T12:30:11.4991620Zat 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2020-10-05T12:30:11.499Zat 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2020-10-05T12:30:11.4992654Zat 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2020-10-05T12:30:11.4993153Zat 
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:229)
2020-10-05T12:30:11.4993661Zat 
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2020-10-05T12:30:11.4994133Zat 
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2020-10-05T12:30:11.4994590Zat 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2020-10-05T12:30:11.4995201Zat 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2020-10-05T12:30:11.4995781Zat 
org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:926)
2020-10-05T12:30:11.4996228Zat 
akka.dispatch.OnComplete.internal(Future.scala:264)
2020-10-05T12:30:11.4996985Zat 
akka.dispatch.OnComplete.internal(Future.scala:261)
2020-10-05T12:30:11.4997419Zat 
akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
2020-10-05T12:30:11.4997855Zat 
akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
2020-10-05T12:30:11.4998312Zat 
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2020-10-05T12:30:11.4998951Zat 
org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74)
2020-10-05T12:30:11.4999477Zat 
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
2020-10-05T12:30:11.548Zat 
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
2020-10-05T12:30:11.5000504Zat 
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
2020-10-05T12:30:11.5000984Zat 
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
2020-10-05T12:30:11.5001567Zat 
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
2020-10-05T12:30:11.5002091Zat 
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
2020-10-05T12:30:11.5002534Zat 
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
2020-10-05T12:30:11.5002976Zat 
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
2020-10-05T12:30:11.5003460Zat 
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
2020-10-05T12:30:11.5004015Zat 
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
2020-10-05T12:30:11.5004603Zat 
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
2020-10-05T12:30:11.5005173Zat 
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
2020-10-05T12:30:11.5005677Zat 
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
2020-10-05T12:30:11.5006170Zat 
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
2020-10-05T12:30:11.5006644Zat 
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
2020-10-05T12:30:

[jira] [Created] (FLINK-19507) Native support for Apache Pulsar

2020-10-05 Thread John Morrow (Jira) 
John Morrow created FLINK-19507:
---

 Summary: Native support for Apache Pulsar
 Key: FLINK-19507
 URL: https://issues.apache.org/jira/browse/FLINK-19507
 Project: Flink
  Issue Type: Wish
  Components: Stateful Functions
Affects Versions: statefun-2.2.0
Reporter: John Morrow


Flink StateFun has a sink/source IO module which can be used to plug in 
existing, or custom, Flink connectors that are not already integrated into a 
dedicated I/O module 
([https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/io-module/flink-connectors.html|https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/io-module/flink-connectors.html).]).

Currently there are dedicated I/O modules for Apache Kafka and AWS Kinesis. It 
would be nice to add a similar one for Apache Pulsar.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[RESULT][VOTE] Release flink-shaded 12.0

2020-10-05 Thread Robert Metzger 
Thank you all for voting. The wait time has passed.

We have the following binding +1 votes:
- Chesnay
- Gordon
- Robert

There were no -1 votes.

I'll proceed with releasing flink-shaded 12.0.

On Mon, Oct 5, 2020 at 1:57 PM Robert Metzger  wrote:

> +1
>
> - Checked diffs between 1.11 and 1.12:
> https://github.com/apache/flink-shaded/compare/release-11.0...release-12.0-rc1
> - staging repository looks good
>
>
> On Mon, Oct 5, 2020 at 11:12 AM Tzu-Li (Gordon) Tai 
> wrote:
>
>> +1
>>
>> - Checked signatures
>> - Source archives contain no binaries
>> - Built from source (mvn clean verify)
>>
>> Cheers,
>> Gordon
>>
>> On Mon, Oct 5, 2020, 4:33 PM Chesnay Schepler  wrote:
>>
>>> +1
>>>
>>> Checked signatures, license files, and that the listed changes are in
>>> the release.
>>>
>>> On 9/30/2020 4:55 PM, Robert Metzger wrote:
>>> > Hi everyone,
>>> >
>>> > Please review and vote on the release candidate #1 for the version
>>> 12.0, as
>>> > follows:
>>> >
>>> > [ ] +1, Approve the release
>>> > [ ] -1, Do not approve the release (please provide specific comments)
>>> >
>>> >
>>> > The complete staging area is available for your review, which includes:
>>> > * JIRA release notes [1],
>>> > * the official Apache source release to be deployed to dist.apache.org
>>> [2],
>>> > which are signed with the key with fingerprint D9839159 [3],
>>> > * all artifacts to be deployed to the Maven Central Repository [4],
>>> > * source code tag "release-12.0-rc1" [5],
>>> > * website pull request listing the new release [6].
>>> >
>>> > The vote will be open for at least 72 hours. It is adopted by majority
>>> > approval, with at least 3 PMC affirmative votes.
>>> >
>>> > Thanks,
>>> > Robert Metzger
>>> >
>>> > [1]
>>> >
>>> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12348339
>>> > [2]
>>> https://dist.apache.org/repos/dist/dev/flink/flink-shaded-12.0-rc1/
>>> > [3] https://dist.apache.org/repos/dist/release/flink/KEYS
>>> > [4]
>>> https://repository.apache.org/content/repositories/orgapacheflink-1400
>>> > [5]
>>> https://github.com/apache/flink-shaded/releases/tag/release-12.0-rc1
>>> > [6] https://github.com/apache/flink-web/pull/380
>>> >
>>>
>>>

Re: Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-05 Thread Fabian Hueske 
Congrats and welcome Zhu!

Best, Fabian

Am Mo., 5. Okt. 2020 um 14:33 Uhr schrieb Yun Gao
:

> Congratulations Zhu!
>
> Best,
> Yun--
> Sender:Arvid Heise
> Date:2020/10/05 15:53:01
> Recipient:dev
> Cc:
> Theme:Re: [ANNOUNCE] New PMC member: Zhu Zhu
>
> Congratulations Zhu Zhu!
>
> On Mon, Oct 5, 2020 at 9:28 AM Till Rohrmann  wrote:
>
> > Congrats and welcome Zhu Zhu!
> >
> > Cheers,
> > Till
> >
> > On Mon, Oct 5, 2020 at 7:32 AM Robert Metzger 
> wrote:
> >
> > > Hi all!
> > >
> > > I'm very happy to announce that Zhu Zhu has joined the Flink PMC!
> > >
> > > Zhu is helping the community a lot with creating and validating
> releases,
> > > contributing to FLIP discussions and good code contributions to the
> > > scheduler and related components.
> > >
> > > Congratulations and welcome Zhu Zhu!
> > >
> > > Regards,
> > > Robert
> > >
> >
>
>
> --
>
> Arvid Heise | Senior Java Developer
>
> 
>
> Follow us @VervericaData
>
> --
>
> Join Flink Forward  - The Apache Flink
> Conference
>
> Stream Processing | Event Driven | Real Time
>
> --
>
> Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany
>
> --
> Ververica GmbH
> Registered at Amtsgericht Charlottenburg: HRB 158244 B
> Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji
> (Toni) Cheng
>
>

Re: Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-05 Thread Guowei Ma 
Congratulations Zhu Zhu!
Best,
Guowei


On Tue, Oct 6, 2020 at 5:47 AM Fabian Hueske  wrote:

> Congrats and welcome Zhu!
>
> Best, Fabian
>
> Am Mo., 5. Okt. 2020 um 14:33 Uhr schrieb Yun Gao
> :
>
> > Congratulations Zhu!
> >
> > Best,
> > Yun--
> > Sender:Arvid Heise
> > Date:2020/10/05 15:53:01
> > Recipient:dev
> > Cc:
> > Theme:Re: [ANNOUNCE] New PMC member: Zhu Zhu
> >
> > Congratulations Zhu Zhu!
> >
> > On Mon, Oct 5, 2020 at 9:28 AM Till Rohrmann 
> wrote:
> >
> > > Congrats and welcome Zhu Zhu!
> > >
> > > Cheers,
> > > Till
> > >
> > > On Mon, Oct 5, 2020 at 7:32 AM Robert Metzger 
> > wrote:
> > >
> > > > Hi all!
> > > >
> > > > I'm very happy to announce that Zhu Zhu has joined the Flink PMC!
> > > >
> > > > Zhu is helping the community a lot with creating and validating
> > releases,
> > > > contributing to FLIP discussions and good code contributions to the
> > > > scheduler and related components.
> > > >
> > > > Congratulations and welcome Zhu Zhu!
> > > >
> > > > Regards,
> > > > Robert
> > > >
> > >
> >
> >
> > --
> >
> > Arvid Heise | Senior Java Developer
> >
> > 
> >
> > Follow us @VervericaData
> >
> > --
> >
> > Join Flink Forward  - The Apache Flink
> > Conference
> >
> > Stream Processing | Event Driven | Real Time
> >
> > --
> >
> > Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany
> >
> > --
> > Ververica GmbH
> > Registered at Amtsgericht Charlottenburg: HRB 158244 B
> > Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji
> > (Toni) Cheng
> >
> >
>

Re: [VOTE] FLIP-143: Unified Sink API

2020-10-05 Thread Guowei Ma 
I have to correct the vote result as following:

There were 5 votes, 3 of which are binding:

- Aljoscha Krettek (binding)
- Steven Wu
- Kostas Kloudas (binding)
- Jingsong Li (binding)
- Jiangang Liu

Changes still have been accepted.

Sorry to disturb everyone!

Best,
Guowei


On Wed, Sep 30, 2020 at 10:11 AM Guowei Ma  wrote:

> Hi all,
>
> The voting time for FLIP-143 [1] has passed. I'm closing the vote now.
>
> There were 5 votes, 4 of which are binding:
>
> - Aljoscha Krettek (binding)
> - Steven Wu
> - Kostas Kloudas (binding)
> - Jingsong Li (binding)
> - Jiangang Liu (binding)
>
> There were no -1 votes.
>
> Thus, changes have been accepted. I'll update the FLIP doc accordingly.
>
> There is still a discussion about the `CommitResult/GlobaCommitter
> interface, which we could do more discussion at the implementation phase.
>
> Thanks everyone for participating and discussing
>
> [1] https://cwiki.apache.org/confluence/x/KEJ4CQ
>
> Best,
> Guowei
>
>
> On Tue, Sep 29, 2020 at 6:32 PM 刘建刚  wrote:
>
>> +1 (binding)
>>
>> Best,
>> Liu Jiangang
>>
>> Jingsong Li  于2020年9月29日周二 下午1:36写道：
>>
>> > +1 (binding)
>> >
>> > Best,
>> > Jingsong
>> >
>> > On Mon, Sep 28, 2020 at 3:21 AM Kostas Kloudas 
>> wrote:
>> >
>> > > +1 (binding)
>> > >
>> > > @Steven Wu I think there will be opportunities to fine tune the API
>> > > during the implementation.
>> > >
>> > > Cheers,
>> > > Kostas
>> > >
>> > > On Sun, Sep 27, 2020 at 7:56 PM Steven Wu 
>> wrote:
>> > > >
>> > > > +1 (non-binding)
>> > > >
>> > > > Although I would love to continue the discussion for tweaking the
>> > > > CommitResult/GlobaCommitter interface maybe during the
>> implementation
>> > > phase.
>> > > >
>> > > > On Fri, Sep 25, 2020 at 5:35 AM Aljoscha Krettek <
>> aljos...@apache.org>
>> > > > wrote:
>> > > >
>> > > > > +1 (binding)
>> > > > >
>> > > > > Aljoscha
>> > > > >
>> > > > > On 25.09.20 14:26, Guowei Ma wrote:
>> > > > > >  From the discussion[1] we could find that FLIP focuses on
>> > providing
>> > > an
>> > > > > > unified transactional sink API. So I updated the FLIP's title to
>> > > "Unified
>> > > > > > Transactional Sink API". But I found that the old link could
>> not be
>> > > > > opened
>> > > > > > again.
>> > > > > >
>> > > > > > I would update the link[2] here. Sorry for the inconvenience.
>> > > > > >
>> > > > > > [1]
>> > > > > >
>> > > > >
>> > >
>> >
>> https://lists.apache.org/thread.html/rf09dfeeaf35da5ee98afe559b5a6e955c9f03ade0262727f6b5c4c1e%40%3Cdev.flink.apache.org%3E
>> > > > > > [2] https://cwiki.apache.org/confluence/x/KEJ4CQ
>> > > > > >
>> > > > > > Best,
>> > > > > > Guowei
>> > > > > >
>> > > > > >
>> > > > > > On Thu, Sep 24, 2020 at 8:13 PM Guowei Ma > >
>> > > wrote:
>> > > > > >
>> > > > > >> Hi, all
>> > > > > >>
>> > > > > >> After the discussion in [1], I would like to open a voting
>> thread
>> > > for
>> > > > > >> FLIP-143 [2], which proposes a unified sink api.
>> > > > > >>
>> > > > > >> The vote will be open until September 29th (72h + weekend),
>> unless
>> > > there
>> > > > > >> is an objection or not enough votes.
>> > > > > >>
>> > > > > >> [1]
>> > > > > >>
>> > > > >
>> > >
>> >
>> https://lists.apache.org/thread.html/rf09dfeeaf35da5ee98afe559b5a6e955c9f03ade0262727f6b5c4c1e%40%3Cdev.flink.apache.org%3E
>> > > > > >> [2]
>> > > > > >>
>> > > > >
>> > >
>> >
>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-143%3A+Unified+Sink+API
>> > > > > >>
>> > > > > >> Best,
>> > > > > >> Guowei
>> > > > > >>
>> > > > > >
>> > > > >
>> > > > >
>> > >
>> >
>> >
>> > --
>> > Best, Jingsong Lee
>> >
>>
>

Re: Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-05 Thread Yu Li 
Congrats and welcome, Zhu Zhu!

Best Regards,
Yu


On Tue, 6 Oct 2020 at 11:45, Guowei Ma  wrote:

> Congratulations Zhu Zhu!
> Best,
> Guowei
>
>
> On Tue, Oct 6, 2020 at 5:47 AM Fabian Hueske  wrote:
>
> > Congrats and welcome Zhu!
> >
> > Best, Fabian
> >
> > Am Mo., 5. Okt. 2020 um 14:33 Uhr schrieb Yun Gao
> > :
> >
> > > Congratulations Zhu!
> > >
> > > Best,
> > > Yun--
> > > Sender:Arvid Heise
> > > Date:2020/10/05 15:53:01
> > > Recipient:dev
> > > Cc:
> > > Theme:Re: [ANNOUNCE] New PMC member: Zhu Zhu
> > >
> > > Congratulations Zhu Zhu!
> > >
> > > On Mon, Oct 5, 2020 at 9:28 AM Till Rohrmann 
> > wrote:
> > >
> > > > Congrats and welcome Zhu Zhu!
> > > >
> > > > Cheers,
> > > > Till
> > > >
> > > > On Mon, Oct 5, 2020 at 7:32 AM Robert Metzger 
> > > wrote:
> > > >
> > > > > Hi all!
> > > > >
> > > > > I'm very happy to announce that Zhu Zhu has joined the Flink PMC!
> > > > >
> > > > > Zhu is helping the community a lot with creating and validating
> > > releases,
> > > > > contributing to FLIP discussions and good code contributions to the
> > > > > scheduler and related components.
> > > > >
> > > > > Congratulations and welcome Zhu Zhu!
> > > > >
> > > > > Regards,
> > > > > Robert
> > > > >
> > > >
> > >
> > >
> > > --
> > >
> > > Arvid Heise | Senior Java Developer
> > >
> > > 
> > >
> > > Follow us @VervericaData
> > >
> > > --
> > >
> > > Join Flink Forward  - The Apache Flink
> > > Conference
> > >
> > > Stream Processing | Event Driven | Real Time
> > >
> > > --
> > >
> > > Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany
> > >
> > > --
> > > Ververica GmbH
> > > Registered at Amtsgericht Charlottenburg: HRB 158244 B
> > > Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji
> > > (Toni) Cheng
> > >
> > >
> >
>

Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-05 Thread Dian Fu 
Congratulations Zhu Zhu!

Regards,
Dian

> 在 2020年10月6日，下午12:05，Yu Li  写道：
> 
> Congrats and welcome, Zhu Zhu!
> 
> Best Regards,
> Yu
> 
> 
> On Tue, 6 Oct 2020 at 11:45, Guowei Ma  wrote:
> 
>> Congratulations Zhu Zhu!
>> Best,
>> Guowei
>> 
>> 
>> On Tue, Oct 6, 2020 at 5:47 AM Fabian Hueske  wrote:
>> 
>>> Congrats and welcome Zhu!
>>> 
>>> Best, Fabian
>>> 
>>> Am Mo., 5. Okt. 2020 um 14:33 Uhr schrieb Yun Gao
>>> :
>>> 
 Congratulations Zhu!
 
 Best,
 Yun--
 Sender:Arvid Heise
 Date:2020/10/05 15:53:01
 Recipient:dev
 Cc:
 Theme:Re: [ANNOUNCE] New PMC member: Zhu Zhu
 
 Congratulations Zhu Zhu!
 
 On Mon, Oct 5, 2020 at 9:28 AM Till Rohrmann 
>>> wrote:
 
> Congrats and welcome Zhu Zhu!
> 
> Cheers,
> Till
> 
> On Mon, Oct 5, 2020 at 7:32 AM Robert Metzger 
 wrote:
> 
>> Hi all!
>> 
>> I'm very happy to announce that Zhu Zhu has joined the Flink PMC!
>> 
>> Zhu is helping the community a lot with creating and validating
 releases,
>> contributing to FLIP discussions and good code contributions to the
>> scheduler and related components.
>> 
>> Congratulations and welcome Zhu Zhu!
>> 
>> Regards,
>> Robert
>> 
> 
 
 
 --
 
 Arvid Heise | Senior Java Developer
 
 
 
 Follow us @VervericaData
 
 --
 
 Join Flink Forward  - The Apache Flink
 Conference
 
 Stream Processing | Event Driven | Real Time
 
 --
 
 Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany
 
 --
 Ververica GmbH
 Registered at Amtsgericht Charlottenburg: HRB 158244 B
 Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji
 (Toni) Cheng
 
 
>>> 
>>

Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-05 Thread Yuan Mei 
Congrats, Zhu Zhu :-)

Best
Yuan

On Tue, Oct 6, 2020 at 1:54 PM Dian Fu  wrote:

> Congratulations Zhu Zhu!
>
> Regards,
> Dian
>
> > 在 2020年10月6日，下午12:05，Yu Li  写道：
> >
> > Congrats and welcome, Zhu Zhu!
> >
> > Best Regards,
> > Yu
> >
> >
> > On Tue, 6 Oct 2020 at 11:45, Guowei Ma  wrote:
> >
> >> Congratulations Zhu Zhu!
> >> Best,
> >> Guowei
> >>
> >>
> >> On Tue, Oct 6, 2020 at 5:47 AM Fabian Hueske  wrote:
> >>
> >>> Congrats and welcome Zhu!
> >>>
> >>> Best, Fabian
> >>>
> >>> Am Mo., 5. Okt. 2020 um 14:33 Uhr schrieb Yun Gao
> >>> :
> >>>
>  Congratulations Zhu!
> 
>  Best,
>  Yun--
>  Sender:Arvid Heise
>  Date:2020/10/05 15:53:01
>  Recipient:dev
>  Cc:
>  Theme:Re: [ANNOUNCE] New PMC member: Zhu Zhu
> 
>  Congratulations Zhu Zhu!
> 
>  On Mon, Oct 5, 2020 at 9:28 AM Till Rohrmann 
> >>> wrote:
> 
> > Congrats and welcome Zhu Zhu!
> >
> > Cheers,
> > Till
> >
> > On Mon, Oct 5, 2020 at 7:32 AM Robert Metzger 
>  wrote:
> >
> >> Hi all!
> >>
> >> I'm very happy to announce that Zhu Zhu has joined the Flink PMC!
> >>
> >> Zhu is helping the community a lot with creating and validating
>  releases,
> >> contributing to FLIP discussions and good code contributions to the
> >> scheduler and related components.
> >>
> >> Congratulations and welcome Zhu Zhu!
> >>
> >> Regards,
> >> Robert
> >>
> >
> 
> 
>  --
> 
>  Arvid Heise | Senior Java Developer
> 
>  
> 
>  Follow us @VervericaData
> 
>  --
> 
>  Join Flink Forward  - The Apache Flink
>  Conference
> 
>  Stream Processing | Event Driven | Real Time
> 
>  --
> 
>  Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany
> 
>  --
>  Ververica GmbH
>  Registered at Amtsgericht Charlottenburg: HRB 158244 B
>  Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason,
> Ji
>  (Toni) Cheng
> 
> 
> >>>
> >>
>
>