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)
