✅ doris作为source的参数使用

👨🏻‍💻 技术问答
1

图片
这个参数怎么去配置
方式1：‘doris.filter.query’=‘yyyymmdd between 2023-01-30 and 2023-02-06 and yyyymmdd_collectime = 2023-02-01’
方式2：‘doris.filter.query’=‘yyyymmdd between ‘2023-01-30’ and ‘2023-02-06’ and yyyymmdd_collectime = ‘2023-02-01’’
方式3：“doris.filter.query”=“yyyymmdd between ‘2023-01-30’ and ‘2023-02-06’ and yyyymmdd_collectime = ‘2023-02-01’”

2

以上3个方式，flink sql都提交任务都不能成功，要么是格式校验不通过，要么提交上去任务报错

3

帮贴下flink任务执行的报错日志

4

这里是where的表达式，比如"doris.filter.query" = "name = ‘zhangsan’ "