王江洲 created FLINK-32812:
---------------------------

             Summary: HBaseRowDataLookupFunction HTable instantiation of thread 
safety problems
                 Key: FLINK-32812
                 URL: https://issues.apache.org/jira/browse/FLINK-32812
             Project: Flink
          Issue Type: Bug
          Components: Connectors / HBase
    Affects Versions: 1.17.1
         Environment: Flink 1.17.1

Hbase 2.4.11

@Override

public void open(FunctionContext context) {
LOG.info("start open ...");
Configuration config = prepareRuntimeConfiguration();
try {
hConnection = ConnectionFactory.createConnection(config);
table = (HTable) hConnection.getTable(TableName.valueOf(hTableName));
} catch (TableNotFoundException tnfe) {
LOG.error("Table '{}' not found ", hTableName, tnfe);
throw new RuntimeException("HBase table '" + hTableName + "' not found.", tnfe);
} catch (IOException ioe) {
LOG.error("Exception while creating connection to HBase.", ioe);
throw new RuntimeException("Cannot create connection to HBase.", ioe);
}
this.serde = new HBaseSerde(hbaseTableSchema, nullStringLiteral);
LOG.info("end open.");
}
            Reporter: 王江洲
             Fix For: 1.17.1


HBaseRowDataLookupFunction HTable instantiation of thread safety problems in 
the actual development environment, the program has been performed, the close 
() method of the large probability can't perform, result in Ttable cannot be 
shut down, all use the same Ttable subsequent applications, multithreading 
safety hazard, Data errors occur.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to