[FLINK-16969] Unable to use case class in flink scala shell

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Duplicate
• Affects Version/s: 1.10.0
• Component/s: Scala Shell
• Labels: auto-deprioritized-major
• Assignee: Unassigned
• Reporter: Jeff Zhang
• Created: 03/Apr/20 09:27
• Updated: 20/Jul/21 10:01
• Resolved: 20/Jul/21 10:01

Description

case class WC(word: String, count: Int)
val wordCounts = benv.fromElements(WC("hello", 1),WC("world", 2), WC("world", 8))
wordCounts.collect()

Get the following exception

java.lang.IllegalArgumentException: requirement failed:
The class WC is an instance class, meaning it is not a member of a
toplevel object, or of an object contained in a toplevel object,
therefore it requires an outer instance to be instantiated, but we don't have a
reference to the outer instance. Please consider changing the outer class to an object.

  at scala.Predef$.require(Predef.scala:224)
  at org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer$.lookupConstructor(ScalaCaseClassSerializer.scala:90)
  at org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer.<init>(ScalaCaseClassSerializer.scala:46)
  ... 66 elided

Issue Links

• duplicates: FLINK-23388 Non-static Scala case classes cannot be serialised