我有一个Flink应用程序,它保持与这个错误的错误。 com.org.ads.audience.traffic.MyClass@6eaa21d8 is not serializable.org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:140) org.apache.flink
在这里,DataStream将键值对作为对象返回,我需要直接使用键值,而不是对象,因为我需要根据键对值进行分组。DataStream<ObjectNode> stream = env
.addSource(new FlinkKafkaConsumer<>("test5", new JSONKeyValueDeserializationSchema: This type (GenericType<org.apache.flink.shaded.jackson2.com.fasterxm