Hi folks,
I am running into this error:

Exception in thread "main" java.lang.RuntimeException: No list started
at
org.apache.calcite.sql.pretty.SqlPrettyWriter.sep(SqlPrettyWriter.java:1079)
at
org.apache.calcite.sql.pretty.SqlPrettyWriter.sep(SqlPrettyWriter.java:1074)
at org.apache.calcite.sql.SqlJoin$SqlJoinOperator.unparse(SqlJoin.java:214)
at org.apache.calcite.sql.SqlDialect.unparseCall(SqlDialect.java:470)
at org.apache.calcite.sql.SqlCall.unparse(SqlCall.java:104)
at org.apache.calcite.sql.SqlNode.toSqlString(SqlNode.java:151)
at org.apache.calcite.sql.SqlNode.toString(SqlNode.java:126)
at java.lang.String.valueOf(String.java:2994)
at java.io.PrintStream.println(PrintStream.java:821)
at scala.Console$.println(Console.scala:271)
at scala.Predef$.println(Predef.scala:404)
at com.cdl.common.sparksql.SQLtoDF$.main(SQLtoDF.scala:53)
at com.cdl.common.sparksql.SQLtoDF.main(SQLtoDF.scala)

This is the code:

    val query =
      "SELECT e.first_name AS FirstName, s.salary AS Salary from employee
AS e join salary AS s on e.emp_id=s.emp_id where e.organization = 'Tesla'
and s.organization = 'Tesla'"

    val config = SqlParser.configBuilder.setCaseSensitive(false).build

    val parser = SqlParser.create(query, config)
    val node = parser.parseQuery()
    val select = node.asInstanceOf[SqlSelect]
    println(select.getFrom)

Any idea what is going on?

Thanks
Nikhil

Reply via email to