You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/07/02 05:42:00 UTC
[jira] [Created] (FLINK-9698) "case class must be static and
globally accessible" is too constrained
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)