[NIFI-6908] PutKudu 1.10.0 Memory Leak

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Duplicate
• Affects Version/s: 1.10.0
• Fix Version/s: 1.11.0
• Component/s: Extensions
• Labels: heap kudu oom
• Environment: NiFi 1.10.0 8-Node Cluster; Kudu 1.10.0
• Assignee: Grant Henke
• Reporter: Josef Zahner
• Created: 27/Nov/19 11:03
• Updated: 31/Jan/20 11:05
• Resolved: 21/Jan/20 21:03

Description

PutKudu 1.10.0 eats up all the heap memory and garbage collection can't anymore free up memory after a few hours.

We have an NiFi 8-Node cluster (31GB java max memory configured) with a streaming source which generates constantly about 2'500 flowfiles/2.5GB data in 5 minutes. In our example the streaming source was running on "nifi-05" (green line). As you can see between 00:00 and 04:00 the memory grows and grows and at the end the node became instable and the dreaded "java.lang.OutOfMemoryError: Java heap space" message appeared. We tried to do a manual garbage collection with visualvm profiler, but it didn't helped.  

We are sure that the PutKudu is the culprit, as we have now taken the codebase from PutKudu 1.9.2 and use it now in NiFi 1.10.0 without any leaks at all.

With the official PutKudu 1.10.0 processor our cluster crashed within 5-6 hours with our current load as the memory was completely full.

 

Issue Links

• duplicates: NIFI-6895 PutKudu Processor Warnings - Applying an operation in a closed session; this is unsafe