flink git commit: Commit for release 0.8.1

2015-02-10 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8.1-rc0 [created] 70943ad56 Commit 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/70943ad5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree

flink git commit: [FLINK-1492] Fix exceptions on blob store shutdown

2015-02-10 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-0.8 e01712111 -> 5b420d847 [FLINK-1492] Fix exceptions on blob store shutdown Conflicts: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java flink-runtime/src/main/java/org/apache/flink/runtime/blob/Bl

flink git commit: [FLINK-1492] Fix exceptions on blob store shutdown

2015-02-10 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 7407076d3 -> b88f909ce [FLINK-1492] Fix exceptions on blob store shutdown This closes #376 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b88f909c Tree: http://git-wi

[3/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

2015-02-10 Thread aljoscha
http://git-wip-us.apache.org/repos/asf/flink/blob/7407076d/flink-java/src/test/java/org/apache/flink/api/common/operators/base/CoGroupOperatorCollectionTest.java -- diff --git a/flink-java/src/test/java/org/apache/flink/api/common

[5/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

2015-02-10 Thread aljoscha
[FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes. - Abstract classes with fields are handled as POJO types. - Interfaces and abstract classes without fields are handled as generic types. This closes #236 This closes #316 Project: http://git-wip-us.apache.org/repos/a

[4/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

2015-02-10 Thread aljoscha
http://git-wip-us.apache.org/repos/asf/flink/blob/7407076d/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/PrimitiveArrayTypeInfo.java -- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Pri

[2/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

2015-02-10 Thread aljoscha
http://git-wip-us.apache.org/repos/asf/flink/blob/7407076d/flink-runtime/src/test/java/org/apache/flink/runtime/operators/drivers/AllGroupReduceDriverTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/o

[1/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

2015-02-10 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 6b402f43d -> 7407076d3 http://git-wip-us.apache.org/repos/asf/flink/blob/7407076d/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/temporaloperator/StreamJoinOperator.java ---