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)