[jira] [Created] (FLINK-16969) Unable to use case class in flink scala shell

[Shang Yuanchun (Jira)]

Jeff Zhang created FLINK-16969:
----------------------------------

             Summary: Unable to use case class in flink scala shell
                 Key: FLINK-16969
                 URL: https://issues.apache.org/jira/browse/FLINK-16969
             Project: Flink
          Issue Type: Bug
          Components: Scala Shell
    Affects Versions: 1.10.0
            Reporter: Jeff Zhang


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

java.lang.IllegalArgumentException: requirement failed:The class WC is an instance class, meaning it is not a member of atoplevel object, or of an object contained in a toplevel object,therefore it requires an outer instance to be instantiated, but we don't have areference 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{code}



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