Re: pyflink利用sql ddl连接hbase-1.4.x出错Configuring the input format (null) failed: Cannot create connection to HBase

Hi 你好, 看root cause是 io.netty.channel.EventLoopGroup 这个类找不到，能否检查一下classpath里是否包含netty的jar包，亦或相关jar包中是否shade了netty库？ > 在 2020年11月16日，17:02，ghostviper 写道： > > *环境配置如下：* > hbase-1.4.13 > flink-1.11.1 > python-3.6.1 > pyflink-1.0 > > *已做配置如下：* > 1.hadoop classpath下已经加入hbase路径

pyflink利用sql ddl连接hbase-1.4.x出错

*环境配置如下：* hbase-1.4.13 flink-1.11.1 python-3.6.1 pyflink-1.0 *已做配置如下：* 1.hadoop classpath下已经加入hbase路径 （:/opt/hbase/hbase-1.4.13/lib/*） 2.程序ddl配置如下： source_ddl = """CREATE TABLE MySourceTable ( hbase_rowkey_name varchar, cf1 ROW) WITH ( 'connector.type' = 'hbase',

pyflink利用sql ddl连接hbase-1.4.x出错Configuring the input format (null) failed: Cannot create connection to HBase

*环境配置如下：* hbase-1.4.13 flink-1.11.1 python-3.6.1 pyflink-1.0 *已做配置如下：* 1.hadoop classpath下已经加入hbase路径 （:/opt/hbase/hbase-1.4.13/lib/*） 2.程序ddl配置如下： source_ddl = """CREATE TABLE MySourceTable ( hbase_rowkey_name varchar, cf1 ROW) WITH ( 'connector.type' = 'hbase',