Hi. 查询语句中可以使用 cast 内置函数将值强制转换为指定的类型，如 select CAST(A.`col1` AS SMALLINT) as col1 from table
参考： https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/functions/systemFunctions.html#type-conversion-functions https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/types.html#data-types best 2021. 在 2020-12-31 17:13:20，"automths" <[email protected]> 写道： >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 >| >| >[email protected] >| >
