spark-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aaditya Ramesh (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (SPARK-19525) Enable Compression of Spark Streaming Checkpoints
Date Thu, 09 Feb 2017 01:05:41 GMT

    [ https://issues.apache.org/jira/browse/SPARK-19525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15858810#comment-15858810
] 

Aaditya Ramesh commented on SPARK-19525:
----------------------------------------

We have a patch that works for an older version. I am currently trying to port it to Spark
2.1.0. Is this okay?

> Enable Compression of Spark Streaming Checkpoints
> -------------------------------------------------
>
>                 Key: SPARK-19525
>                 URL: https://issues.apache.org/jira/browse/SPARK-19525
>             Project: Spark
>          Issue Type: Improvement
>          Components: Structured Streaming
>    Affects Versions: 2.1.0
>            Reporter: Aaditya Ramesh
>
> In our testing, compressing partitions while writing them to checkpoints on HDFS using
snappy helped performance significantly while also reducing the variability of the checkpointing
operation. In our tests, checkpointing time was reduced by 3X, and variability was reduced
by 2X for data sets of compressed size approximately 1 GB.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org


Mime
View raw message