Skip to content

Commit ca634b3

Browse files
committed
addressed review comment
1 parent 38991d0 commit ca634b3

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -936,15 +936,15 @@ class DatasetSuite extends QueryTest with SharedSQLContext {
936936
}
937937

938938
test("SPARK-18284: Serializer should have correct nullable value") {
939-
val df1 = sparkContext.parallelize(Seq(1, 2, 3, 4), 1).toDF
939+
val df1 = Seq(1, 2, 3, 4).toDF
940940
assert(df1.schema(0).nullable == false)
941-
val df2 = sparkContext.parallelize(Seq(Integer.valueOf(1), Integer.valueOf(2)), 1).toDF
941+
val df2 = Seq(Integer.valueOf(1), Integer.valueOf(2)).toDF
942942
assert(df2.schema(0).nullable == true)
943943

944-
val df3 = sparkContext.parallelize(Seq(Seq(1, 2), Seq(3, 4)), 1).toDF
944+
val df3 = Seq(Seq(1, 2), Seq(3, 4)).toDF
945945
assert(df3.schema(0).nullable == true)
946946
assert(df3.schema(0).dataType.asInstanceOf[ArrayType].containsNull == false)
947-
val df4 = sparkContext.parallelize(Seq(Seq("a", "b"), Seq("c", "d")), 1).toDF
947+
val df4 = Seq(Seq("a", "b"), Seq("c", "d")).toDF
948948
assert(df4.schema(0).nullable == true)
949949
assert(df4.schema(0).dataType.asInstanceOf[ArrayType].containsNull == true)
950950
}

0 commit comments

Comments
 (0)