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:

[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:

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:

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:

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:

[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:

[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:

[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:

[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:

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:

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:

[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:

[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:

[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:

[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:

[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:

[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:

[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

[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:

[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:

[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:

[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

[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:

[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

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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

[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:

[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:

[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

[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

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: