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