Andrew Or created SPARK-13071: --------------------------------- Summary: Coalescing HadoopRDD overwrites existing input metrics Key: SPARK-13071 URL: https://issues.apache.org/jira/browse/SPARK-13071 Project: Spark Issue Type: Bug Components: Spark Core Affects Versions: 2.0.0 Reporter: Andrew Or Assignee: Andrew Or
Currently if we do the following in Hadoop 2.5+: {code} sc.textFile(..., 4).coalesce(2).collect() {code} We'll get incorrect `InputMetrics#bytesRead`. This is because HadoopRDD's compute method overwrites any existing value of `bytesRead`, and in the case of coalesce we'll end up calling `compute` multiple times in the same task. This is why InputOutputMetricsSuite is failing in master, but only for hadoop2.6/2.7: https://amplab.cs.berkeley.edu/jenkins/job/spark-master-test-sbt-hadoop-2.7/67/ -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org