Print SQL connector无法正常使用

Sun, 16 Aug 2020 20:53:43 -0700 

Hi All:
目前使用flink sql的Print SQL connector，想要将查询的结果打印出来，结果报错：
Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could 
not find a suitable table factory for 
'org.apache.flink.table.factories.TableSinkFactory' in
the classpath.


可以保证：HBase-connector是在lib包下存在的，是否我还需要在lib下添加什么依赖？


下面为执行的sql：


CREATE TABLE dimension ( 
    rowKey STRING, 
    cf ROW<age INT, area BIGINT>, 
    tas BIGINT 
) WITH ( 
    'connector.type' = 'hbase', 
    'connector.version' = '1.4.3', 
    'connector.table-name' = ’test', 
    'connector.write.buffer-flush.max-rows' = '10', 
    'connector.zookeeper.quorum' = ‘IP:port', 
    'connector.zookeeper.znode.parent' = '/hbase', 
);


CREATE TABLE print_table (
 f0 STRING,
 f1 INT,
 f2 BIGINT,
 f3 BIGINT
) WITH (
 'connector' = 'print'
);


insert into print_table
select rowKey, cf.age, cf.area, tas
from dimension

回复