[ 
https://issues.apache.org/jira/browse/SPARK-53210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Dongjoon Hyun updated SPARK-53210:
----------------------------------
    Description: 
{code}
scala> val a = new Array[Byte](2_000_000_000)

scala> spark.time(java.nio.file.Files.write(Path.of("/tmp/a"), a))
Time taken: 560 ms

scala> spark.time(com.google.common.io.Files.write(a, new 
java.io.File("/tmp/a")))
Time taken: 685 ms
{code}

  was:
{code}
scala> spark.time(java.nio.file.Files.write(Path.of("/tmp/a"), a))
Time taken: 560 ms

scala> spark.time(com.google.common.io.Files.write(a, new 
java.io.File("/tmp/a")))
Time taken: 685 ms
{code}


> Use Java `Files.write` instead of `com.google.common.io.Files.write`
> --------------------------------------------------------------------
>
>                 Key: SPARK-53210
>                 URL: https://issues.apache.org/jira/browse/SPARK-53210
>             Project: Spark
>          Issue Type: Sub-task
>          Components: DStreams, Spark Core, SQL, Tests, YARN
>    Affects Versions: 4.1.0
>            Reporter: Dongjoon Hyun
>            Assignee: Dongjoon Hyun
>            Priority: Major
>              Labels: pull-request-available
>
> {code}
> scala> val a = new Array[Byte](2_000_000_000)
> scala> spark.time(java.nio.file.Files.write(Path.of("/tmp/a"), a))
> Time taken: 560 ms
> scala> spark.time(com.google.common.io.Files.write(a, new 
> java.io.File("/tmp/a")))
> Time taken: 685 ms
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

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

Reply via email to