[ https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Tzu-Li (Gordon) Tai closed FLINK-7309. -------------------------------------- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > NullPointerException in CodeGenUtils.timePointToInternalCode() generated code > ----------------------------------------------------------------------------- > > Key: FLINK-7309 > URL: https://issues.apache.org/jira/browse/FLINK-7309 > Project: Flink > Issue Type: Bug > Components: Local Runtime, Table API & SQL > Affects Versions: 1.3.1 > Reporter: Liangliang Chen > Priority: Critical > Fix For: 1.3.4, 1.4.0 > > > 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: > {code} > 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") > result.toAppendStream[Order].print() > > env.execute() > } > case class Order(ts: Timestamp, product: String, amount: Int) > } > {code} > In the above example, timePointToInternalCode() will generated some > statements like this: > {code} > ... > long result$1 = > org.apache.calcite.runtime.SqlFunctions.toLong((java.sql.Timestamp) in1.ts()); > boolean isNull$2 = (java.sql.Timestamp) in1.ts() == null; > ... > {code} > so, the NPE will happen when in1.ts() is null. -- This message was sent by Atlassian JIRA (v7.6.3#76005)