Github user sunjincheng121 commented on a diff in the pull request:
— Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala —
@@ -437,39 +437,64 @@ abstract class StreamTableEnvironment(
var rowtime: Option[(Int, String)] = None
var proctime: Option[(Int, String)] = None
When user write a mistake row-time property name of POJO. e.g.:
`(recordTimeA as rowtime).rowtime` --> correct name is `recordTime`.
will get the exception as follows:
Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1
I suggest that:
1. May be we need check the row-time property name of POJO as early as possible.
2. We should check the index value must >= 0, If no so, we should throw a exception with clearly error information.