Chen He created HADOOP-14641:
--------------------------------
Summary: hadoop-openstack driver reports input stream leaking
Key: HADOOP-14641
URL: https://issues.apache.org/jira/browse/HADOOP-14641
Project: Hadoop Common
Issue Type: Bug
Affects Versions: 2.7.3
Reporter: Chen He
[2017-07-07 14:51:07,052] ERROR Input stream is leaking handles by not being
closed() properly: HttpInputStreamWithRelease working with https://url/logs
released=false dataConsumed=false
(org.apache.hadoop.fs.swift.snative.SwiftNativeInputStream:259)
[2017-07-07 14:51:07,052] DEBUG Releasing connection to https://url/logs:
finalize() (org.apache.hadoop.fs.swift.http.HttpInputStreamWithRelease:101)
java.lang.Exception: stack
at
org.apache.hadoop.fs.swift.http.HttpInputStreamWithRelease.<init>(HttpInputStreamWithRelease.java:71)
at
org.apache.hadoop.fs.swift.http.SwiftRestClient$10.extractResult(SwiftRestClient.java:1523)
at
org.apache.hadoop.fs.swift.http.SwiftRestClient$10.extractResult(SwiftRestClient.java:1520)
at
org.apache.hadoop.fs.swift.http.SwiftRestClient.perform(SwiftRestClient.java:1406)
at
org.apache.hadoop.fs.swift.http.SwiftRestClient.doGet(SwiftRestClient.java:1520)
at
org.apache.hadoop.fs.swift.http.SwiftRestClient.getData(SwiftRestClient.java:679)
at
org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStore.getObject(SwiftNativeFileSystemStore.java:276)
at
org.apache.hadoop.fs.swift.snative.SwiftNativeInputStream.<init>(SwiftNativeInputStream.java:104)
at
org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystem.open(SwiftNativeFileSystem.java:555)
at
org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystem.open(SwiftNativeFileSystem.java:536)
at org.apache.hadoop.fs.FileSystem.open(FileSystem.java:769)
at
com.oracle.kafka.connect.swift.SwiftStorage.exists(SwiftStorage.java:74)
at io.confluent.connect.hdfs.DataWriter.createDir(DataWriter.java:371)
at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:175)
at
com.oracle.kafka.connect.swift.SwiftSinkTask.start(SwiftSinkTask.java:78)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:231)
at
org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:145)
at
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:139)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:182)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
