[FLINK-26601] Flink HBase HBaseRowDataAsyncLookupFunction threadPool not close cause container has so many 'hbase-async-lookup-worker' thread

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.13.0
• Component/s: Connectors / HBase
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: zhisheng
• Created: 11/Mar/22 07:33
• Updated: 19/Oct/23 22:02

Description

https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java#L111

the thread pool create in the open function, but not gracefulShutdown in the close function, when the job failover, it will renew the thread pool

 

Issue Links

• links to: GitHub Pull Request #19068