Re: How to add flink dependency in pom

2016-12-30 Thread Liang Chen
My problem is solved, thanks. Regards Liang Liang Chen-2 wrote > Hi > > Can i do like this : > To directly run the below example in my project through adding flink's pom > dependency? > Thanks. > > Regards > Liang > > --- > > object WordCount { > > def

[DISCUSS] schedule for execution from different list of ExecutionJobVertex

2016-12-30 Thread sjk
Hi, all On [FLINK-1425][1] add executeMode supporting by Ufuk Celebi . I want to know why two loop using different list object: task.value() and getVerticesTopologically(). task and getVerticesTopologically() all filled in attachJobGraph function: public void attachJobGraph(List

[jira] [Created] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2016-12-30 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5402: Summary: Fails AkkaRpcServiceTest#testTerminationFuture Key: FLINK-5402 URL: https://issues.apache.org/jira/browse/FLINK-5402 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5401) Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics

2016-12-30 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5401: Summary: Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics Key: FLINK-5401 URL: https://issues.apache.org/jira/browse/FLINK-5401 Project: Flink