I'm trying to connect HBase 1.2 with FlinkSQL, (I have tried with HBase 2.2 and the flink connector 2.2 with the same result). Test is done with docker-compose and hbase. Do I have to do something else? I have checked that table it's okay in HBase.
root@70e2d4767504:/opt/flink/lib# ls flink-cep-1.20.0.jar flink-connector-hbase-1.4-1.17.2.jar ...... Flink SQL> CREATE TABLE tableTest ( rowkey INT, imeis ROW<key STRING, black BOOLEAN>, PRIMARY KEY (rowkey) NOT ENFORCED ) WITH ( 'connector' = 'hbase-1.4', 'table-name' = 'tableTest', 'zookeeper.quorum' = 'zookeeper:2181' ); [INFO] Execute statement succeeded. Flink SQL> select * from tableTest limit 10; [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.flink.connector.hbase.table.HBaseConnectorOptions
