[jira] [Created] (FLINK-17320) Java8 lambda expression cannot be serialized.

["Jiayi Liao (Jira)" <ji...@apache.org>]

Jiayi Liao created FLINK-17320:
----------------------------------

             Summary: Java8 lambda expression cannot be serialized.
                 Key: FLINK-17320
                 URL: https://issues.apache.org/jira/browse/FLINK-17320
             Project: Flink
          Issue Type: Bug
          Components: API / Type Serialization System, Table SQL / Runtime
    Affects Versions: 1.9.0
            Reporter: Jiayi Liao


Reproduce codes.


{code:java}
@Test
public void test() throws IOException {
        PriorityQueue<String> pq = new PriorityQueue<>((o1, o2) -> o1.length - o2.length - 1);
        pq.add("1234135");
        pq.add("12323424135");

        KryoSerializer kryoSerializer = new KryoSerializer(PriorityQueue.class, new ExecutionConfig());
        kryoSerializer.serialize(pq, new DataOutputSerializer(10240));
}
{code}

And the NPE will be thrown:


{code:java}
Caused by: java.lang.NullPointerException
        at com.esotericsoftware.kryo.util.DefaultClassResolver.writeClass(DefaultClassResolver.java:80)
        at com.esotericsoftware.kryo.Kryo.writeClass(Kryo.java:488)
        at com.esotericsoftware.kryo.Kryo.writeClassAndObject(Kryo.java:593)
        at org.apache.flink.runtime.types.PriorityQueueSerializer.write(PriorityQueueSerializer.java:67)
        at org.apache.flink.runtime.types.PriorityQueueSerializer.write(PriorityQueueSerializer.java:40)
        at com.esotericsoftware.kryo.Kryo.writeClassAndObject(Kryo.java:599)
        at org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.serialize(KryoSerializer.java:307)
        at org.apache.flink.util.InstantiationUtil.serializeToByteArray(InstantiationUtil.java:526)
{code}




--
This message was sent by Atlassian Jira
(v8.3.4#803005)