Re: Print SQL connector无法正常使用

Mon, 17 Aug 2020 08:00:23 -0700 

String createHbaseSql = 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',
);
tableEnv.executeSql(createHbaseSql);
Table queryTable = tableEnv.sqlQuery("select * from dimension");
tableEnv.toAppendStream(queryTable, Row.class).print();

你先用这种方式，看看能不能打印出来，证明你hbase没有问题。然后在用print_table。 



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复