[flink] Git Push Summary

2016-01-19 Thread chesnay
Repository: flink Updated Branches: refs/heads/2686_json_exchange [deleted] 49f5a0179

[3/3] flink git commit: [FLINK-3014] Replace InStr.read() calls with DataInStr.readFully()

2016-01-19 Thread chesnay
[FLINK-3014] Replace InStr.read() calls with DataInStr.readFully() This closes #1432 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c7ada8d7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c7ada8d7 Diff: http://git-w

[2/3] flink git commit: [FLINK-3057] Bidrectional plan connection

2016-01-19 Thread chesnay
[FLINK-3057] Bidrectional plan connection Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fc4d9469 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fc4d9469 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fc4d94

[1/3] flink git commit: [FLINK-3057] Bidrectional plan connection

2016-01-19 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 0ac5d4020 -> c7ada8d78 http://git-wip-us.apache.org/repos/asf/flink/blob/fc4d9469/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/streaming/data/PythonStreamer.java -

flink git commit: [FLINK-3165] [py] Windows OS support

2016-01-19 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 018f1fee9 -> 0ac5d4020 [FLINK-3165] [py] Windows OS support This closes #1454 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ac5d402 Tree: http://git-wip-us.apache.o

flink git commit: [FLINK-3241] Fix Scala 2.11 build by moving some flink-table classes into the right directory

2016-01-19 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 046f044df -> 018f1fee9 [FLINK-3241] Fix Scala 2.11 build by moving some flink-table classes into the right directory Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/01

flink git commit: [FLINK-2831] [Storm Compatibility Tests] Fixed instable test

2016-01-19 Thread mjsax
Repository: flink Updated Branches: refs/heads/master 82ff716cb -> 046f044df [FLINK-2831] [Storm Compatibility Tests] Fixed instable test This closes #1519. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/046f044d Tree: h

flink git commit: [FLINK-3220] Remove javax.servlet exclusions from hadoop2 fat jar to fix Flink on HDP

2016-01-19 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 8f0c47df0 -> 82ff716cb [FLINK-3220] Remove javax.servlet exclusions from hadoop2 fat jar to fix Flink on HDP Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82ff716c T

flink git commit: [FLINK-3241] Fix SNAPSHOT deployment for Scala 2.11

2016-01-19 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 544abb937 -> 8f0c47df0 [FLINK-3241] Fix SNAPSHOT deployment for 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/8f0c47df Tree: http://git-wip-us.apache.org/r

[2/2] flink git commit: [Refactor] [DataSet] Refactor key selector translation in DataSet API. Clean up several compiler warnings.

2016-01-19 Thread fhueske
[Refactor] [DataSet] Refactor key selector translation in DataSet API. Clean up several compiler warnings. This closes #1509 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/544abb93 Tree: http://git-wip-us.apache.org/repos/as

[1/2] flink git commit: [Refactor] [DataSet] Refactor key selector translation in DataSet API. Clean up several compiler warnings.

2016-01-19 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 153a67881 -> 544abb937 http://git-wip-us.apache.org/repos/asf/flink/blob/544abb93/flink-java/src/main/java/org/apache/flink/api/java/operators/ReduceOperator.java -- diff --