王江洲 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)
