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
a/flink-staging/f
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
a/flink-staging/flink-st
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
a/flink-staging/flink-streami
[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 t
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
a/flink-staging/flink-strea
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
a/flink-staging/flink-streaming/f
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
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
a/flink-stagin
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
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: by
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/21
Buildbot URL: http://ci.apache.org/
Buildslave for this Build: orcus_ubuntu
Build Reason:
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: forc
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:
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: http://git-wip-us.ap
[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 values
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: http://git-wip-us.
[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: http://git-wi
[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: http://git-w
[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
Br
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
b/flink-runtim
http://git-wip-us.apache.org/repos/asf/flink/blob/d59cebd8/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf
--
diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf
b/flink-runtime-web/web
[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 Netty
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
b/flink-runtime-
[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: http://
[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: http://git-wip-
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 b7c
[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: http://git-wip-us.apache.org/repos/as
[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: ht
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 fi
[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: http://git-wip-us.apache.org/repos/asf/flink/tree/0818b
[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: http://git-wip-us.apache.or
[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: http://git-wip-us.apache.org/repos/asf/flin
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
b/flink-runtime-web/web
[FLINK-1943] [gelly] Added GSA compiler and translation tests
This closes #916
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/11b48633
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/11b48633
Diff: http://git-wip-us.
[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: http://git-wip-us.apache.o
http://git-wip-us.apache.org/repos/asf/flink/blob/ea2b1b13/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
index
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
[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: h
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
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
a/flin
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
b/flink-runtime-
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
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/web/
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 Nightly
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: T
44 matches
Mail list logo