flink git commit: FLINK-6474 Potential loss of precision in 32 bit integer multiplication

Repository: flink Updated Branches: refs/heads/master 38003c282 -> 12b941d36 FLINK-6474 Potential loss of precision in 32 bit integer multiplication Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/12b941d3 Tree:

[2/2] flink git commit: [FLINK-6471] [checkpoint] Fix RocksDBStateBackendTest#testCancelRunningSnapshot failing sporadically

[FLINK-6471] [checkpoint] Fix RocksDBStateBackendTest#testCancelRunningSnapshot failing sporadically Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8ffacb1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8ffacb1

[1/2] flink git commit: [FLINK-6475] [checkpoint] Incremental snapshots in RocksDB should not hold lock during async file upload

Repository: flink Updated Branches: refs/heads/master 63c04a516 -> 38003c282 [FLINK-6475] [checkpoint] Incremental snapshots in RocksDB should not hold lock during async file upload Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/8] flink git commit: [hotfix] [core] Catch InvalidClassException in TypeSerializerSerializationProxy

Repository: flink Updated Branches: refs/heads/master fe4e96a72 -> 63c04a516 [hotfix] [core] Catch InvalidClassException in TypeSerializerSerializationProxy Previously, the TypeSerializerSerializationProxy only uses the dummy ClassNotFoundDummyTypeSerializer as a placeholder in the case where

[2/8] flink git commit: [FLINK-6178] [core] Allow serializer upgrades for managed state

http://git-wip-us.apache.org/repos/asf/flink/blob/8aa5e057/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java -- diff --git

[8/8] flink git commit: [FLINK-6178] [core] Introduce TypeDeserializer interface for CompatibilityResult

[FLINK-6178] [core] Introduce TypeDeserializer interface for CompatibilityResult Previously, the CompatibilityResult class accepts a full-blown TypeSerializer for its convert deserializer, which will actually only ever be used for deserialization. This commit narrows down the interface by

[3/8] flink git commit: [FLINK-6178] [core] Allow serializer upgrades for managed state

http://git-wip-us.apache.org/repos/asf/flink/blob/8aa5e057/flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorBackendSerializationProxy.java -- diff --git

[7/8] flink git commit: [FLINK-6178] [core] Allow serializer upgrades for managed state

[FLINK-6178] [core] Allow serializer upgrades for managed state This commit adds the functionality of allowing serializer upgrades for Flink's managed state. It consists of 2 major changes: 1) new user-facing API in `TypeSerializer`, and 2) activate serializer upgrades in state backends. For 1)

[5/8] flink git commit: [FLINK-6178] [core] Allow serializer upgrades for managed state

http://git-wip-us.apache.org/repos/asf/flink/blob/8aa5e057/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java -- diff --git

[4/8] flink git commit: [FLINK-6178] [core] Allow serializer upgrades for managed state

http://git-wip-us.apache.org/repos/asf/flink/blob/8aa5e057/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerTest.java -- diff --git

[6/8] flink git commit: [FLINK-6178] [core] Allow serializer upgrades for managed state

http://git-wip-us.apache.org/repos/asf/flink/blob/8aa5e057/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/FloatSerializer.java -- diff --git

[1/3] flink git commit: [FLINK-6033] [table] Add support for SQL UNNEST.

Repository: flink Updated Branches: refs/heads/master e5b65a7fc -> fe4e96a72 [FLINK-6033] [table] Add support for SQL UNNEST. This closes #3793. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe4e96a7 Tree:

[3/3] flink git commit: [FLINK-6257] [table] Refactor OVER window tests.

[FLINK-6257] [table] Refactor OVER window tests. This closes #3697. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9f2293cf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9f2293cf Diff:

[2/3] flink git commit: [FLINK-6257] [table] Refactor OVER window tests.

http://git-wip-us.apache.org/repos/asf/flink/blob/9f2293cf/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/WindowAggregateTest.scala -- diff --git

[1/2] flink git commit: [FLINK-4821] Implement rescalable non-partitioned state for Kinesis Connector

Repository: flink Updated Branches: refs/heads/master fde4f9097 -> e5b65a7fc [FLINK-4821] Implement rescalable non-partitioned state for Kinesis Connector Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a05b574c Tree:

[2/2] flink git commit: [FLINK-4821] [kinesis] General improvements to rescalable FlinkKinesisConsumer

[FLINK-4821] [kinesis] General improvements to rescalable FlinkKinesisConsumer This commit adds some general improvements to the rescalable implementation of FlinkKinesisConsumer, including: - Refactor setup procedures in KinesisDataFetcher so that duplicate work isn't done on a restored run -