aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorKaren Feng <karenfeng.us@gmail.com>2013-07-10 14:52:29 -0700
committerKaren Feng <karenfeng.us@gmail.com>2013-07-10 14:52:29 -0700
commitf5f3b272f874a3ac22f4e0b2caab9053657a9124 (patch)
tree7fc4d633b6e4bc77a1808bb85368b9118e644fa0 /core
parentdbe948d9a2198845feb7c8bfa738286db41344d9 (diff)
downloadspark-f5f3b272f874a3ac22f4e0b2caab9053657a9124.tar.gz
spark-f5f3b272f874a3ac22f4e0b2caab9053657a9124.tar.bz2
spark-f5f3b272f874a3ac22f4e0b2caab9053657a9124.zip
Fixed mixup of start/end, moved more import files
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/spark/Utils.scala4
-rw-r--r--core/src/test/scala/spark/UtilsSuite.scala9
-rw-r--r--core/src/test/scala/spark/ui/UISuite.scala4
3 files changed, 8 insertions, 9 deletions
diff --git a/core/src/main/scala/spark/Utils.scala b/core/src/main/scala/spark/Utils.scala
index 1c5af2700a..1da9c9574e 100644
--- a/core/src/main/scala/spark/Utils.scala
+++ b/core/src/main/scala/spark/Utils.scala
@@ -625,8 +625,8 @@ private object Utils extends Logging {
def offsetBytes(path: String, start: Long, end: Long): String = {
val file = new File(path)
val length = file.length()
- val effectiveStart = math.min(length, start)
- val effectiveEnd = math.max(0, end)
+ val effectiveEnd = math.min(length, end)
+ val effectiveStart = math.max(0, start)
val buff = new Array[Byte]((effectiveEnd-effectiveStart).toInt)
val stream = new FileInputStream(file)
diff --git a/core/src/test/scala/spark/UtilsSuite.scala b/core/src/test/scala/spark/UtilsSuite.scala
index 942702c826..d83a0307fa 100644
--- a/core/src/test/scala/spark/UtilsSuite.scala
+++ b/core/src/test/scala/spark/UtilsSuite.scala
@@ -1,12 +1,11 @@
package spark
-import org.scalatest.FunSuite
-import java.io.{ByteArrayOutputStream, ByteArrayInputStream}
-import scala.util.Random
+import com.google.common.base.Charsets
import com.google.common.io.Files
+import java.io.{ByteArrayOutputStream, ByteArrayInputStream, FileOutputStream, File}
+import org.scalatest.FunSuite
import org.apache.commons.io.FileUtils
-import java.io.{FileOutputStream, File}
-import com.google.common.base.Charsets
+import scala.util.Random
class UtilsSuite extends FunSuite {
diff --git a/core/src/test/scala/spark/ui/UISuite.scala b/core/src/test/scala/spark/ui/UISuite.scala
index cd7d105928..fc0c160720 100644
--- a/core/src/test/scala/spark/ui/UISuite.scala
+++ b/core/src/test/scala/spark/ui/UISuite.scala
@@ -1,9 +1,9 @@
package spark.ui
+import scala.util.{Failure, Success, Try}
+import java.net.ServerSocket
import org.scalatest.FunSuite
import org.eclipse.jetty.server.Server
-import java.net.ServerSocket
-import scala.util.{Failure, Success, Try}
class UISuite extends FunSuite {
test("jetty port increases under contention") {