[2/2] flink git commit: [FLINK-1411] Fix standalone plan visualizer

[FLINK-1411] Fix standalone plan visualizer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/004c115f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/004c115f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/004c

[1/2] flink git commit: [webclient] Remove obsolete arrow images

Repository: flink Updated Branches: refs/heads/master 6151d707c -> 004c115f7 [webclient] Remove obsolete arrow images Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f1b0fb03 Tree: http://git-wip-us.apache.org/repos/asf/fl

flink git commit: [FLINK-1411] Fix standalone plan visualizer

Repository: flink Updated Branches: refs/heads/release-0.8 79da5a920 -> 68a0478a8 [FLINK-1411] Fix standalone plan visualizer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/68a0478a Tree: http://git-wip-us.apache.org/repo

[1/2] flink git commit: [FLINK-1438] [jobmanager] Fix class loading issue for messages with custom input splits

Repository: flink Updated Branches: refs/heads/release-0.8 5b420d847 -> 79da5a920 [FLINK-1438] [jobmanager] Fix class loading issue for messages with custom input splits Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/689

[2/2] flink git commit: [FLINK-1492] [FLINK-1513] Fix BLOB service shutdown message and avoid global configuration

[FLINK-1492] [FLINK-1513] Fix BLOB service shutdown message and avoid global configuration Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/79da5a92 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/79da5a92 Diff: http:/

[2/3] flink git commit: [FLINK-1530] Cache deserialized ExecutionConfig in the AbstractInvokable

[FLINK-1530] Cache deserialized ExecutionConfig in the AbstractInvokable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/69b79456 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/69b79456 Diff: http://git-wip-us.apache.

[1/3] flink git commit: [FLINK-1492] [FLINK-1513] Fix BLOB service shutdown message and avoid global configuration

Repository: flink Updated Branches: refs/heads/master 90834ca70 -> 6151d707c [FLINK-1492] [FLINK-1513] Fix BLOB service shutdown message and avoid global configuration Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6151d

[3/3] flink git commit: [tests fix] Fix runtime exceptions for large record sorter by properly mocking the environment.

[tests fix] Fix runtime exceptions for large record sorter by properly mocking the environment. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/18c9082c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/18c9082c Diff: h

flink git commit: [FLINK-1491] [runtime] Fixes logging output by setting Akka's stdout logger to log level WARNING.

Repository: flink Updated Branches: refs/heads/master 82cda12ef -> 90834ca70 [FLINK-1491] [runtime] Fixes logging output by setting Akka's stdout logger to log level WARNING. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commi

flink git commit: [FLINK-1504] support for secure HDFS access using kerberos

Repository: flink Updated Branches: refs/heads/master aedbacfc5 -> 82cda12ef [FLINK-1504] support for secure HDFS access using kerberos This closes #383 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82cda12e Tree: http:

flink git commit: [FLINK-1489] Replaces blocking scheduleOrUpdateConsumers message calls with asynchronous futures. Buffers PartitionInfos at the JobManager in case that the respective consumer has no

Repository: flink Updated Branches: refs/heads/master f577c9ef4 -> aedbacfc5 [FLINK-1489] Replaces blocking scheduleOrUpdateConsumers message calls with asynchronous futures. Buffers PartitionInfos at the JobManager in case that the respective consumer has not been scheduled. Conflicts:

flink git commit: [FLINK-1455] [runtime] Improve robustness of external sorting test errors

Repository: flink Updated Branches: refs/heads/master bec9c4dae -> f577c9ef4 [FLINK-1455] [runtime] Improve robustness of external sorting test errors Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f577c9ef Tree: http://g

flink git commit: [runtime] Corrects messages sent to the JobManager by the JobManagerInfoServlet

Repository: flink Updated Branches: refs/heads/master 1e9b68164 -> bec9c4dae [runtime] Corrects messages sent to the JobManager by the JobManagerInfoServlet Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bec9c4da Tree: ht

flink git commit: [FLINK-1473] Make abstract methods public in SplittableIterator

Repository: flink Updated Branches: refs/heads/master c699557c1 -> 1e9b68164 [FLINK-1473] Make abstract methods public in SplittableIterator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1e9b6816 Tree: http://git-wip-us.

[16/50] [abbrv] flink git commit: [FLINK-1201] [gelly] fix ClassCastException and Type errors in mapVertices; fixes #41 and #46

[FLINK-1201] [gelly] fix ClassCastException and Type errors in mapVertices; fixes #41 and #46 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b751df28 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b751df28 Diff: htt

[38/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Renamed tests from TestXyz to XyzITCase

http://git-wip-us.apache.org/repos/asf/flink/blob/6296c394/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/TestJoinWithVertices.java -- diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/grap

[10/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed mapEdges to also return a Graph

[FLINK-1201] [gelly] changed mapEdges to also return a Graph Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b5b63d75 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5b63d75 Diff: http://git-wip-us.apache.org/repos/as

[24/50] [abbrv] flink git commit: [FLINK-1201] [gelly] cloned spargel classes

[FLINK-1201] [gelly] cloned spargel classes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b0b12952 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b0b12952 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b0b1

[30/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use fromTupleDataset method instead of Tuple3ToEdgeMap

[FLINK-1201] [gelly] use fromTupleDataset method instead of Tuple3ToEdgeMap Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09d39ce6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/09d39ce6 Diff: http://git-wip-us.apac

[34/50] [abbrv] flink git commit: [FLINK-1201] [gelly] label propagation example

[FLINK-1201] [gelly] label propagation example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0393bc13 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0393bc13 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0

[48/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors

http://git-wip-us.apache.org/repos/asf/flink/blob/081de39b/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java -- diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java b/flin

[20/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed pageRank example to use joinWithEdgesOnSource

[FLINK-1201] [gelly] changed pageRank example to use joinWithEdgesOnSource Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/753c71ae Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/753c71ae Diff: http://git-wip-us.apach

[06/50] [abbrv] flink git commit: [FLINK-1201] [gelly] SSSP with runVertexCentricIteration

[FLINK-1201] [gelly] SSSP with runVertexCentricIteration Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2815df3c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2815df3c Diff: http://git-wip-us.apache.org/repos/asf/fl

[02/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use vertex/edge instead of tuples in the test

[FLINK-1201] [gelly] use vertex/edge instead of tuples in the test fixed a few warnings in pagerank example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/60363727 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6036

[43/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use MultipleProgramsTestBase for the tests

http://git-wip-us.apache.org/repos/asf/flink/blob/e6b9cecd/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/TestJoinWithEdges.java -- diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/t

[12/50] [abbrv] flink git commit: [FLINK-1201] [gelly] correct graph execution environment in InvalidVertexIdsValidator

[FLINK-1201] [gelly] correct graph execution environment in InvalidVertexIdsValidator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/99544bd9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/99544bd9 Diff: http://git-

[08/50] [abbrv] flink git commit: [FLINK-1201] [gelly] joinWithVertices implemented and tested

[FLINK-1201] [gelly] joinWithVertices implemented and tested Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3f600098 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3f600098 Diff: http://git-wip-us.apache.org/repos/as

[35/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added label propagation step in MusicProfiles

[FLINK-1201] [gelly] added label propagation step in MusicProfiles Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/32d9d2b1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/32d9d2b1 Diff: http://git-wip-us.apache.org/re

[25/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed spargel classes to work with Vertex and Edge types

[FLINK-1201] [gelly] changed spargel classes to work with Vertex and Edge types Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d45c0491 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d45c0491 Diff: http://git-wip-us.

[15/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added description in GraphMetrics example

[FLINK-1201] [gelly] added description in GraphMetrics example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d883c3ad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d883c3ad Diff: http://git-wip-us.apache.org/repos/

[47/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors

http://git-wip-us.apache.org/repos/asf/flink/blob/081de39b/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

[42/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use MultipleProgramsTestBase for the tests

http://git-wip-us.apache.org/repos/asf/flink/blob/e6b9cecd/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/TestMapVertices.java -- diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/tes

[49/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors

[FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/081de39b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/081de39b Dif

[29/50] [abbrv] flink git commit: [FLINK-1201] [gelly] created fromTupleDataSet() methods

[FLINK-1201] [gelly] created fromTupleDataSet() methods issue #53 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/878118a1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/878118a1 Diff: http://git-wip-us.apache.org/re

[32/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added label propagation in library

[FLINK-1201] [gelly] added label propagation in library Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/de2aa578 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/de2aa578 Diff: http://git-wip-us.apache.org/repos/asf/fli

[26/50] [abbrv] flink git commit: [FLINK-1201] [gelly] remove isUndirected flag; methods will always consider the graph as directed

[FLINK-1201] [gelly] remove isUndirected flag; methods will always consider the graph as directed Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b98bebc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2b98bebc Diff:

[09/50] [abbrv] flink git commit: [FLINK-1201] [gelly] return arbitrary type instead of Tuple2 for the neighbor methods

[FLINK-1201] [gelly] return arbitrary type instead of Tuple2 for the neighbor methods Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9a9dfc7c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9a9dfc7c Diff: http://git-

[07/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed mapVertices to return a Graph and simplified SSSP

[FLINK-1201] [gelly] changed mapVertices to return a Graph and simplified SSSP Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f41b9efa Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f41b9efa Diff: http://git-wip-us.a

[41/50] [abbrv] flink git commit: [FLINK-1201] [gelly] changed ConstantFields to ForwardedFields

[FLINK-1201] [gelly] changed ConstantFields to ForwardedFields This closes #335 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c699557c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c699557c Diff: http://git-wip-us

[44/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use MultipleProgramsTestBase for the tests

[FLINK-1201] [gelly] use MultipleProgramsTestBase for the tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e6b9cecd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e6b9cecd Diff: http://git-wip-us.apache.org/repos

[18/50] [abbrv] flink git commit: [FLINK-1201] [gelly] joinWithEdges implemented and tested

[FLINK-1201] [gelly] joinWithEdges implemented and tested Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e0c10ec8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e0c10ec8 Diff: http://git-wip-us.apache.org/repos/asf/f

[46/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors

http://git-wip-us.apache.org/repos/asf/flink/blob/081de39b/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/TestDegrees.java -- diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/Te

[37/50] [abbrv] flink git commit: [FLINK-1201] [gelly] refactored methods for Graph creation

[FLINK-1201] [gelly] refactored methods for Graph creation - constructors are now private - create() methods have been renamed and refactored to fromDataSet() - fromCollection() methods have been refactored - overall consistency in creating new Graph objects, using the constructor now in all plac

[33/50] [abbrv] flink git commit: [FLINK-1201] [gelly] LP example update: nodes get their id as initial label; if 2 labels have the same freq, select the one with the highest value

[FLINK-1201] [gelly] LP example update: nodes get their id as initial label; if 2 labels have the same freq, select the one with the highest value Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ccf1b804 Tree: http://git-wip-

[11/50] [abbrv] flink git commit: [FLINK-1201] [gelly] reduceOnNeighbors with vertex value

[FLINK-1201] [gelly] reduceOnNeighbors with vertex value Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4b2c96d9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4b2c96d9 Diff: http://git-wip-us.apache.org/repos/asf/fl

[22/50] [abbrv] flink git commit: [FLINK-1201] [gelly] use type hints for mapVertices, mapEdges and create

[FLINK-1201] [gelly] use type hints for mapVertices, mapEdges and create Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1d6a2001 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1d6a2001 Diff: http://git-wip-us.apache.

[40/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Renamed tests from TestXyz to XyzITCase

[FLINK-1201] [gelly] Renamed tests from TestXyz to XyzITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6296c394 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6296c394 Diff: http://git-wip-us.apache.org/repos/as

[23/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Updated JavaDoc for Graph class

[FLINK-1201] [gelly] Updated JavaDoc for Graph class Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b511932d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b511932d Diff: http://git-wip-us.apache.org/repos/asf/flink/

[04/50] [abbrv] flink git commit: [FLINK-1201] [gelly] get rid of Vertex to Tuple2 and Edge to Tuple3 conversions in runVertexCentricIteration

[FLINK-1201] [gelly] get rid of Vertex to Tuple2 and Edge to Tuple3 conversions in runVertexCentricIteration Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/935ad5a7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/935

[14/50] [abbrv] flink git commit: [FLINK-1201] [gelly] removed 2-arg Edge constructor

[FLINK-1201] [gelly] removed 2-arg Edge constructor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0bb7b7fc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0bb7b7fc Diff: http://git-wip-us.apache.org/repos/asf/flink/d

[21/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Expose the full Vertex and Edge object in filter functions

[FLINK-1201] [gelly] Expose the full Vertex and Edge object in filter functions Expose the full Vertex and Edge object in filter functions to allow filtering by key value: - subgraph() - filterOnVertices() - filterOnEdges() fixes #56 Project: http://git-wip-us.apache.org/repos/asf/flink/repo C

[36/50] [abbrv] flink git commit: [FLINK-1201] [gelly] updated music profiles example

[FLINK-1201] [gelly] updated music profiles example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ac477e8b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ac477e8b Diff: http://git-wip-us.apache.org/repos/asf/flink/d

[17/50] [abbrv] flink git commit: [FLINK-1201] [gelly] key and value types shouldn't be static fields; fixed #42

[FLINK-1201] [gelly] key and value types shouldn't be static fields; fixed #42 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3cf734f7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3cf734f7 Diff: http://git-wip-us.a

[39/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Renamed tests from TestXyz to XyzITCase

http://git-wip-us.apache.org/repos/asf/flink/blob/6296c394/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/ReduceOnEdgesMethodsITCase.java -- diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flin

[01/50] [abbrv] flink git commit: [FLINK-1201] [gelly] first take on neighborhood methods: OutEdges

Repository: flink Updated Branches: refs/heads/master 0a4c7694c -> c699557c1 [FLINK-1201] [gelly] first take on neighborhood methods: OutEdges Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16bdfab0 Tree: http://git-wip-u

[05/50] [abbrv] flink git commit: [FLINK-1201] [gelly] [sssp example] only update the vertex value if new distance is smaller

[FLINK-1201] [gelly] [sssp example] only update the vertex value if new distance is smaller Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d57a9d7a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d57a9d7a Diff: http:

[19/50] [abbrv] flink git commit: [FLINK-1201] [gelly] Fix bug in TestReduceOnNeighborMethods caused by object reuse

[FLINK-1201] [gelly] Fix bug in TestReduceOnNeighborMethods caused by object reuse Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b2c89cc8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b2c89cc8 Diff: http://git-wip

[27/50] [abbrv] flink git commit: [FLINK-1201] [gelly] filtering bad records and top track per user

[FLINK-1201] [gelly] filtering bad records and top track per user Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3cef2105 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3cef2105 Diff: http://git-wip-us.apache.org/rep

[03/50] [abbrv] flink git commit: [FLINK-1201] [gelly] set joins to sort-merge joins in isWeaklyConnected

[FLINK-1201] [gelly] set joins to sort-merge joins in isWeaklyConnected Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b0e17e39 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b0e17e39 Diff: http://git-wip-us.apache.o

[45/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added licence headers; added gelly to addons pom file; fixed checkstyle errors

http://git-wip-us.apache.org/repos/asf/flink/blob/081de39b/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/TestWeaklyConnected.java -- diff --git a/flink-staging/flink-gelly/src/test/java/org/apache/flink/graph

[28/50] [abbrv] flink git commit: [FLINK-1201] [gelly] replaced create with fromDataSet

[FLINK-1201] [gelly] replaced create with fromDataSet Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f99691c0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f99691c0 Diff: http://git-wip-us.apache.org/repos/asf/flink

[13/50] [abbrv] flink git commit: [FLINK-1201] [gelly] reduceOnNeighbors without vertex value

[FLINK-1201] [gelly] reduceOnNeighbors without vertex value Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d9b46c6e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d9b46c6e Diff: http://git-wip-us.apache.org/repos/asf

[31/50] [abbrv] flink git commit: [FLINK-1201] [gelly] create similar users graph

[FLINK-1201] [gelly] create similar users graph Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ff94da2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8ff94da2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/

[50/50] [abbrv] flink git commit: [FLINK-1201] [gelly] added missing javadocs

[FLINK-1201] [gelly] added missing javadocs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/902df078 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/902df078 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/902d

flink git commit: [FLINK-1496] [distributed runtime] Fix loss of events at uninitialized input channels

Repository: flink Updated Branches: refs/heads/master b88f909ce -> 0a4c7694c [FLINK-1496] [distributed runtime] Fix loss of events at uninitialized input channels This closes #380. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flin