更新时间:2024-09-10 GMT+08:00
HBase数据表开发规则
提前在HBase中创建表
Flink作业在HBase中找不到对应表会报错,所以需要提前在HBase中创建好对应的表。
HBase与Flink不在同一集群时只支持Flink和HBase均为普通模式集群的对接
当HBase与Flink为同一集群或互信的集群,支持FlinkServer对接HBase。
当HBase与Flink不在同一集群或不互信的集群,则只支持Flink和HBase均为普通模式集群的对接。
FlinkServer对接HBase时需要配置HBASE_CONF_DIR参数
- 以客户端安装用户登录安装客户端的节点,复制HBase的“/opt/client/HBase/hbase/conf/”目录下的所有配置文件至部署FlinkServer的所有节点的一个空目录,如“/tmp/client/HBase/hbase/conf/”。
修改FlinkServer节点上面配置文件目录及其上层目录属主为omm。
- 登录Manager,选择“集群 > 服务 > Flink > 配置 > 全部配置”,搜索“HBASE_CONF_DIR”参数,在该参数的“值”中填写1中复制了HBase配置文件的FlinkServer的目录,如“/tmp/client/HBase/hbase/conf/”。
若FlinkServer实例所在节点与包含HBase服务客户端的安装节点相同,则在HBASE_CONF_DIR”参数的“值”填写HBase的“/opt/client/HBase/hbase/conf/”目录。
- 填写完成后单击“保存”,确认修改配置后单击“确定”。
- 单击“实例”,勾选所有FlinkServer实例,选择“更多 > 重启实例”,根据界面提示重启实例。
父主题: HBase数据表开发规范