You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by tr...@apache.org on 2021/02/11 17:40:15 UTC

[flink] branch master updated (b900746 -> aeeb617)

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from b900746  [hotfix] fix mobile layout on documentation
     add 8d9ffcd  [FLINK-21138] - User ClassLoader in KvStateServerHandler
     add 1e6d1d2  [FLINK-21138][tests] Register serializer instance in AbstractQueryableStateTestBase.testCustomKryoSerializerHandling
     add 9c04e64  [FLINK-21138] Fix classloader on QueryableStateClient
     add aeeb617  [FLINK-21138] Explicit Classloader in QueryableStateClient

No new revisions were added by this update.

Summary of changes:
 .../client/QueryableStateClient.java               |  26 +++++-
 .../flink-queryable-state-runtime/pom.xml          |   8 ++
 .../server/KvStateServerHandler.java               |  20 ++--
 .../itcases/AbstractQueryableStateTestBase.java    | 103 +++++++++++++++++++++
 .../flink/queryablestate/network/ClientTest.java   |   3 +-
 .../network/KvStateServerHandlerTest.java          |   3 +-
 .../apache/flink/runtime/query/KvStateEntry.java   |   9 +-
 .../flink/runtime/query/KvStateRegistry.java       |   6 +-
 .../flink/runtime/query/TaskKvStateRegistry.java   |  10 +-
 .../runtime/state/AbstractKeyedStateBackend.java   |   2 +-
 .../flink/runtime/query/KvStateRegistryTest.java   |  24 ++++-
 11 files changed, 194 insertions(+), 20 deletions(-)