This is an automated email from the ASF dual-hosted git repository.
ijokarumawak pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/master by this push:
new e6e4175 NIFI-5841 Fix memory leak of PutHive3Streaming.
e6e4175 is described below
commit e6e4175d71d23157c152e7337e97fc45533b3869
Author: kei miyauchi <[email protected]>
AuthorDate: Tue Jan 8 09:38:46 2019 +0900
NIFI-5841 Fix memory leak of PutHive3Streaming.
This closes #3249.
Signed-off-by: Koji Kawamura <[email protected]>
---
.../main/java/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 810471b..81916c6 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();
