FlinkSQL 下推的值类型与字段类型不对应

[automths]

Hi：
我自定义connect并实现了FilterableTableSource接口，可是发现flink planner 下推的Filter中， 
Literal类型与字段类型不匹配。
比如：下面的SQL：
 select * from shortRow1 where key in (1, 2, 3) and col1 > 10 and col1 <= 15
其中DDL定义时， key、col1、col1都是SMALLINT类型
在下推的Filter中， GreaterThan中的Literal是Integer类型，这样是合理的吗？或者我的查询语句中要做什么处理？


祝好！
| |
automths
|
|
autom...@163.com
|