Search before asking
What happened
What you expected to happen
cannot assign instance of
java.lang.invoke.SerializedLambda to field
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.userFunction
of type org.apache.flink.api.common.functions.Function in instance of
org.apache.flink.streaming.api.operators.StreamFlatMap
How to reproduce
FYI
https://aws.amazon.com/cn/blogs/china/building-an-emr-data-analysis-platform-based-on-open-source-tools-part-two/
Anything else
No response
Version
1.2.0
Are you willing to submit PR?
Code of Conduct