flink1.11.0讀取kafka數據寫入hive中hive無分區信息及讀取不到數據解決

一、前言 在上一博客中寫了flink1.11.0讀取kafka數據寫入到hive中,發現hive中無法查詢flink通過scala寫入的數據,搜了些資料查找原因,參考了下文章:https://zhuanlan.zhihu.com/p/157899980 裏無法讀取hive數據的原因,但裏面比較明確給出的解決方案是修改源碼,我覺得太麻煩了。查了下官方和閱讀些flink源碼,終於找到一種我認爲比較便捷
相關文章
相關標籤/搜索