flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Liangliang Chen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7309) NullPointerException in CodeGenUtils.timePointToInternalCode() generated code
Date Mon, 31 Jul 2017 13:17:00 GMT
Liangliang Chen created FLINK-7309:

             Summary: NullPointerException in CodeGenUtils.timePointToInternalCode() generated
                 Key: FLINK-7309
                 URL: https://issues.apache.org/jira/browse/FLINK-7309
             Project: Flink
          Issue Type: Bug
          Components: Table API & SQL
    Affects Versions: 1.3.1
            Reporter: Liangliang Chen
            Priority: Critical

The code generated by CodeGenUtils.timePointToInternalCode() will cause a NullPointerException
when SQL table field type is `TIMESTAMP` and the field value is `null`.

Example for reproduce:
object StreamSQLExample {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val tEnv = TableEnvironment.getTableEnvironment(env)

    // null field value
    val orderA: DataStream[Order] = env.fromCollection(Seq(
      Order(null, "beer", 3)))
    tEnv.registerDataStream("OrderA", orderA, 'ts, 'product, 'amount)
    val result = tEnv.sql("SELECT * FROM OrderA")

  case class Order(ts: Timestamp, product: String, amount: Int)

In the above example, timePointToInternalCode() will generated some statements like this:
          long result$1 = org.apache.calcite.runtime.SqlFunctions.toLong((java.sql.Timestamp)
          boolean isNull$2 = (java.sql.Timestamp) in1.ts() == null;

so, the NPE will happen when in1.ts() is null.

This message was sent by Atlassian JIRA

View raw message