Hi 大家好
有个问题要问问大家,我现在用flink1.9版本创建hbase表
sql:
create table hbase_dimention_table(
 id varchar,
 info ROW(xxx)
)with(
'connector.type' = 'hbase',
 'connector.version' = '1.4.3',     
 'connector.table-name' = 'xxxx', 
 'connector.zookeeper.quorum' = ‘xxx'
);
接着把flink-hbase_2.11-1.9.0.jar 放到了lib目录下,但是在执行的时候出现这种错误
org.apache.flink.client.program.ProgramInvocationException: The main method 
caused an error: SQL validation failed. findAndCreateTableSource failed
Caused by: java.lang.ClassNotFoundException: 
org.apache.hadoop.hbase.HBaseConfiguration




请问我还需要在那里加上依赖?

回复