flink git commit: Commit for release 0.10.0-milestone-1

2015-09-22 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1-rc1 [created] ffdd484ce Commit for release 0.10.0-milestone-1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ffdd484c Tree: http://git-wip-us.apach

Git Push Summary

2015-09-22 Thread fhueske
Repository: flink Updated Branches: refs/heads/0.10.0-milestone-1-rc1 [deleted] ffdd484ce

flink git commit: Commit for release 0.10.0-milestone-1

2015-09-22 Thread fhueske
Repository: flink Updated Branches: refs/heads/0.10.0-milestone-1-rc1 [created] ffdd484ce Commit for release 0.10.0-milestone-1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ffdd484c Tree: http://git-wip-us.apache.org/re

[4/4] flink git commit: [FLINK-2097][core] implement a job session management

2015-09-22 Thread mxm
[FLINK-2097][core] implement a job session management Sessions make sure that the JobManager does not immediately discard a JobGraph after execution, but keeps it around for further operations to be attached to the graph. That is the basis for interactive sessions. This pull request implements a

[1/4] flink git commit: [FLINK-2097] temporarily disable session management API

2015-09-22 Thread mxm
Repository: flink Updated Branches: refs/heads/master 7984acc6b -> d58caa8ec [FLINK-2097] temporarily disable session management API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d58caa8e Tree: http://git-wip-us.apache.o

[3/4] flink git commit: [FLINK-2097][core] implement a job session management

2015-09-22 Thread mxm
http://git-wip-us.apache.org/repos/asf/flink/blob/71bf2f57/flink-clients/src/main/java/org/apache/flink/client/program/PreviewPlanEnvironment.java -- diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/Preview

[2/4] flink git commit: [FLINK-2097][core] implement a job session management

2015-09-22 Thread mxm
http://git-wip-us.apache.org/repos/asf/flink/blob/71bf2f57/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph

flink git commit: [Maven] fix order of parent module information

2015-09-22 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1 356eef089 -> ed3bbb93e [Maven] fix order of parent module information An order other than "groupId, artifactId, version" can cause problems with the release scripts. This needs to be properly fixed in tools/generate_spe

flink git commit: [Maven] fix order of parent module information

2015-09-22 Thread mxm
Repository: flink Updated Branches: refs/heads/master 47afdfbf9 -> 7984acc6b [Maven] fix order of parent module information An order other than "groupId, artifactId, version" can cause problems with the release scripts. This needs to be properly fixed in tools/generate_specific_pom.sh Proje

flink git commit: [FLINK-2392][yarn tests] Address concurrent modification exception

2015-09-22 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master a3df109cf -> 47afdfbf9 [FLINK-2392][yarn tests] Address concurrent modification exception Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/47afdfbf Tree: http://git-wip-

flink git commit: [hotfix] Use InetAddress.getLocalHost() as first approach when detecting the TMs own ip/hostname

2015-09-22 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1 f4cb5938a -> 356eef089 [hotfix] Use InetAddress.getLocalHost() as first approach when detecting the TMs own ip/hostname Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/re

flink git commit: [FLINK-2722] Use InetAddress.getLocalHost() as first approach when detecting the TMs own ip/hostname

2015-09-22 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master c24b8e6cb -> a3df109cf [FLINK-2722] Use InetAddress.getLocalHost() as first approach when detecting the TMs own ip/hostname This closes #1159 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org

flink git commit: [FLINK-2643] [build] Update Travis build matrix and change snapshot deploy profiles

2015-09-22 Thread sewen
Repository: flink Updated Branches: refs/heads/master b8f58fab5 -> c24b8e6cb [FLINK-2643] [build] Update Travis build matrix and change snapshot deploy profiles This closes #1146 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/

[1/3] flink git commit: [FLINK-2683] [FLINK-2682] [runtime] Add dedicated operator for aligned processing time windows.

2015-09-22 Thread sewen
Repository: flink Updated Branches: refs/heads/master 64e1dc6fe -> b8f58fab5 http://git-wip-us.apache.org/repos/asf/flink/blob/b8f58fab/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/operators/windows/AggregatingAlignedProcessingTimeWindowOpe

[2/3] flink git commit: [FLINK-2683] [FLINK-2682] [runtime] Add dedicated operator for aligned processing time windows.

2015-09-22 Thread sewen
[FLINK-2683] [FLINK-2682] [runtime] Add dedicated operator for aligned processing time windows. Also add utilities for heap-backed keyed state in panes (dedicated tailored hash table) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flin

[3/3] flink git commit: [FLINK-2675] [streaming] Add utilities for scheduled triggers.

2015-09-22 Thread sewen
[FLINK-2675] [streaming] Add utilities for scheduled triggers. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ad21031 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7ad21031 Diff: http://git-wip-us.apache.org/repos/

flink git commit: [FLINK-2392][yarn tests] Produce more log output on travis for the flink-yarn-tests to avoid running into the 300s limit

2015-09-22 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 0fea61a04 -> 64e1dc6fe [FLINK-2392][yarn tests] Produce more log output on travis for the flink-yarn-tests to avoid running into the 300s limit Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.or

flink git commit: [test-stability] Sets the number of ZooKeeper servers of TestingCluster in ForkableFlinkMiniCluster to 1 in order to avoid test failures when two servers try to bind to the same port

2015-09-22 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 6d1656a21 -> 0fea61a04 [test-stability] Sets the number of ZooKeeper servers of TestingCluster in ForkableFlinkMiniCluster to 1 in order to avoid test failures when two servers try to bind to the same port. Project: http://git-wip-us.apa

flink git commit: [FLINK-2392][yarn tests] Use log event which is guaranteed to show up to test whether the job was successful

2015-09-22 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 5e6175d6e -> 6d1656a21 [FLINK-2392][yarn tests] Use log event which is guaranteed to show up to test whether the job was successful Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/f