Hi,
I've not configured any serializer in the descriptor. (Neither in flink
job, nor in state query client).
Which serializer should I use?
Jayant Ameta
On Thu, Oct 25, 2018 at 2:13 PM bupt_ljy <bupt_...@163.com> wrote:
> Hi,
>
> It seems that your codes are right. Are you sure that you’re using the
> same Serializer as the Flink program do? Could you show the serializer in
> descriptor?
>
>
>
> Jiayi Liao, Best
>
> Original Message
> *Sender:* Jayant Ameta<wittyam...@gmail.com>
> *Recipient:* user<user@flink.apache.org>
> *Date:* Thursday, Oct 25, 2018 14:17
> *Subject:* 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
>
