keep us posted if that works 😊
>
>
>
> Thias
>
>
>
>
>
> *From:* Guowei Ma
> *Sent:* Freitag, 24. September 2021 09:34
> *To:* Caizhi Weng
> *Cc:* Dan Hill ; user
> *Subject:* Re: byte array as keys in Flink
>
>
>
> Hi Hill
>
>
>
> As far
us posted if that works 😊
Thias
From: Guowei Ma
Sent: Freitag, 24. September 2021 09:34
To: Caizhi Weng
Cc: Dan Hill ; user
Subject: Re: byte array as keys in Flink
Hi Hill
As far as I know you could not use byte[] as a keyby. You could find more
information from [1].
[1]
https
Hi Hill
As far as I know you could not use byte[] as a keyby. You could find more
information from [1].
[1]
https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/datastream/operators/overview/#keyby
Best,
Guowei
On Fri, Sep 24, 2021 at 3:15 PM Caizhi Weng wrote:
> Hi!
>
> It de
Hi!
It depends on the state backend you use. For example if you use a heap
memory state backend it is backed by a hash map and it uses the hash code
of byte[] to compare the two byte[] (see HeapMapState#put). However for
rocksdb state backend it uses the serialized bytes (that is to say, the
conte
*Context*
I want to perform joins based on UUIDs. String version is less efficient
so I figured I should use the byte[] version. I did a shallow dive into
the Flink code I'm not sure it's safe to use byte[] as a key (since it uses
object equals/hashcode).
*Request*
How do other Flink devs do for
