從flink1.11.0開始，只要開啟了hive dialect配置，使用者就可以使用hiveql語法，這樣我們就可以在flink中使用hive的語法使用一些ddl和dml操作。
flink目前支援兩種sql方言(sql dialects),分別為：default和hive。預設的sql方言是default，如果要使用hive的語法，需要將sql方言切換到hive。
預設方言
sql-client-defaults.yaml
configuration:
table.sql-dialect: hive
flink sql> set table.sql-dialect=hive; -- 使用hive dialect
flink sql> set table.sql-dialect=default; -- 使用default dialect
萬字長文|一文了解基於flink構建流批一體數倉的技術點
StreamingPro支援Flink的流式計算了
前言 有的時候我們只要按條處理，追求實時性而非吞吐量的時候，類似storm的模式就比較好了。spark 在流式處理一直缺乏改進，而flink在流式方面做得很棒，兩者高層的api也是互相借鑑，容易形成統一的感官，所以決定讓streamingpro適配flink,讓其作為streamingpro底層的流...
Flink 支援的重啟策略有哪些
flink支援不同的重啟策略，可以控制在發生故障時如何重啟新啟動作業。預設重啟策略是通過flink的配置檔案設定的flink conf.yaml。配置引數restart strategy定義採用的策略。如果未啟用檢查點，則使用 無重啟 策略。如果啟用了檢查點並且尚未配置重啟策略，則固定延遲策略將用於...
pageHelper方言不支援怎麼辦
首先可以查閱一下 使用自定義方言，參考鏈結如下 自定義方言 然還有一種更簡單方式，如下 pageautodialect.registerdialectalias dm6 oracledialect.class 此處 在sqlsessionfactory建立之後執行即可。原理說明 使用pagehelp...