Jeff Zhang created FLINK-9698:
---------------------------------
Summary: "case class must be static and globally accessible" is
too constrained
Key: FLINK-9698
URL: https://issues.apache.org/jira/browse/FLINK-9698
Project: Flink
Issue Type: Improvement
Reporter: Jeff Zhang
The following code can reproduce this issue.
{code}
object BatchJob {
def main(args: Array[String]) {
// set up the batch execution environment
val env = ExecutionEnvironment.getExecutionEnvironment
val tenv = TableEnvironment.getTableEnvironment(env)
case class Person(id:Int, name:String)
val ds = env.fromElements(Person(1,"jeff"), Person(2, "andy"))
tenv.registerDataSet("table_1", ds);
}
}
{code}
Although I have workaround to declare case class outside of the main method,
this workaround won't work in scala-shell.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
