Repository: flink Updated Branches: refs/heads/master dd7311ed8 -> 1f464c27e
[FLINK-5618][docs] createSerializer must actually get a non-null ExecutionConfig This closes #3279. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1f464c27 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1f464c27 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1f464c27 Branch: refs/heads/master Commit: 1f464c27ef252e7513caf5640acf7f5e6225609f Parents: dd7311e Author: Nico Kruber <[email protected]> Authored: Mon Feb 6 17:19:28 2017 +0100 Committer: Ufuk Celebi <[email protected]> Committed: Mon Feb 6 18:28:13 2017 +0100 ---------------------------------------------------------------------- docs/dev/stream/queryable_state.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/1f464c27/docs/dev/stream/queryable_state.md ---------------------------------------------------------------------- diff --git a/docs/dev/stream/queryable_state.md b/docs/dev/stream/queryable_state.md index 6c34536..728d4d6 100644 --- a/docs/dev/stream/queryable_state.md +++ b/docs/dev/stream/queryable_state.md @@ -214,9 +214,9 @@ config.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, queryPort); QueryableStateClient client = new QueryableStateClient(config); final TypeSerializer<Long> keySerializer = - TypeInformation.of(new TypeHint<Long>() {}).createSerializer(null); + TypeInformation.of(new TypeHint<Long>() {}).createSerializer(new ExecutionConfig()); final TypeSerializer<Tuple2<Long, Long>> valueSerializer = - TypeInformation.of(new TypeHint<Tuple2<Long, Long>>() {}).createSerializer(null); + TypeInformation.of(new TypeHint<Tuple2<Long, Long>>() {}).createSerializer(new ExecutionConfig()); final byte[] serializedKey = KvStateRequestSerializer.serializeKeyAndNamespace(
