[HDFS-15865] Interrupt DataStreamer thread

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.3.1, 3.4.0
• Component/s: datanode
• Labels: pull-request-available
• Assignee: Karthik Palanisamy
• Reporter: Karthik Palanisamy
• Created: 01/Mar/21 08:11
• Updated: 24/May/23 09:52
• Resolved: 01/May/21 18:06

Description

Have noticed HiveServer2 halts due to DataStreamer#waitForAckedSeqno. 

I think we have to interrupt DataStreamer if no packet ack(from datanodes). It likely happens with infra/network issue.

"HiveServer2-Background-Pool: Thread-35977576" #35977576 prio=5 os_prio=0 cpu=797.65ms elapsed=3406.28s tid=0x00007fc0c6c29800 nid=0x4198 in Object.wait()  [0x00007fc1079f3000]
    java.lang.Thread.State: TIMED_WAITING (on object monitor)
         at java.lang.Object.wait(java.base(at)11.0.5/Native Method)
         - waiting on <no object reference available>
         at org.apache.hadoop.hdfs.DataStreamer.waitForAckedSeqno(DataStreamer.java:886)
         - waiting to re-lock in wait() <0x00007fe6eda86ca0> (a java.util.LinkedList)

Issue Links

• causes: HDFS-17024 Potential data race introduced by HDFS-15865
• links to: GitHub Pull Request #2728