aboutsummaryrefslogtreecommitdiff
path: root/core/src/test/scala/org/apache
diff options
context:
space:
mode:
authorXin Ren <iamshrek@126.com>2016-08-13 11:29:42 +0100
committerSean Owen <sowen@cloudera.com>2016-08-13 11:29:42 +0100
commit7f7133bdccecaccd6dfb52f13c18c1e320d65f86 (patch)
tree833bdf4a254b460c570e72692c177c77fde4af6c /core/src/test/scala/org/apache
parente46cb78b3b9fd04a50b5ae50f360db612d656a48 (diff)
downloadspark-7f7133bdccecaccd6dfb52f13c18c1e320d65f86.tar.gz
spark-7f7133bdccecaccd6dfb52f13c18c1e320d65f86.tar.bz2
spark-7f7133bdccecaccd6dfb52f13c18c1e320d65f86.zip
[MINOR][CORE] fix warnings on depreciated methods in MesosClusterSchedulerSuite and DiskBlockObjectWriterSuite
## What changes were proposed in this pull request? Fixed warnings below after scanning through warnings during build: ``` [warn] /home/jenkins/workspace/SparkPullRequestBuilder/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterSchedulerSuite.scala:34: imported `Utils' is permanently hidden by definition of object Utils in package mesos [warn] import org.apache.spark.scheduler.cluster.mesos.Utils [warn] ^ ``` and ``` [warn] /home/jenkins/workspace/SparkPullRequestBuilder/core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala:113: method shuffleBytesWritten in class ShuffleWriteMetrics is deprecated: use bytesWritten instead [warn] assert(writeMetrics.shuffleBytesWritten === file.length()) [warn] ^ [warn] /home/jenkins/workspace/SparkPullRequestBuilder/core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala:119: method shuffleBytesWritten in class ShuffleWriteMetrics is deprecated: use bytesWritten instead [warn] assert(writeMetrics.shuffleBytesWritten === file.length()) [warn] ^ [warn] /home/jenkins/workspace/SparkPullRequestBuilder/core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala:131: method shuffleBytesWritten in class ShuffleWriteMetrics is deprecated: use bytesWritten instead [warn] assert(writeMetrics.shuffleBytesWritten === file.length()) [warn] ^ [warn] /home/jenkins/workspace/SparkPullRequestBuilder/core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala:135: method shuffleBytesWritten in class ShuffleWriteMetrics is deprecated: use bytesWritten instead [warn] assert(writeMetrics.shuffleBytesWritten === file.length()) [warn] ^ ``` ## How was this patch tested? Tested manually on local laptop. Author: Xin Ren <iamshrek@126.com> Closes #14609 from keypointt/suiteWarnings.
Diffstat (limited to 'core/src/test/scala/org/apache')
-rw-r--r--core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterSchedulerSuite.scala1
-rw-r--r--core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala8
2 files changed, 4 insertions, 5 deletions
diff --git a/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterSchedulerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterSchedulerSuite.scala
index 0260759027..87d9080de5 100644
--- a/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterSchedulerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterSchedulerSuite.scala
@@ -31,7 +31,6 @@ import org.scalatest.mock.MockitoSugar
import org.apache.spark.{LocalSparkContext, SparkConf, SparkFunSuite}
import org.apache.spark.deploy.Command
import org.apache.spark.deploy.mesos.MesosDriverDescription
-import org.apache.spark.scheduler.cluster.mesos.Utils
class MesosClusterSchedulerSuite extends SparkFunSuite with LocalSparkContext with MockitoSugar {
diff --git a/core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala b/core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala
index 059c2c2444..684e978d11 100644
--- a/core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala
+++ b/core/src/test/scala/org/apache/spark/storage/DiskBlockObjectWriterSuite.scala
@@ -110,13 +110,13 @@ class DiskBlockObjectWriterSuite extends SparkFunSuite with BeforeAndAfterEach {
writer.write(Long.box(20), Long.box(30))
val firstSegment = writer.commitAndGet()
assert(firstSegment.length === file.length())
- assert(writeMetrics.shuffleBytesWritten === file.length())
+ assert(writeMetrics.bytesWritten === file.length())
writer.write(Long.box(40), Long.box(50))
writer.revertPartialWritesAndClose()
assert(firstSegment.length === file.length())
- assert(writeMetrics.shuffleBytesWritten === file.length())
+ assert(writeMetrics.bytesWritten === file.length())
}
test("calling revertPartialWritesAndClose() after commit() should have no effect") {
@@ -128,11 +128,11 @@ class DiskBlockObjectWriterSuite extends SparkFunSuite with BeforeAndAfterEach {
writer.write(Long.box(20), Long.box(30))
val firstSegment = writer.commitAndGet()
assert(firstSegment.length === file.length())
- assert(writeMetrics.shuffleBytesWritten === file.length())
+ assert(writeMetrics.bytesWritten === file.length())
writer.revertPartialWritesAndClose()
assert(firstSegment.length === file.length())
- assert(writeMetrics.shuffleBytesWritten === file.length())
+ assert(writeMetrics.bytesWritten === file.length())
}
test("calling revertPartialWritesAndClose() on a closed block writer should have no effect") {