[ https://issues.apache.org/jira/browse/SPARK-38273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496183#comment-17496183 ]
Apache Spark commented on SPARK-38273: -------------------------------------- User 'kevins-29' has created a pull request for this issue: https://github.com/apache/spark/pull/35613 > Native memory leak in SparkPlan > ------------------------------- > > Key: SPARK-38273 > URL: https://issues.apache.org/jira/browse/SPARK-38273 > Project: Spark > Issue Type: Bug > Components: SQL > Affects Versions: 3.2.0, 3.2.1 > Reporter: Kevin Sewell > Priority: Major > > SPARK-34647 replaced the ZstdInputStream with ZstdInputStreamNoFinalizer. > This meant that all usages of `CompressionCodec.compressedInputStream` would > need to manually close the stream as this would no longer be handled by GC > finaliser mechanism. > In SparkPlan, the result of `CompressionCodec.compressedInputStream` is > wrapped in an Iterator which never calls close. This implementation needs to > make use of NextIterator which allows for the closing of underlying streams. -- This message was sent by Atlassian Jira (v8.20.1#820001) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org