Hi.
You should put the hbase jar into the ${FLINK-HOMe}/lib directory.
Best,
Shengkai
Guillermo <konstt2...@gmail.com> 于2024年11月12日周二 19:28写道：
> 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
>>
>
