Re: How to build flink-dist.jar from source code

2017-08-11 Thread Michael Fong
Cool. Thanks! On Sat, Aug 12, 2017 at 9:44 AM, Ted Yu wrote: > **Maven 3.3.x** > The build has to be done in two steps: First in the base directory, then in > the distribution project: > > ~~~bash > mvn clean install -DskipTests > cd flink-dist > mvn clean install > > On

Re: How to build flink-dist.jar from source code

2017-08-11 Thread Ted Yu
**Maven 3.3.x** The build has to be done in two steps: First in the base directory, then in the distribution project: ~~~bash mvn clean install -DskipTests cd flink-dist mvn clean install On Fri, Aug 11, 2017 at 6:19 PM, Michael Fong wrote: > Hi, > > I am new to Flink. I

How to build flink-dist.jar from source code

2017-08-11 Thread Michael Fong
Hi, I am new to Flink. I would like to know how to build the flink-dist.jar from source code, i.e. from the master branch from github. Could anyone show me the quickest way to do so? Thanks in advance. Sincerely, Michael Fong

Re: Which branch should I build for Flink 1.3.2

2017-08-11 Thread Bowen Li
Thanks guys! But we prefer a git branch, rather than a downloaded code, so we can maintain our own branch at our company. Any recommendations to achieve that goal? On Fri, Aug 11, 2017 at 3:06 PM, Fabian Hueske wrote: > There's also a tag "release-1.3.2". > > Cheers,

Re: Which branch should I build for Flink 1.3.2

2017-08-11 Thread Fabian Hueske
There's also a tag "release-1.3.2". Cheers, Fabian Am 11.08.2017 11:56 nachm. schrieb "Ted Yu" : From http://search-hadoop.com/m/Flink/VkLeQ4jYZR3pCAq1?subj=+ ANNOUNCE+Apache+Flink+1+3+2+released , you can find this link: https://flink.apache.org/downloads.html#source On

Re: Which branch should I build for Flink 1.3.2

2017-08-11 Thread Ted Yu
From http://search-hadoop.com/m/Flink/VkLeQ4jYZR3pCAq1?subj=+ANNOUNCE+Apache+Flink+1+3+2+released , you can find this link: https://flink.apache.org/downloads.html#source On Fri, Aug 11, 2017 at 2:53 PM, Bowen Li wrote: > Hi guys, > I'm trying to build Flink 1.3.2

Which branch should I build for Flink 1.3.2

2017-08-11 Thread Bowen Li
Hi guys, I'm trying to build Flink 1.3.2 myself from source code, and which branch I should build from? 'release-1.3' or 'release-1.3.2-rc3'? I think it should be the former one, but want you confirm on it. Thanks, Bowen

[jira] [Created] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers

2017-08-11 Thread Ted Yu (JIRA)
Ted Yu created FLINK-7433: - Summary: Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers Key: FLINK-7433 URL: https://issues.apache.org/jira/browse/FLINK-7433 Project: Flink

[jira] [Created] (FLINK-7432) Unclosed HighAvailabilityServices instance in QueryableStateClient

2017-08-11 Thread Ted Yu (JIRA)
Ted Yu created FLINK-7432: - Summary: Unclosed HighAvailabilityServices instance in QueryableStateClient Key: FLINK-7432 URL: https://issues.apache.org/jira/browse/FLINK-7432 Project: Flink Issue

[jira] [Created] (FLINK-7431) test instability in JobManagerFailsITCase

2017-08-11 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7431: -- Summary: test instability in JobManagerFailsITCase Key: FLINK-7431 URL: https://issues.apache.org/jira/browse/FLINK-7431 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions

2017-08-11 Thread Peter Ertl (JIRA)
Peter Ertl created FLINK-7430: - Summary: ContinuousFileReaderOperator swallows exceptions Key: FLINK-7430 URL: https://issues.apache.org/jira/browse/FLINK-7430 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer

2017-08-11 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7429: -- Summary: Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer Key: FLINK-7429 URL: https://issues.apache.org/jira/browse/FLINK-7429

Re: How to access HDFS file from flink

2017-08-11 Thread Aljoscha Krettek
Hi, Unfortunately. Inline images do not work on these mailing lists. Also, could you please use the user mailing lists in the future, since the dev mailing lists are meant for discussing the development of Flink. Best, Aljoscha > On 11. Aug 2017, at 11:31, P. Ramanjaneya Reddy

[jira] [Created] (FLINK-7428) avoid one additional buffer copy when receiving messages

2017-08-11 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7428: -- Summary: avoid one additional buffer copy when receiving messages Key: FLINK-7428 URL: https://issues.apache.org/jira/browse/FLINK-7428 Project: Flink Issue

[jira] [Created] (FLINK-7427) integrate PartitionRequestProtocol into NettyProtocol

2017-08-11 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7427: -- Summary: integrate PartitionRequestProtocol into NettyProtocol Key: FLINK-7427 URL: https://issues.apache.org/jira/browse/FLINK-7427 Project: Flink Issue Type:

[jira] [Created] (FLINK-7426) Table API does not support null values in keys

2017-08-11 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7426: --- Summary: Table API does not support null values in keys Key: FLINK-7426 URL: https://issues.apache.org/jira/browse/FLINK-7426 Project: Flink Issue Type: Bug