GitHub user balidani opened a pull request:
https://github.com/apache/flink/pull/400
[FLINK-1528] Added local clustering coefficient example (failing)
As @vasia requested, here is the current version of local clustering
coefficient for Gelly. It causes exceptions, so this PR is only a draft.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/balidani/flink master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/400.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #400
----
commit c2b19492932e1fe4f8ade1319d8dd4786bfc257e
Author: Daniel Bali <[email protected]>
Date: 2015-02-13T11:35:50Z
[FLINK-1528] Added local clustering coefficient example (failing)
commit 39f88893ecf47dbcab3f1057f526bbf014c3086f
Author: Gyula Fora <[email protected]>
Date: 2015-02-11T13:19:22Z
[FLINK-1517] [streaming] Added indexed input iterator for streaming
commit c519ddfc64bc33474f6b8575fc051a50ab7fb0e5
Author: mbalassi <[email protected]>
Date: 2015-02-12T21:20:14Z
[streaming] Added ITCase for streaming classloading
commit 7c35e748f1b17fe86c7faea4712f673fecbeea8f
Author: Henry Saputra <[email protected]>
Date: 2015-02-13T17:09:26Z
Small cleanups to add space between if-else keyword and parentheses to be
consistent
as I found them.
Also fix some comments typos."
commit b0d4e94a709e40a38bba778dd32b97c72a407d06
Author: Stephan Ewen <[email protected]>
Date: 2015-02-11T18:01:41Z
[FLINK-1529] [jobmanager] Improve error handling on JobManager startup
This closes #385
commit 7d5aa836e9af88b46957e08986073db3fa4a7ef6
Author: Stephan Ewen <[email protected]>
Date: 2015-02-13T11:22:35Z
[FLINK-1532] [tests] Fix spurious failure in AggregatorsITCase (plus minor
cleanups)
commit aeaa82c7a874a8e65c3615e3b4872c80dc426a6b
Author: Till Rohrmann <[email protected]>
Date: 2015-02-10T11:21:33Z
[FLINK-1508] [runtime] Removes AkkaUtil.ask and replaces respective calls
with explicit future handling.
Removes blocking calls for ActorRef retrieval in actors.
This closes #384.
commit 2052be6d864b0d163b3212ed20625a77399029df
Author: Till Rohrmann <[email protected]>
Date: 2015-02-12T10:49:09Z
[FLINK-1543] [runtime] Adds try and catch blocks around all method calls
from an actor's receive method which can throw an exception. Sets the
StoppingSupervisorStrategy as default for all guardians.
This closes #394.
commit 1162266a270a3c4508393073bf27dc8c5a656ed2
Author: Chiwan Park <[email protected]>
Date: 2015-02-08T06:36:19Z
[FLINK-1179] [jobmanager] Add button to JobManager web interface to request
stack trace of a TaskManager
This closes #374
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
