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