From e6e4175d71d23157c152e7337e97fc45533b3869 Mon Sep 17 00:00:00 2001 From: kei miyauchi Date: Tue, 8 Jan 2019 09:38:46 +0900 Subject: [PATCH] NIFI-5841 Fix memory leak of PutHive3Streaming. This closes #3249. Signed-off-by: Koji Kawamura --- .../org/apache/nifi/processors/hive/PutHive3Streaming.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/PutHive3Streaming.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/PutHive3Streaming.java index 810471bb09..81916c65fd 100644 --- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/PutHive3Streaming.java +++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/main/java/org/apache/nifi/processors/hive/PutHive3Streaming.java @@ -412,9 +412,6 @@ public class PutHive3Streaming extends AbstractProcessor { } hiveStreamingConnection = makeStreamingConnection(options, reader); - // Add shutdown handler with higher priority than FileSystem shutdown hook so that streaming connection gets closed first before - // filesystem close (to avoid ClosedChannelException) - ShutdownHookManager.addShutdownHook(hiveStreamingConnection::close, FileSystem.SHUTDOWN_HOOK_PRIORITY + 1); // Write records to Hive streaming, then commit and close hiveStreamingConnection.beginTransaction();