[1/4] flink git commit: [FLINK-5155] Deprecate ValueStateDescriptor constructors with default value
Repository: flink
Updated Branches:
refs/heads/release-1.2 af244aaed -> 8b7331409
[FLINK-5155] Deprecate ValueStateDescriptor constructors with default value
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b733140
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8b733140
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8b733140
Branch: refs/heads/release-1.2
Commit: 8b7331409cd1b903d2ca46b81f3265bc2973e659
Parents: b4c60a9
Author: Aljoscha Krettek
Authored: Wed Jan 11 12:14:13 2017 +0100
Committer: Aljoscha Krettek
Committed: Fri Jan 13 11:38:44 2017 +0100
--
.../state/RocksDBAsyncSnapshotTest.java | 6 +--
.../flink/api/common/state/ValueState.java | 10 ++--
.../api/common/state/ValueStateDescriptor.java | 50 +++-
.../AbstractKeyedCEPPatternOperator.java| 6 +--
.../runtime/query/QueryableStateClientTest.java | 2 +-
.../runtime/query/netty/KvStateClientTest.java | 2 +-
.../query/netty/KvStateServerHandlerTest.java | 10 ++--
.../runtime/query/netty/KvStateServerTest.java | 2 +-
.../runtime/state/StateBackendTestBase.java | 15 +++---
.../streaming/api/datastream/KeyedStream.java | 3 +-
.../api/operators/StreamGroupedFold.java| 2 +-
.../api/operators/StreamGroupedReduce.java | 2 +-
.../api/windowing/triggers/DeltaTrigger.java| 2 +-
.../operators/AbstractStreamOperatorTest.java | 2 +-
.../api/operators/ProcessOperatorTest.java | 2 +-
.../operators/StreamingRuntimeContextTest.java | 2 +-
.../api/operators/co/CoProcessOperatorTest.java | 4 +-
.../flink/streaming/api/scala/KeyedStream.scala | 3 +-
.../api/scala/function/StatefulFunction.scala | 2 +-
.../StatefulUDFSavepointMigrationITCase.java| 8 ++--
.../flink/test/query/QueryableStateITCase.java | 3 +-
21 files changed, 90 insertions(+), 48 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/flink/blob/8b733140/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
--
diff --git
a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
index 002b16d..70f74b0 100644
---
a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
+++
b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
@@ -371,8 +371,7 @@ public class RocksDBAsyncSnapshotTest {
ValueState state = getPartitionedState(
VoidNamespace.INSTANCE,
VoidNamespaceSerializer.INSTANCE,
- new ValueStateDescriptor<>("count",
-
StringSerializer.INSTANCE, "hello"));
+ new ValueStateDescriptor<>("count",
StringSerializer.INSTANCE));
}
@@ -383,8 +382,7 @@ public class RocksDBAsyncSnapshotTest {
ValueState state = getPartitionedState(
VoidNamespace.INSTANCE,
VoidNamespaceSerializer.INSTANCE,
- new ValueStateDescriptor<>("count",
-
StringSerializer.INSTANCE, "hello"));
+ new ValueStateDescriptor<>("count",
StringSerializer.INSTANCE));
state.update(element.getValue());
}
http://git-wip-us.apache.org/repos/asf/flink/blob/8b733140/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
--
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
b/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
index de3250a..7e42daa 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
@@ -45,8 +45,11 @@ public interface ValueState extends State {
* operator instance. If state partitioning is applied, the value
returned
* depends on the current operator input, as the operator maintains an
* independent state for each partition.
-*
-* @return The operator state value corresponding to the
flink git commit: [FLINK-5155] Deprecate ValueStateDescriptor constructors with default value
Repository: flink
Updated Branches:
refs/heads/master 51a357351 -> 7a2d3bea9
[FLINK-5155] Deprecate ValueStateDescriptor constructors with default value
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a2d3bea
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a2d3bea
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7a2d3bea
Branch: refs/heads/master
Commit: 7a2d3bea96d262de5cb963003b92833b27346af0
Parents: 51a3573
Author: Aljoscha Krettek
Authored: Wed Jan 11 12:14:13 2017 +0100
Committer: Aljoscha Krettek
Committed: Fri Jan 13 11:30:57 2017 +0100
--
.../state/RocksDBAsyncSnapshotTest.java | 6 +--
.../flink/api/common/state/ValueState.java | 10 ++--
.../api/common/state/ValueStateDescriptor.java | 50 +++-
.../AbstractKeyedCEPPatternOperator.java| 6 +--
.../runtime/query/QueryableStateClientTest.java | 2 +-
.../runtime/query/netty/KvStateClientTest.java | 2 +-
.../query/netty/KvStateServerHandlerTest.java | 10 ++--
.../runtime/query/netty/KvStateServerTest.java | 2 +-
.../runtime/state/StateBackendTestBase.java | 15 +++---
.../streaming/api/datastream/KeyedStream.java | 3 +-
.../api/operators/StreamGroupedFold.java| 2 +-
.../api/operators/StreamGroupedReduce.java | 2 +-
.../api/windowing/triggers/DeltaTrigger.java| 2 +-
.../operators/AbstractStreamOperatorTest.java | 2 +-
.../api/operators/ProcessOperatorTest.java | 2 +-
.../operators/StreamingRuntimeContextTest.java | 2 +-
.../api/operators/co/CoProcessOperatorTest.java | 4 +-
.../flink/streaming/api/scala/KeyedStream.scala | 3 +-
.../api/scala/function/StatefulFunction.scala | 2 +-
.../StatefulUDFSavepointMigrationITCase.java| 8 ++--
.../flink/test/query/QueryableStateITCase.java | 3 +-
21 files changed, 90 insertions(+), 48 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/flink/blob/7a2d3bea/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
--
diff --git
a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
index 002b16d..70f74b0 100644
---
a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
+++
b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
@@ -371,8 +371,7 @@ public class RocksDBAsyncSnapshotTest {
ValueState state = getPartitionedState(
VoidNamespace.INSTANCE,
VoidNamespaceSerializer.INSTANCE,
- new ValueStateDescriptor<>("count",
-
StringSerializer.INSTANCE, "hello"));
+ new ValueStateDescriptor<>("count",
StringSerializer.INSTANCE));
}
@@ -383,8 +382,7 @@ public class RocksDBAsyncSnapshotTest {
ValueState state = getPartitionedState(
VoidNamespace.INSTANCE,
VoidNamespaceSerializer.INSTANCE,
- new ValueStateDescriptor<>("count",
-
StringSerializer.INSTANCE, "hello"));
+ new ValueStateDescriptor<>("count",
StringSerializer.INSTANCE));
state.update(element.getValue());
}
http://git-wip-us.apache.org/repos/asf/flink/blob/7a2d3bea/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
--
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
b/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
index de3250a..7e42daa 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/state/ValueState.java
@@ -45,8 +45,11 @@ public interface ValueState extends State {
* operator instance. If state partitioning is applied, the value
returned
* depends on the current operator input, as the operator maintains an
* independent state for each partition.
-*
-* @return The operator state value corresponding to the current i
