Re: [Flink-9407] Question about proposed ORC Sink !

2018-06-22 Thread zhangminglei
Yes, it should be exit. Thanks to Ted Yu. Very exactly! Cheers Zhangminglei > 在 2018年6月23日,下午12:40,Ted Yu 写道: > > For #1, the word exist should be exit, right ? > Thanks > > Original message > From: zhangminglei <18717838...@163.com> > Date: 6/23/18 10:12 AM (GMT+08:00) > To

Re: [Flink-9407] Question about proposed ORC Sink !

2018-06-22 Thread Ted Yu
For #1, the word exist should be exit, right ?Thanks Original message From: zhangminglei <18717838...@163.com> Date: 6/23/18 10:12 AM (GMT+08:00) To: sagar loke Cc: dev , user Subject: Re: [Flink-9407] Question about proposed ORC Sink ! Hi, Sagar. 1. It solves the issue par

Re: [Flink-9407] Question about proposed ORC Sink !

2018-06-22 Thread zhangminglei
Hi, Sagar. > 1. It solves the issue partially meaning files which have finished > checkpointing don't show .pending status but the files which were in progress > when the program exists are still in .pending state. Ans: Yea, Make the program exists and in that time if a checkpoint does no

Re: [ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread zhangminglei
Congrats Piotr! Cheers Minglei > 在 2018年6月23日,上午3:26,Till Rohrmann 写道: > > Hi everybody, > > On behalf of the PMC I am delighted to announce Piotr Nowojski as a new > Flink > committer! > > Piotr has been an active member of our community for more than a year. > Among other things, he contribu

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Dawid Wysakowicz
Congratulations Sihua! On 22.06.2018 15:17, Till Rohrmann wrote: > Hi everybody, > > On behalf of the PMC I am delighted to announce Sihua Zhou as a new Flink > committer! > > Sihua has been an active member of our community for several months. Among > other things, he helped developing Flip-6, i

Re: [ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread Dawid Wysakowicz
Congratulations Piotr, very well deserved!!! On 22.06.2018 21:26, Till Rohrmann wrote: > Hi everybody, > > On behalf of the PMC I am delighted to announce Piotr Nowojski as a new > Flink > committer! > > Piotr has been an active member of our community for more than a year. > Among other things,

Re: [ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread Ted Yu
Congratulations, Piotr! On Fri, Jun 22, 2018 at 12:26 PM, Till Rohrmann wrote: > Hi everybody, > > On behalf of the PMC I am delighted to announce Piotr Nowojski as a new > Flink > committer! > > Piotr has been an active member of our community for more than a year. > Among other things, he cont

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Kostas Kloudas
Congratulations! On Fri, Jun 22, 2018, 21:33 Shuyi Chen wrote: > Congratulations! > > On Fri, Jun 22, 2018 at 11:08 AM Matthias J. Sax wrote: > > > -BEGIN PGP SIGNED MESSAGE- > > Hash: SHA512 > > > > Congrats! > > > > On 6/22/18 10:33 AM, shimin yang wrote: > > > Congrats! > > > > > > O

Re: [ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread Kostas Kloudas
Congratulations! On Fri, Jun 22, 2018, 21:33 Shuyi Chen wrote: > Congratulations! > > > On Fri, Jun 22, 2018 at 12:30 PM Matthias J. Sax wrote: > > > -BEGIN PGP SIGNED MESSAGE- > > Hash: SHA512 > > > > Congrats! > > > > On 6/22/18 12:28 PM, Stefan Richter wrote: > > > Congrats Piotr! >

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Shuyi Chen
Congratulations! On Fri, Jun 22, 2018 at 11:08 AM Matthias J. Sax wrote: > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Congrats! > > On 6/22/18 10:33 AM, shimin yang wrote: > > Congrats! > > > > On Sat, Jun 23, 2018 at 1:13 AM Chen Qin > > wrote: > > > >> Congrats! > >> > >>> On Jun 2

Re: [ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread Shuyi Chen
Congratulations! On Fri, Jun 22, 2018 at 12:30 PM Matthias J. Sax wrote: > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Congrats! > > On 6/22/18 12:28 PM, Stefan Richter wrote: > > Congrats Piotr! > > > >> Am 22.06.2018 um 21:26 schrieb Till Rohrmann > >> : > >> > >> Hi everybody, > >>

Re: [ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread Matthias J. Sax
-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Congrats! On 6/22/18 12:28 PM, Stefan Richter wrote: -BEGIN PGP SIGNATURE- Comment: GPGTools - https://gpgtools.org iQIzBAEBCgAdFiEEeiQdEa0SVXokodP3DccxaWtLg18FAlstTjMACgkQDccxaWtL g1+AgA/8DT/ZS8nUrE/DKWs5JPqEBTXvuR6f7/pfs12cJQ+vesbpIUxCB87

Re: [ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread Matthias J. Sax
-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Congrats! On 6/22/18 12:28 PM, Stefan Richter wrote: > Congrats Piotr! > >> Am 22.06.2018 um 21:26 schrieb Till Rohrmann >> : >> >> Hi everybody, >> >> On behalf of the PMC I am delighted to announce Piotr Nowojski as >> a new Flink committer! >

Re: [ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread Stefan Richter
Congrats Piotr! > Am 22.06.2018 um 21:26 schrieb Till Rohrmann : > > Hi everybody, > > On behalf of the PMC I am delighted to announce Piotr Nowojski as a new > Flink > committer! > > Piotr has been an active member of our community for more than a year. > Among other things, he contributed the

[ANNOUNCE] New committer Piotr Nowojski

2018-06-22 Thread Till Rohrmann
Hi everybody, On behalf of the PMC I am delighted to announce Piotr Nowojski as a new Flink committer! Piotr has been an active member of our community for more than a year. Among other things, he contributed the TwoPhaseCommitSink, worked extensively on improving Flink's network stack and is now

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Matthias J. Sax
-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Congrats! On 6/22/18 10:33 AM, shimin yang wrote: > Congrats! > > On Sat, Jun 23, 2018 at 1:13 AM Chen Qin > wrote: > >> Congrats! >> >>> On Jun 22, 2018, at 9:48 AM, Ted Yu >>> wrote: >>> >>> Congratulations Sihua! >>> On Fri, Jun 22,

[jira] [Created] (FLINK-9649) TaskManagers are not scheduled on Mesos

2018-06-22 Thread Leonid Ishimnikov (JIRA)
Leonid Ishimnikov created FLINK-9649: Summary: TaskManagers are not scheduled on Mesos Key: FLINK-9649 URL: https://issues.apache.org/jira/browse/FLINK-9649 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread shimin yang
Congrats! On Sat, Jun 23, 2018 at 1:13 AM Chen Qin wrote: > Congrats! > > > On Jun 22, 2018, at 9:48 AM, Ted Yu wrote: > > > > Congratulations Sihua! > > > >> On Fri, Jun 22, 2018 at 6:42 AM, zhangminglei <18717838...@163.com> > wrote: > >> > >> Congrats! Sihua > >> > >> Cheers > >> Minglei. >

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Chen Qin
Congrats! > On Jun 22, 2018, at 9:48 AM, Ted Yu wrote: > > Congratulations Sihua! > >> On Fri, Jun 22, 2018 at 6:42 AM, zhangminglei <18717838...@163.com> wrote: >> >> Congrats! Sihua >> >> Cheers >> Minglei. >> >>> 在 2018年6月22日,下午9:17,Till Rohrmann 写道: >>> >>> Hi everybody, >>> >>> On be

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Ted Yu
Congratulations Sihua! On Fri, Jun 22, 2018 at 6:42 AM, zhangminglei <18717838...@163.com> wrote: > Congrats! Sihua > > Cheers > Minglei. > > > 在 2018年6月22日,下午9:17,Till Rohrmann 写道: > > > > Hi everybody, > > > > On behalf of the PMC I am delighted to announce Sihua Zhou as a new Flink > > commit

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Shaoxuan Wang
Welcome and Congratulations~~ Sihua! On Fri, Jun 22, 2018 at 10:28 PM, Fabian Hueske wrote: > Congratulations! :-) > > Cheers, Fabian > > 2018-06-22 16:07 GMT+02:00 Stefan Richter : > > > Congratulations Sihua! That is great news. > > > > Best, > > Stefan > > > > > Am 22.06.2018 um 15:17 schrie

[jira] [Created] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig

2018-06-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9648: --- Summary: Do not store distributed cache entries in ExecutionConfig Key: FLINK-9648 URL: https://issues.apache.org/jira/browse/FLINK-9648 Project: Flink

[jira] [Created] (FLINK-9647) Files uploaded to blobservice during job submission aren't rmeoved on failure

2018-06-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9647: --- Summary: Files uploaded to blobservice during job submission aren't rmeoved on failure Key: FLINK-9647 URL: https://issues.apache.org/jira/browse/FLINK-9647 Pro

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread sihua zhou
Thank you everyone! This is definitely an honour for me! It is very nice to work with you and I got a lot from you guys! Thanks, Sihua On 06/22/2018 22:31,zhenya Sun wrote: Congratulations from my iphone! On 06/22/2018 21:17, Till Rohrmann wrote: Hi everybody, On behalf of the PMC I

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread zhenya Sun
Congratulations from my iphone! On 06/22/2018 21:17, Till Rohrmann wrote: Hi everybody, On behalf of the PMC I am delighted to announce Sihua Zhou as a new Flink committer! Sihua has been an active member of our community for several months. Among other things, he helped developing Flip-6, imp

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Fabian Hueske
Congratulations! :-) Cheers, Fabian 2018-06-22 16:07 GMT+02:00 Stefan Richter : > Congratulations Sihua! That is great news. > > Best, > Stefan > > > Am 22.06.2018 um 15:17 schrieb Till Rohrmann : > > > > Hi everybody, > > > > On behalf of the PMC I am delighted to announce Sihua Zhou as a new F

[jira] [Created] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart

2018-06-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9646: Summary: ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart Key: FLINK-9646 URL: https://issues.apache.org/jira/browse/FLINK-9646 Project: Flink

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Stefan Richter
Congratulations Sihua! That is great news. Best, Stefan > Am 22.06.2018 um 15:17 schrieb Till Rohrmann : > > Hi everybody, > > On behalf of the PMC I am delighted to announce Sihua Zhou as a new Flink > committer! > > Sihua has been an active member of our community for several months. Among >

FlinkML SVM Predictions are always 1.0

2018-06-22 Thread Mano Swerts
Hi guys, Here I am again. I am playing with Flink ML and was just trying to get the example to work used in the documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/libs/ml/quickstart.html#loading-data (the one using the astroparticle LibSVM data). My code is basicall

Re: [ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread zhangminglei
Congrats! Sihua Cheers Minglei. > 在 2018年6月22日,下午9:17,Till Rohrmann 写道: > > Hi everybody, > > On behalf of the PMC I am delighted to announce Sihua Zhou as a new Flink > committer! > > Sihua has been an active member of our community for several months. Among > other things, he helped develop

[ANNOUNCE] New committer: Sihua Zhou

2018-06-22 Thread Till Rohrmann
Hi everybody, On behalf of the PMC I am delighted to announce Sihua Zhou as a new Flink committer! Sihua has been an active member of our community for several months. Among other things, he helped developing Flip-6, improved Flink's state backends and fixed a lot of major and minor issues. Moreo

[jira] [Created] (FLINK-9645) DispatcherTest.testSubmittedJobGraphListener fails on Travis

2018-06-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9645: Summary: DispatcherTest.testSubmittedJobGraphListener fails on Travis Key: FLINK-9645 URL: https://issues.apache.org/jira/browse/FLINK-9645 Project: Flink I

[jira] [Created] (FLINK-9644) Restore a job from savepoint in a local stream environment

2018-06-22 Thread Manuel Haddadi (JIRA)
Manuel Haddadi created FLINK-9644: - Summary: Restore a job from savepoint in a local stream environment Key: FLINK-9644 URL: https://issues.apache.org/jira/browse/FLINK-9644 Project: Flink Is

[jira] [Created] (FLINK-9643) Flink allowing TLS 1.1 in spite of configuring TLS 1.2

2018-06-22 Thread Vinay (JIRA)
Vinay created FLINK-9643: Summary: Flink allowing TLS 1.1 in spite of configuring TLS 1.2 Key: FLINK-9643 URL: https://issues.apache.org/jira/browse/FLINK-9643 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9642) Reduce the count to deal with state during a CEP process

2018-06-22 Thread aitozi (JIRA)
aitozi created FLINK-9642: - Summary: Reduce the count to deal with state during a CEP process Key: FLINK-9642 URL: https://issues.apache.org/jira/browse/FLINK-9642 Project: Flink Issue Type: Improve