class java.util.UUID is not a valid POJO type

[Leonard Wolters-2]

Hi,

Quick question. I'm currently implementing our Machine Learning into
Spark using the Scala interface.
Do I understand correctly that when using scala only, you can only use
primitive types? How can I register
the UUID class in order to get supported for (de)serializing between the
nodes?

BTW: Would love to see the UUID class get 'native' support.

Keep on going the good work guys!,

Leonard

[Till Rohrmann]

Hi Leonard,

the UUID class cannot be treated as a POJO by Flink, because it is lacking the public getters and setters for mostSigBits and leastSigBits. However, it should be possible to treat it as a generic type. I think the difference is that you cannot use key expressions and key indices to define join keys. But you can use a KeySelector to define the key.

If that should not be your problem, then it would be helpful if you could show me the problematic code which produces the error message.

Cheers,
Till

​

On Mon, Apr 18, 2016 at 9:28 PM, Leonard Wolters <[hidden email]> wrote:

Hi,

Quick question. I'm currently implementing our Machine Learning into
Spark using the Scala interface.
Do I understand correctly that when using scala only, you can only use
primitive types? How can I register
the UUID class in order to get supported for (de)serializing between the
nodes?

BTW: Would love to see the UUID class get 'native' support.

Keep on going the good work guys!,

Leonard