【flink】1.12 读写hive

阅读量：

问题解决

Caused by: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job

复制代码

    这是在sql-client中查询hive表遇到的问题，启动一下flink的Standlone集群即可。要把之前的启动的都关掉。

从Kafka中提取数据并导入至Hive过程中，始终无法检索到相关数据？

复制代码

    打开路径/user/hive/warehouse/flink.db/user_behavior_hive_tbl 发现好多分区，原来是时间戳搞错了,吧ts/1000换成秒在转换

SQL client __

复制代码

 切换方言
    Flink SQL> set table.sql-dialect=hive; -- to use hive dialect
    [INFO] Session property has been set.
    
    Flink SQL> set table.sql-dialect=default; -- to use default dialect
    [INFO] Session property has b

全部评论 (0)

还没有任何评论哟~