[jira] [Created] (FLINK-17924) HBase connector：we can write data to HBase table, but con`t read data from HBase

["pengnengsong (Jira)" <ji...@apache.org>]

pengnengsong created FLINK-17924:
------------------------------------

             Summary: HBase connector：we can write data to HBase table, but con`t read data from HBase
                 Key: FLINK-17924
                 URL: https://issues.apache.org/jira/browse/FLINK-17924
             Project: Flink
          Issue Type: Bug
            Reporter: pengnengsong


CREATE TABLE source(
	rowkey INT,
	f1 ROW<col1 INT>,
	f2 ROW<col1 VARCHAR, col2 INT>
)WITH(
  'connector.type' = 'hbase',
  'connector.version' = '1.4.3',
  'connector.table-name' = 'test_source:flink',
  'connector.zookeeper.quorum' = 'xxxx:2181',
  'connector.zookeeper.znode.parent' = '/test/hbase'
)

Look at the source code of the Hbase connector, execute the configure method of HBaseRowInputformat. Java, this.conf is always null. The default hbase configuration information is created, and the configuration parameters in with are not in effect.

private void connectToTable(){
      if(this.conf ==null){
        this.conf = HBaseConfiguration.create();
   }
     ...
}




--
This message was sent by Atlassian Jira
(v8.3.4#803005)