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

2015-01-24 Thread sewen
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

2015-02-03 Thread sewen
[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.

2015-02-03 Thread sewen
[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

2015-02-03 Thread sewen
[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.

2015-02-03 Thread sewen
[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

2015-02-03 Thread sewen
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:

[4/9] flink git commit: [FLINK-1193][java-api][scala-api] Complete support for multidimensional arrays

2015-02-03 Thread sewen
[FLINK-1193][java-api][scala-api] Complete support for multidimensional arrays This closes #348 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/57b3e9f9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/57b3e9f9 Diff:

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

2015-02-03 Thread sewen
[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: http://git-wip-us.apache.org/repos/asf/flink/commit/fb7ce0e3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fb7ce0e3 Diff:

flink git commit: [docs] add documentation for FLink GCE setup using bdutil

2015-02-05 Thread sewen
Repository: flink Updated Branches: refs/heads/master 0ab9d4665 - f361e7d00 [docs] add documentation for FLink GCE setup using bdutil This closes #361 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f361e7d0 Tree:

[4/7] flink git commit: [FLINK-1442] [runtime] Minor code cleanups in MemoryArchivist

2015-02-05 Thread sewen
[FLINK-1442] [runtime] Minor code cleanups in MemoryArchivist Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/56b7f85b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/56b7f85b Diff:

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

2015-02-05 Thread sewen
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

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

2015-02-06 Thread sewen
Repository: flink Updated Branches: refs/heads/master f6c85bc59 - a07d59d72 [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/a07d59d7

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

2015-01-18 Thread sewen
[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

2015-01-18 Thread sewen
[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.

2015-01-18 Thread sewen
[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:

[17/17] flink git commit: Commit for year 2015

2015-01-18 Thread sewen
Commit for year 2015 Updated NOTICE files Updated inceptionYear in pom Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e818729e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e818729e Diff:

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

2015-01-18 Thread sewen
[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/4] flink git commit: [FLINK-1399] Fix kryo registration of types and make sure that tags are assigned for registered types.

2015-01-18 Thread sewen
[FLINK-1399] Fix kryo registration of types and make sure that tags are assigned for registered types. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a0b6af20 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a0b6af20

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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
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

2015-02-11 Thread sewen
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-1542] Test case at BlobUtilsTest should not assume user could not create new item in root directory

2015-02-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master 6ba5fcdf8 - 5ab1f1f19 [FLINK-1542] Test case at BlobUtilsTest should not assume user could not create new item in root directory Sometimes, user that run tests could have write access to root dir such as creating /cannot-create-this is

[2/3] flink git commit: [FLINK-1559] [akka] Normalize all akka URLs to use IP addresses rather than hostnames

2015-02-16 Thread sewen
[FLINK-1559] [akka] Normalize all akka URLs to use IP addresses rather than hostnames Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2dcff4c1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2dcff4c1 Diff:

[1/3] flink git commit: [FLINK-1454] [job client] Improve error handling for failed connections between JobClient and JobManager

2015-02-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master e30a2ea2f - 6ba5fcdf8 [FLINK-1454] [job client] Improve error handling for failed connections between JobClient and JobManager Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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

2015-02-16 Thread sewen
[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

2015-02-12 Thread sewen
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-1432] [runtime] Make memory segment release robust against concurrent modifications of the collection

2015-02-12 Thread sewen
Repository: flink Updated Branches: refs/heads/master 081a7ddda - fab1bd9dc [FLINK-1432] [runtime] Make memory segment release robust against concurrent modifications of the collection Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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

2015-02-12 Thread sewen
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: [tests] Fix hostname escaping for older akka versions.

2015-02-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master 5ab1f1f19 - 743399a41 [tests] Fix hostname escaping for older akka versions. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/743399a4 Tree:

[6/9] flink git commit: [FLINK-1556] [runtime] Fails jobs properly in case of a job submission exception

2015-02-19 Thread sewen
[FLINK-1556] [runtime] Fails jobs properly in case of a job submission exception This closes #422 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4ff91cd7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4ff91cd7

[5/9] flink git commit: [tests] Add integration test for restart recovery

2015-02-19 Thread sewen
[tests] Add integration test for restart recovery Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7d80711d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7d80711d Diff:

[7/9] flink git commit: [Flink-1484] [runtime] JobManager sends an explicit disconnect message to the registered TaskManagers in case of a graceful shutdown.

2015-02-19 Thread sewen
[Flink-1484] [runtime] JobManager sends an explicit disconnect message to the registered TaskManagers in case of a graceful shutdown. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5ac1911a Tree:

[9/9] flink git commit: [tests] Cleanup style and timeouts in recovery restart tests

2015-02-19 Thread sewen
[tests] Cleanup style and timeouts in recovery restart tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a51c02f6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a51c02f6 Diff:

[4/9] flink git commit: [FLINK-1584] [tests] Move logic for failure detection test cluster into test classes

2015-02-19 Thread sewen
[FLINK-1584] [tests] Move logic for failure detection test cluster into test classes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dbf589ad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dbf589ad Diff:

[1/9] flink git commit: [FLINK-1585] [tests] Fix mini clusters to respect memory and buffer configurations and improve relative memory computation.

2015-02-19 Thread sewen
Repository: flink Updated Branches: refs/heads/master 877cf - a51c02f6e [FLINK-1585] [tests] Fix mini clusters to respect memory and buffer configurations and improve relative memory computation. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: Remove extra space after open parenthesis in InstanceConnectionInfo#toString.

2015-02-19 Thread sewen
Repository: flink Updated Branches: refs/heads/master 42578b67a - c1a334e1c Remove extra space after open parenthesis in InstanceConnectionInfo#toString. This closes #416 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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

2015-02-19 Thread sewen
[FLINK-1483] IOManager puts temp files in dedicated directory and removes that on shutdown This closes #417 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1a334e1 Tree:

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

2015-02-19 Thread sewen
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/3] flink git commit: [FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests.

2015-02-20 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/b5e1c5a1/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java -- diff --git

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

2015-02-20 Thread sewen
[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/b5e1c5a1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5e1c5a1 Diff:

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

2015-02-18 Thread sewen
[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

2015-02-18 Thread sewen
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.

2015-02-18 Thread sewen
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: [blob manager] Fix flakey test.

2015-02-18 Thread sewen
Repository: flink Updated Branches: refs/heads/master e6754a6da - 42578b67a [blob manager] Fix flakey test. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42578b67 Tree:

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

2015-02-17 Thread sewen
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

2015-02-09 Thread sewen
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

2015-02-09 Thread sewen
[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:

[1/2] flink git commit: [FLINK-1529] [jobmanager] Improve error handling on JobManager startup

2015-02-13 Thread sewen
Repository: flink Updated Branches: refs/heads/master 6bec22877 - 0a22b71c8 [FLINK-1529] [jobmanager] Improve error handling on JobManager startup This closes #385 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1dafd810

[2/2] flink git commit: [FLINK-1532] [tests] Fix spurious failure in AggregatorsITCase (plus minor cleanups)

2015-02-13 Thread sewen
[FLINK-1532] [tests] Fix spurious failure in AggregatorsITCase (plus minor cleanups) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a22b71c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0a22b71c Diff:

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

2015-02-11 Thread sewen
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:

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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
[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

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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
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

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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
[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

2015-02-11 Thread sewen
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

2015-02-11 Thread sewen
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

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

2015-02-11 Thread sewen
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

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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
[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:

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

2015-02-11 Thread sewen
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

flink git commit: [FLINK-1479] [runtime] Spawned threads in sorter get the same context class loader as the parent thread

2015-02-09 Thread sewen
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)

2015-02-09 Thread sewen
[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)

2015-02-09 Thread sewen
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

2015-02-09 Thread sewen
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.

2015-02-15 Thread sewen
[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:

[1/2] flink git commit: [FLINK-1545] [runtime][tests] Fixes AsynchronousFileIOChannelsTest.testExceptionForwardsToClose by introducing additional error check in AsynchronousFileIOChannel.close method

2015-02-15 Thread sewen
Repository: flink Updated Branches: refs/heads/master da8c02b91 - 1b40386d3 [FLINK-1545] [runtime][tests] Fixes AsynchronousFileIOChannelsTest.testExceptionForwardsToClose by introducing additional error check in AsynchronousFileIOChannel.close method This closes #399 Project:

[2/4] flink git commit: [runtime] Increase timeout in pipeline queue tests, to increase test robustness on CI servers

2015-02-05 Thread sewen
[runtime] Increase timeout in pipeline queue tests, to increase test robustness on CI servers Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7afcf003 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7afcf003 Diff:

[3/4] flink git commit: [FLINK-1478] [jobmanager] Scheduler support for external location constraints

2015-02-05 Thread sewen
[FLINK-1478] [jobmanager] Scheduler support for external location constraints Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/970b2b7a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/970b2b7a Diff:

[4/4] flink git commit: [FLINK-1478] [jobmanager] Stubs to support eager input split assignment on task creation

2015-02-05 Thread sewen
[FLINK-1478] [jobmanager] Stubs to support eager input split assignment on task creation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a9ac7aab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a9ac7aab Diff:

  1   2   3   4   5   6   7   8   9   10   >