flink git commit: [FLINK-1440] [docs] Fix missing plan visualizer image.

Repository: flink Updated Branches: refs/heads/master 96585f149 - 095dc4a54 [FLINK-1440] [docs] Fix missing plan visualizer image. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/095dc4a5 Tree:

[5/9] flink git commit: [FLINK-1193][java-api][scala-api] Fix copy method for ObjectArraySerializer

[FLINK-1193][java-api][scala-api] Fix copy method for ObjectArraySerializer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9906cbaa Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9906cbaa Diff:

[8/9] flink git commit: [FLINK-1165] [java-api] Rename createCollectionEnvironment to not break existing APIs.

[FLINK-1165] [java-api] Rename createCollectionEnvironment to not break existing APIs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aeec128b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/aeec128b Diff:

[9/9] flink git commit: [java api] Fix various compiler warnings through code cleanups

[java api] Fix various compiler warnings through code cleanups Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80646b57 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/80646b57 Diff:

[6/9] flink git commit: [FLINK-1464] [java-api] Added ResultTypeQueryable interface implementation to TypeSerializerInputFormat.

[FLINK-1464] [java-api] Added ResultTypeQueryable interface implementation to TypeSerializerInputFormat. This closes #349 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e3f6c9ba Tree:

[1/9] flink git commit: Improved exception for missing type of InputFormat

Repository: flink Updated Branches: refs/heads/master 94c3e9c08 - 80646b57a Improved exception for missing type of InputFormat This closes #351 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2a7e40bb Tree:

[5/7] flink git commit: [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure.

http://git-wip-us.apache.org/repos/asf/flink/blob/db1b8b99/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduleWithCoLocationHintTest.java -- diff --git

[2/2] flink git commit: [tests] Minor cleanup of compiler warnings.

[tests] Minor cleanup of compiler warnings. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6cc35837 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6cc35837 Diff:

[12/17] flink git commit: [docs] Prepare documentation for 0.8 release

[docs] Prepare documentation for 0.8 release Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/839fd030 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/839fd030 Diff:

[15/17] flink git commit: [FLINK-1229][FLINK-1206] [web frontend] Synchronize webclient arguments with command line and add default parallelism.

[FLINK-1229][FLINK-1206] [web frontend] Synchronize webclient arguments with command line and add default parallelism. This closes #291 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3072ba5 Tree:

[4/4] flink git commit: [FLINK-1416] Fix dependency versions in quickstart archetypes

[FLINK-1416] Fix dependency versions in quickstart archetypes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29c54a20 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/29c54a20 Diff:

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

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

[3/3] flink git commit: [core] [java api] Various code cleanup and fixed for warnings.

[core] [java api] Various code cleanup and fixed for warnings. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6ba5fcdf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6ba5fcdf Diff:

flink git commit: Update LICENSE and NOTICE files for release 0.8.1

Repository: flink Updated Branches: refs/heads/release-0.8 5a5ec524a - bab2d4992 Update LICENSE and NOTICE files for release 0.8.1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bab2d499 Tree:

flink git commit: [FLINK-1437][Java API] Fixes copy() methods in PojoSerializer for null values

Repository: flink Updated Branches: refs/heads/release-0.8 68a0478a8 - 5a5ec524a [FLINK-1437][Java API] Fixes copy() methods in PojoSerializer for null values This closes #342 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-1483] IOManager puts temp files in dedicated directory and removes that on shutdown

Repository: flink Updated Branches: refs/heads/release-0.8 af50e5619 - 8038d227d [FLINK-1483] IOManager puts temp files in dedicated directory and removes that on shutdown Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests.

[FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cfce493f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cfce493f Diff:

flink git commit: [FLINK-1561] [build system] Use a fresh fork for each integration test run

Repository: flink Updated Branches: refs/heads/master 30e3893bd - 47fed3dfb [FLINK-1561] [build system] Use a fresh fork for each integration test run This closes #412 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests.

Repository: flink Updated Branches: refs/heads/master 47fed3dfb - cfce493fe http://git-wip-us.apache.org/repos/asf/flink/blob/cfce493f/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java -- diff

flink git commit: [FLINK-1557] Move JobManager web frontend server out of JobManager actor

Repository: flink Updated Branches: refs/heads/master 743399a41 - c1e326707 [FLINK-1557] Move JobManager web frontend server out of JobManager actor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1e32670 Tree:

[1/2] flink git commit: [FLINK-1498] [tests] Better error messages in external sort tests

Repository: flink Updated Branches: refs/heads/master 6ddfcb402 - 52d9806ba [FLINK-1498] [tests] Better error messages in external sort tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/52d9806b Tree:

[2/2] flink git commit: [FLINK-1498] [tests] Set a minimal JVM size to prevent NIO memory problems

[FLINK-1498] [tests] Set a minimal JVM size to prevent NIO memory problems Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30a52a0c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30a52a0c Diff:

[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-1479] [runtime] Spawned threads in sorter get the same context class loader as the parent thread

Repository: flink Updated Branches: refs/heads/release-0.8 aca62100f - 44b799d6e [FLINK-1479] [runtime] Spawned threads in sorter get the same context class loader as the parent thread Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-1478] [jobmanager] Add deterministic strictly local split assignment (part 2)

[FLINK-1478] [jobmanager] Add deterministic strictly local split assignment (part 2) This closes #375 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4386620c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4386620c

[1/2] flink git commit: [FLINK-1478] [jobmanager] Add deterministic strictly local split assignment (part 1)

Repository: flink Updated Branches: refs/heads/master 8b3805ba5 - 4386620c0 [FLINK-1478] [jobmanager] Add deterministic strictly local split assignment (part 1) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6fcef7df

flink git commit: [FLINK-1478] [jobmanager] (addendum) Add eager check for null as input split host name

Repository: flink Updated Branches: refs/heads/master 4386620c0 - c1e1aca21 [FLINK-1478] [jobmanager] (addendum) Add eager check for null as input split host name Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1e1aca2

[2/2] flink git commit: [FLINK-1487] [runtime][tests] Fixes SchedulerIsolatedTasksTest.testScheduleQueueing by waiting for the released resources to registered at the Scheduler again.

[FLINK-1487] [runtime][tests] Fixes SchedulerIsolatedTasksTest.testScheduleQueueing by waiting for the released resources to registered at the Scheduler again. This closes #398 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/4] flink git commit: [project] Added additional IntelliJ file ignores

[project] Added additional IntelliJ file ignores This closes #483 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2eea012e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2eea012e Diff:

[4/4] flink git commit: [FLINK-1705] [taskmanager] Fix hostname lookup.

[FLINK-1705] [taskmanager] Fix hostname lookup. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5308ac83 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5308ac83 Diff:

[3/8] flink git commit: [FLINK-1671] [tests] Rename ExecutionMode in MultiProgramTestBase to TestExecutionMode

[FLINK-1671] [tests] Rename ExecutionMode in MultiProgramTestBase to TestExecutionMode ... to avoid name clashes with the program execution mode. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/47827702 Tree:

[5/8] flink git commit: [FLINK-1671] [optimizer] Add data exchange mode to optimizer classes

http://git-wip-us.apache.org/repos/asf/flink/blob/1c50d87c/flink-compiler/src/test/java/org/apache/flink/compiler/dataexchange/DataExchangeModeForwardTest.java -- diff --git

[4/8] flink git commit: [FLINK-1671] [core] Add execution mode to execution config

[FLINK-1671] [core] Add execution mode to execution config Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7f8e1566 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7f8e1566 Diff:

[7/8] flink git commit: [FLINK-1671] [optimizer] Add data exchange mode to optimizer classes

[FLINK-1671] [optimizer] Add data exchange mode to optimizer classes This closes #487 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1c50d87c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1c50d87c Diff:

[8/8] flink git commit: [FLINK-1671] [jobmanager] Rename JobManager's ExecutionMode to JobManagerMode

[FLINK-1671] [jobmanager] Rename JobManager's ExecutionMode to JobManagerMode This is done to avoid name conflicts with the overloaded type name ExecutionMode. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/361c90a8 Tree:

[2/8] flink git commit: [FLINK-1671] [tests] Rename ExecutionMode in MultiProgramTestBase to TestExecutionMode

http://git-wip-us.apache.org/repos/asf/flink/blob/47827702/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/ReduceITCase.scala -- diff --git

[6/8] flink git commit: [FLINK-1671] [optimizer] Add data exchange mode to optimizer classes

http://git-wip-us.apache.org/repos/asf/flink/blob/1c50d87c/flink-compiler/src/main/java/org/apache/flink/compiler/dataproperties/GlobalProperties.java -- diff --git

[3/4] flink git commit: [FLINK-1342] Use maven-shade-plugin in quickstarts to build fat-jar

[FLINK-1342] Use maven-shade-plugin in quickstarts to build fat-jar This closes #486 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/04a73883 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/04a73883 Diff:

[2/4] flink git commit: [FLINK-1414] Move quickstarts to website

[FLINK-1414] Move quickstarts to website Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9b4f483f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9b4f483f Diff:

flink git commit: [FLINK-1721] [yarn] Temporarily disable search for exceptions in the YARN log due to akka bug

Repository: flink Updated Branches: refs/heads/master ceea93d41 - 1b6903216 [FLINK-1721] [yarn] Temporarily disable search for exceptions in the YARN log due to akka bug Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[11/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java -- diff --git

[41/53] [abbrv] flink git commit: [FLINK-441] [optimizer] Removed obsolete plan validator

[FLINK-441] [optimizer] Removed obsolete plan validator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c91fb7c2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c91fb7c2 Diff:

[25/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-compiler/src/test/java/org/apache/flink/optimizer/ReduceAllTest.java -- diff --git a/flink-compiler/src/test/java/org/apache/flink/optimizer/ReduceAllTest.java

[37/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-compiler/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java -- diff --git

[27/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-compiler/src/test/java/org/apache/flink/optimizer/FeedbackPropertiesMatchTest.java -- diff --git

flink git commit: [runtime] Slight improvements and tests in the Buffer class

Repository: flink Updated Branches: refs/heads/master 798823597 - 55db268f0 [runtime] Slight improvements and tests in the Buffer class Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/55db268f Tree:

[2/2] flink git commit: [FLINK-1760] [maven] Added Scala version profiles to support building with Scala 2.11

[FLINK-1760] [maven] Added Scala version profiles to support building with Scala 2.11 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2cd5e93d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2cd5e93d Diff:

[1/2] flink git commit: [FLINK-1760] Add travis profiles for scala-2.11 builds.

Repository: flink Updated Branches: refs/heads/master 684ec7ef5 - 798823597 [FLINK-1760] Add travis profiles for scala-2.11 builds. This closes #477 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/79882359 Tree:

[1/4] flink git commit: [streaming] Improve comments for source functions. Minor cleanups.

Repository: flink Updated Branches: refs/heads/master ff60ecfb2 - 244e5d5f8 [streaming] Improve comments for source functions. Minor cleanups. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f372358b Tree:

[4/4] flink git commit: [streaming] Add test that runs streaming with fault tolerance

[streaming] Add test that runs streaming with fault tolerance Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/244e5d5f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/244e5d5f Diff:

[22/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-compiler/src/test/java/org/apache/flink/optimizer/dataproperties/RequestedGlobalPropertiesFilteringTest.java -- diff --git

[14/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossStreamOuterSecondDescriptor.java -- diff --git

[10/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/main/java/org/apache/flink/optimizer/postpass/GenericFlatTypePostPass.java -- diff --git

[08/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/test/java/org/apache/flink/optimizer/CompilerTestBase.java -- diff --git

[21/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-compiler/src/test/java/org/apache/flink/optimizer/java/WorksetIterationsJavaApiCompilerTest.java -- diff --git

[23/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-compiler/src/test/java/org/apache/flink/optimizer/dataexchange/DataExchangeModeForwardTest.java -- diff --git

[12/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/WorksetIterationPlanNode.java -- diff --git

[18/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/JoinNode.java -- diff --git a/flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/JoinNode.java

[31/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-compiler/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java -- diff --git

[46/53] [abbrv] flink git commit: [FLINK-441] [optimizer] Rename Pact* and Nephele* classes

http://git-wip-us.apache.org/repos/asf/flink/blob/a9150b30/flink-tests/src/test/java/org/apache/flink/test/compiler/iterations/IterativeKMeansTest.java -- diff --git

[19/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/BulkIterationNode.java -- diff --git

[43/53] [abbrv] flink git commit: [FLINK-441] [optimizer] Remove obsolete and unused utility classes

[FLINK-441] [optimizer] Remove obsolete and unused utility classes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9d222ca1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9d222ca1 Diff:

[15/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedLocalProperties.java -- diff --git

[02/53] [abbrv] flink git commit: [optimizer] Rename optimizer project to flink-optimizer (previously flink-compiler)

http://git-wip-us.apache.org/repos/asf/flink/blob/633b0d6a/flink-optimizer/src/test/java/org/apache/flink/optimizer/dataproperties/RequestedGlobalPropertiesFilteringTest.java -- diff --git

[4/4] flink git commit: [hotfix] Fix erroneous testing log4j configuration for flink-runtime

[hotfix] Fix erroneous testing log4j configuration for flink-runtime Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0df5601a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0df5601a Diff:

[05/14] flink git commit: [FLINK-1638] [streaming] RegisterState removed from datastream + CoRecordReader barrier test added

[FLINK-1638] [streaming] RegisterState removed from datastream + CoRecordReader barrier test added Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/490fa700 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/490fa700

[06/14] flink git commit: [FLINK-1638] [streaming] Barrier sync added to CoRecordReader, barrier tests

[FLINK-1638] [streaming] Barrier sync added to CoRecordReader, barrier tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5327d56d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5327d56d Diff:

[03/14] flink git commit: [FLINK-1638] [streaming] Vertex level fault tolerance and state monitor

[FLINK-1638] [streaming] Vertex level fault tolerance and state monitor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5061edb8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5061edb8 Diff:

[14/14] flink git commit: [FLINK-1638] [jobmanager] Cleanups in the ExecutionGraph for streaming fault tolerance

[FLINK-1638] [jobmanager] Cleanups in the ExecutionGraph for streaming fault tolerance Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2bba2b3f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2bba2b3f Diff:

  1   2   3   4   5   6   7   8   9   10   >