flink git commit: [FLINK-2382] fix Flink live accumulators for TwoInputStreamTask

Repository: flink Updated Branches: refs/heads/master 0f589aad8 - 1d373a7de [FLINK-2382] fix Flink live accumulators for TwoInputStreamTask Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1d373a7d Tree:

buildbot success in ASF Buildbot on flink-docs-release-0.9

The Buildbot has detected a restored build on builder flink-docs-release-0.9 while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/flink-docs-release-0.9/builds/24 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason:

buildbot success in ASF Buildbot on flink-docs-master

The Buildbot has detected a restored build on builder flink-docs-master while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/flink-docs-master/builds/23 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason: The

[23/26] flink git commit: [docs] Document some missing configuration parameters

[docs] Document some missing configuration parameters This closes #915 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f798df8d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f798df8d Diff:

[06/26] flink git commit: [FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.

http://git-wip-us.apache.org/repos/asf/flink/blob/d59cebd8/flink-runtime-web/web-dashboard/web/css/vendor.css -- diff --git a/flink-runtime-web/web-dashboard/web/css/vendor.css b/flink-runtime-web/web-dashboard/web/css/vendor.css

[21/26] flink git commit: [FLINK-2377] [tests] Add reader.close() to readAllResultLines in TestBaseUtils

[FLINK-2377] [tests] Add reader.close() to readAllResultLines in TestBaseUtils This closes #924 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29454de5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/29454de5 Diff:

[03/26] flink git commit: [FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.

http://git-wip-us.apache.org/repos/asf/flink/blob/d59cebd8/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js new file

[01/26] flink git commit: [FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.

Repository: flink Updated Branches: refs/heads/master 1d373a7de - 148395bcd http://git-wip-us.apache.org/repos/asf/flink/blob/d59cebd8/flink-runtime-web/web-dashboard/web/partials/jobs/completed-jobs.html -- diff --git

[07/26] flink git commit: [FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.

http://git-wip-us.apache.org/repos/asf/flink/blob/d59cebd8/flink-runtime-web/web-dashboard/assets/fonts/fontawesome-webfont.ttf -- diff --git a/flink-runtime-web/web-dashboard/assets/fonts/fontawesome-webfont.ttf

[12/26] flink git commit: [FLINK-2358] [dashboard] First part dashboard server backend

http://git-wip-us.apache.org/repos/asf/flink/blob/44ee1c1b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/web/WebInfoServer.java -- diff --git

[13/26] flink git commit: [FLINK-2358] [dashboard] First part dashboard server backend

[FLINK-2358] [dashboard] First part dashboard server backend - Adds a separate Maven project for easier maintenance. Also allows users to refer to runtime without web libraries. - Simple HTTP server based on Netty HTTP (slim dependency, since we use netty anyways) - REST URL parsing via

[08/26] flink git commit: [FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.

http://git-wip-us.apache.org/repos/asf/flink/blob/d59cebd8/flink-runtime-web/web-dashboard/assets/fonts/fontawesome-webfont.svg -- diff --git a/flink-runtime-web/web-dashboard/assets/fonts/fontawesome-webfont.svg

[20/26] flink git commit: [FLINK-2358] [dashboard] Adding comments to web dashboard files, add LICENSE file entries

[FLINK-2358] [dashboard] Adding comments to web dashboard files, add LICENSE file entries Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ea2b1b13 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ea2b1b13 Diff:

[14/26] flink git commit: [FLINK-2362] [docs] Add Scala and Java documentation for the 'distinct()' transformation

[FLINK-2362] [docs] Add Scala and Java documentation for the 'distinct()' transformation This closes #922 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0818bec0 Tree:

[24/26] flink git commit: [FLINK-2377] [tests] Make buffer closing logic robust to I/O failures.

[FLINK-2377] [tests] Make buffer closing logic robust to I/O failures. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1404db6a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1404db6a Diff:

[09/26] flink git commit: [FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.

[FLINK-2358] [dashboard] Add first stub of angular.js based dashboard. Add README.md that outlines build instructions. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d59cebd8 Tree:

[05/26] flink git commit: [FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.

http://git-wip-us.apache.org/repos/asf/flink/blob/d59cebd8/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.eot -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.eot

[25/26] flink git commit: [FLINK-2018] [core] Add ParameterUtil.fromGenericOptionsParser()

[FLINK-2018] [core] Add ParameterUtil.fromGenericOptionsParser() This closes #720 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/148395bc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/148395bc Diff:

[19/26] flink git commit: [FLINK-2358] [dashboard] Adding comments to web dashboard files, add LICENSE file entries

http://git-wip-us.apache.org/repos/asf/flink/blob/ea2b1b13/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index

[22/26] flink git commit: [docs] Clean up completeness checker for configuration docs.

[docs] Clean up completeness checker for configuration docs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/efafaee8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/efafaee8 Diff:

[15/26] flink git commit: [FLINK-2376] Raise the time limit in testFindConnectableAddress under Windows

[FLINK-2376] Raise the time limit in testFindConnectableAddress under Windows This closes #920 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bbbfd220 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bbbfd220 Diff:

[02/26] flink git commit: [FLINK-2358] [dashboard] Add first stub of angular.js based dashboard.

http://git-wip-us.apache.org/repos/asf/flink/blob/d59cebd8/flink-runtime-web/web-dashboard/web/js/vendor.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/vendor.js b/flink-runtime-web/web-dashboard/web/js/vendor.js new

[10/26] flink git commit: [FLINK-2358] [dashboard] Add server for static dashboard files (HTML, JS, CSS, ...)

[FLINK-2358] [dashboard] Add server for static dashboard files (HTML, JS, CSS, ...) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e86f4517 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e86f4517 Diff:

[26/26] flink git commit: [FLINK-2198] [tests] Under Windows, skip tests that use setWritable

[FLINK-2198] [tests] Under Windows, skip tests that use setWritable This closes #919 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50344d70 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50344d70 Diff:

[11/26] flink git commit: [core] Remove obsolete OperatorUtil

[core] Remove obsolete OperatorUtil Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/75d1639a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/75d1639a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/75d1639a

[17/26] flink git commit: [FLINK-2358] [dashboard] Adding comments to web dashboard files, add LICENSE file entries

http://git-wip-us.apache.org/repos/asf/flink/blob/ea2b1b13/flink-runtime-web/web-dashboard/web/partials/jobs/completed-jobs.html -- diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/completed-jobs.html

[4/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/StreamGroupedFoldTest.java -- diff --git

[6/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/BlockingQueueBroker.java -- diff --git

[8/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

[FLINK-1967] Introduce (Event)time in Streaming This introduces an additional timestamp field in StreamRecord. When using a SourceFunction and an auto-timestamp interval is set using the ExecutionConfig, the timestamp is automatically set to System.currentTimeMillis() upon element emission. The

[5/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTask.java -- diff --git

[7/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/StreamReduce.java -- diff --git

[2/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/partitioner/ForwardPartitionerTest.java -- diff --git

[1/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

Repository: flink Updated Branches: refs/heads/master 2d191ab05 - a2eb6cc87 http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/timestamp/TimestampITCase.java

[3/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/windowing/WindowIntegrationTest.java -- diff --git

buildbot success in ASF Buildbot on flink-docs-master

The Buildbot has detected a restored build on builder flink-docs-master while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/flink-docs-master/builds/20 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason: forced: by

buildbot exception in ASF Buildbot on flink-docs-master

The Buildbot has detected a build exception on builder flink-docs-master while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/flink-docs-master/builds/21 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason: forced:

buildbot exception in ASF Buildbot on flink-docs-release-0.9

The Buildbot has detected a build exception on builder flink-docs-release-0.9 while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/flink-docs-release-0.9/builds/23 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason:

buildbot failure in ASF Buildbot on flink-docs-release-0.9

The Buildbot has detected a new failure on builder flink-docs-release-0.9 while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/flink-docs-release-0.9/builds/22 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build Reason:

[1/2] flink git commit: [tests] add flag for synchronous execution of futures in TestingCluster

Repository: flink Updated Branches: refs/heads/master a2eb6cc87 - 0f589aad8 [tests] add flag for synchronous execution of futures in TestingCluster This adds a flag to TestingCluster to disabled asynchronous execution of futures via the CallingThreadDispatcher. Project:

[2/2] flink git commit: [FLINK-2371] improve AccumulatorLiveITCase

[FLINK-2371] improve AccumulatorLiveITCase Instead of using Thread.sleep() to synchronize the checks of the accumulator values, we rely on message passing here to synchronize the task process. Therefore, we let the task process signal to the task manager that it has updated its accumulator