在sql client端,两种方式读取hive分区表如下:
1、Flink SQL> select platform,uv FROM
vip_dataeye_valid.dm_log_validuv_daily_5min /*+
OPTIONS('streaming-source.enable'='true','streaming-source.monitor-interval'='5
min','streaming-source.consume-start-offset'='dt=20210111/hm=1000') */
可以读取到数据;
2、Flink SQL>create view if not exists hive.temp_dw.uv_result_view as
select platform,uv FROM vip_dataeye_valid.dm_log_validuv_daily_5min /*+
OPTIONS('streaming-source.enable'='true','streaming-source.monitor-interval'='5
min','streaming-source.consume-start-offset'='dt=20210111/hm=1000') */
会报:[ERROR] Could not execute SQL statement. Reason:
java.lang.UnsupportedOperationException: class
org.apache.calcite.sql.SqlSyntax$6: SPECIAL
--
Sent from:
http://apache-flink.147419.n8.nabble.com/