*环境配置如下:*
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',
*环境配置如下:*
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',