[FLINK-20082] Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.11.2
• Component/s: API / DataStream, API / Scala
• Labels: auto-deprioritized-major auto-deprioritized-minor

Environment

• Flink 1.11.2
• Java 11
• Scala 2.12.11

• Assignee: Unassigned
• Reporter: ChangZhuo Chen (陳昌倬)
• Created: 11/Nov/20 06:21
• Updated: 09/Nov/21 10:43

Description

Hi,

• Our Flink application (Java 11 + Scala 2.12) has the following problem when executing it. It cannot be run in Flink cluster.
• The problem is similar to https://issues.apache.org/jira/browse/SPARK-25047, so maybe the same fix shall be implemented in Flink?