The Buildbot has detected a new failure on builder flink-docs-release-0.8.0
while building ASF Buildbot. Full details are available at:
http://ci.apache.org/builders/flink-docs-release-0.8.0/builds/77
Buildbot URL: http://ci.apache.org/
Buildslave for this Build: orcus_ubuntu
Build Reason:
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/113
Buildbot URL: http://ci.apache.org/
Buildslave for this Build: orcus_ubuntu
Build Reason: The Nightl
Repository: flink
Updated Branches:
refs/heads/master 147997388 -> 912f8d90e
[FLINK-1523] [gelly] Added Vertex Centric Configuration Tests
This commit squashes the following:
Pratially addressed inline comments
Added test for removal of a non-SP-edge
Project: http://git-wip-us.apache.org/r
[FLINK-1523] [gelly] Vertex centric iteration extensions
Removed trailing splits into vertex key and value
Made the extensions optional and separate
Removed overhead when the options are not used
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/re
http://git-wip-us.apache.org/repos/asf/flink/blob/e2f28d47/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/ConnectedComponentsWithRandomisedEdgesITCase.java
--
diff --git
a/flink-staging/flink-gelly/src
[FLINK-1523] [gelly] added getIn/Out degrees methods in update and messaging
functions;
deleted VertexWithValue type;
deleted InaccessibleMethodException; if the options are not set, -1 is
returned;
added missing javadocs;
added tests;
renamed type parameters VertexKey -> K, V
[gelly] renamed IncrementalSSSPExample -> IncrementalSSSP to match the new
examples naming scheme
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/912f8d90
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/912f8d90
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/8f4039dc/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SimpleCommunityDetection.java
--
diff --git
a/flink-staging/flink-gelly/src/main/java/org/apache/fli
http://git-wip-us.apache.org/repos/asf/flink/blob/8f4039dc/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/LabelPropagationExample.java
--
diff --git
a/flink-staging/flink-gelly/src/main/java/org/apache/flin
[FLINK-1523] [gelly] Added VertexWithDegrees as a subclass of Vertex
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e1720673
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e1720673
Diff: http://git-wip-us.apache.org/
[FLINK-1523] [gelly] [docs] updated vertex-centric docs accordingly
This closes #680
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a067d59c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a067d59c
Diff: http://git-w
[gelly] [refactoring] Removed Example end string from all gelly examples
Added Algorithm end string to the library methods
This closes #625
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8f4039dc
Tree: http://git-wip-us.apa
[streaming] Added HDFS test for FileStateHandle
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6edf31a0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6edf31a0
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/
[streaming] State backend configurable from flink-conf.yaml
Closes #676
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/14799738
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/14799738
Diff: http://git-wip-us.apache.
[streaming] Discard method added to state handle
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59bee4ad
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/59bee4ad
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff
[streaming] StateHandleProvider added for configurable state backend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/197cd6cf
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/197cd6cf
Diff: http://git-wip-us.apache.org/
Repository: flink
Updated Branches:
refs/heads/master f59d6a118 -> 147997388
[streaming] ByteStream and File state handle added
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/48a27200
Tree: http://git-wip-us.apache.org/re
[FLINK-1986] [streaming] Iterative stream creation bugfix
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2d3e69a2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2d3e69a2
Diff: http://git-wip-us.apache.org/repos/asf/f
http://git-wip-us.apache.org/repos/asf/flink/blob/58865ff3/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java
--
diff --git
a/flink-staging/
[FLINK-2009] Force chaining for System Operators
The system operators are, for example, the StreamDiscretizer and
WindowBuffer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a04f0912
Tree: http://git-wip-us.apache.org/repos/
http://git-wip-us.apache.org/repos/asf/flink/blob/58865ff3/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
--
diff --git
a/flink-staging/flink-streaming/fli
http://git-wip-us.apache.org/repos/asf/flink/blob/58865ff3/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowingExample.java
--
diff --git
a/flink-stag
[FLINK-1977] Rework Stream Operators to always be push based
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/58865ff3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/58865ff3
Diff: http://git-wip-us.apache.org/repos/as
Repository: flink
Updated Branches:
refs/heads/master 3cd36a51d -> f59d6a118
Disable Test in ComplexIntegrationTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f59d6a11
Tree: http://git-wip-us.apache.org/repos/asf/flin
http://git-wip-us.apache.org/repos/asf/flink/blob/58865ff3/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/co/CoStreamFlatMap.java
--
diff --git
a/flink-staging/flink-strea
Repository: flink
Updated Branches:
refs/heads/master 8aad7affb -> 3cd36a51d
[FLINK-1952] [tests] Add a test that runs an iterative job after a failure in
another iterative job.
This test validates that task slots in co-location constraints are properly
freed in the presence of failures.
P
[runtime] Fix for task canceling the order of (1) resource deregistration (2)
completeness notification
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3cd36a51
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3cd36a51
Repository: flink
Updated Branches:
refs/heads/master ea23f28c4 -> 8aad7affb
[FLINK-2040] [runtime] Tolerate out-of-order CANCELING and CANCELED messages.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8aad7aff
Tree: http
[FLINK-1820] Consistent behavior of numeric value parsers.
This closes #566
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/39d526e6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/39d526e6
Diff: http://git-wip-us.apa
Repository: flink
Updated Branches:
refs/heads/master 6403dbdb4 -> ea23f28c4
[FLINK-1820] Consistent behavior of numeric value parsers.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ea23f28c
Tree: http://git-wip-us.apach
30 matches
Mail list logo