Hi! scan.partition.lower-bound 和 scan.partition.upper-bound 都是一个 long 值(而不是一个 timestamp 字符串的形式)。它们将会转换成 where <column-name> between <lower-bound> and <upper-bound> 的 SQL 语句通过 jdbc 获取数据。可以检查一下配置项的格式和值的范围是否符合期望。
天下五帝东 <[email protected]> 于2021年12月1日周三 上午9:23写道: > Hi: > 我在使用flink sql jdbc connector测试partitioned scan功能,发现指定 > scan.partition.column 为timestamp类型时,scan.partition.lower-bound > > 和scan.partition.upper-bound指定具体的值后,没有读取到相关数据,哪位大佬帮忙解答下 > > 谢谢 > >
