[FLINK-32812] HBaseRowDataLookupFunction HTable instantiation of thread safety problems

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.17.1
• Fix Version/s: 1.17.1
• Component/s: Connectors / HBase
• Labels: pull-request-available security

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.");
}

• Release Note: HBaseRowDataLookupFunction HTable instantiation of thread safety problems

Docs Text

HBaseRowDataLookupFunction HTable instantiation thread safety problems, in the open () method of initialization HTable, but 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, Subsequent programs all use the same Ttable, which poses a multi-thread security risk, resulting in data errors.

Language

java

• Assignee: Unassigned
• Reporter: 王江洲
• Created: 08/Aug/23 13:07
• Updated: 19/Oct/23 22:06

Description

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.

Issue Links

• links to: GitHub Pull Request #23170