You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by yanzi <an...@126.com> on 2021/01/12 03:11:46 UTC

flinksql1.12建view流式读取hive分区表不支持，报错信息：[ERROR] Could not execute SQL statement. Reason: java.lang.UnsupportedOperationException: class org.apache.calcite.sql.SqlSyntax$6: SPECIAL

在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/