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

Posted to user@flink.apache.org by Jayant Ameta <wi...@gmail.com> on 2018/10/25 06:17:22 UTC

Queryable state when key is UUID - getting Kyro Exception

I get Kyro exception when querying the state.

Key: UUID
MapState<UUID, String>

Client code snippet:

CompletableFuture<MapState<UUID, String>> resultFuture =
    client.getKvState(JobID.fromHexString("c7b8af14b8afacf4fac16cdd0da7e997"),
"rule",
        UUID.fromString("3b3f17a0-d81a-11e8-bb91-7fd1412de84d"),
        TypeInformation.of(new TypeHint<UUID>() {}), descriptor);
MapState<UUID, String> mapState = resultFuture.get(10, TimeUnit.SECONDS);


Any better way to query it?


Jayant Ameta