前言

总结 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表