Re: Print SQL connector无法正常使用

Mon, 17 Aug 2020 23:45:41 -0700 

我这个是mysql的，直接run，没问题


EnvironmentSettings settings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
TableEnvironment tableEnv = TableEnvironment.create(settings);

String createMysqlTableSQL ="CREATE TABLE mysqlTable1 (\n" +
        " id INT,\n" +
        " username STRING,\n" +
        " age INT , \n" +
        " PRIMARY KEY (id) NOT ENFORCED\n" +
        ") WITH (\n" +
        " 'connector' = 'jdbc' ,\n" +
        " 'url' = 'jdbc:mysql://1.2.3.4:3306/bigdata',\n" +
        " 'table-name' = 'test' ,\n" +
        " 'username' = 'root' ,\n" +
        " 'password' = 'root' \n" +
        ")";
String  print_table=" CREATE TABLE print_table (" +
        " id INT," +
        " username STRING," +
        " age INT" +
        " ) WITH (" +
        " 'connector' = 'print'" +
        " )";
tableEnv.executeSql(createMysqlTableSQL);
tableEnv.executeSql(print_table);

String querysql ="insert into print_table select * from mysqlTable1";

tableEnv.executeSql(querysql);

在 2020/8/18 11:57, xiao cai 写道:

Hi china_tao:
你好，HBase肯定没有问题的，请问你可以正常使用print connector吗，能否让我看看正确的使用姿势，感谢


  原始邮件
发件人: china_tao<[email protected]>
收件人: user-zh<[email protected]>
发送时间: 2020年8月17日(周一) 23:00
主题: Re: Print SQL connector无法正常使用


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/

回复