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

2020-11-16 文章 ghostviper
*环境配置如下:* 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出错

2020-11-16 文章 ghostviper
*环境配置如下:* 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',