flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [FLINK-5618][docs] createSerializer must actually get a non-null ExecutionConfig
Date Mon, 06 Feb 2017 17:28:26 GMT
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 <nico@data-artisans.com>
Authored: Mon Feb 6 17:19:28 2017 +0100
Committer: Ufuk Celebi <uce@apache.org>
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(


Mime
View raw message