I'm using Flink 1.20 because I need some features from this version, I have seen that there're not available the HBase connector in this version, I don't know if this is the problem or it could be compatible.
El mar, 12 nov 2024 a las 11:56, Guillermo (<konstt2...@gmail.com>) escribió: > 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 >
