前言

總結 Flink 讀寫 HBase

版本

• Flink 1.15.4
• HBase 2.0.2
• Hudi 0.13.0

官方文檔

https://nightlies.apache.org/flink/flink-docs-release-1.17/zh/docs/connectors/table/hbase/

Jar包

https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-hbase-2.2/1.15.4/flink-sql-connector-hbase-2.2-1.15.4.jar

SQL

需要提前建好hbase表；如果沒有對應的hbase表，flink寫hbase任務會顯示finished，沒有異常，但是并沒有自動創建對應的hbase表

hbase shell創建Hbase表