Skip to content

Commit

Permalink
fixed bug in path name, renamed tests
Browse files Browse the repository at this point in the history
  • Loading branch information
kmader committed Aug 14, 2014
1 parent bc5c0b9 commit f032bc0
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions core/src/test/scala/org/apache/spark/FileSuite.scala
Original file line number Diff line number Diff line change
Expand Up @@ -224,10 +224,10 @@ class FileSuite extends FunSuite with LocalSparkContext {
assert(output.map(_.toString).collect().toList === List("(1,a)", "(2,aa)", "(3,aaa)"))
}

test("byte stream input") {
test("binary file input as byte array") {
sc = new SparkContext("local", "test")
val outputDir = new File(tempDir, "output").getAbsolutePath
val outFile = new File(outputDir, "part-00000.bin")
val outputDir = new File(tempDir).getAbsolutePath
val outFile = new File(outputDir, "record-bytestream-00000.bin")
val outFileName = outFile.toPath().toString()

// create file
Expand All @@ -248,13 +248,13 @@ class FileSuite extends FunSuite with LocalSparkContext {
assert(indata === testOutput)
}

test("fixed length byte stream input") {
test("fixed record length binary file as byte array") {
// a fixed length of 6 bytes

sc = new SparkContext("local", "test")

val outputDir = new File(tempDir, "output").getAbsolutePath
val outFile = new File(outputDir, "part-00000.bin")
val outputDir = new File(tempDir).getAbsolutePath
val outFile = new File(outputDir, "record-bytestream-00000.bin")
val outFileName = outFile.toPath().toString()

// create file
Expand Down

0 comments on commit f032bc0

Please sign in to comment.