File tree Expand file tree Collapse file tree 1 file changed +1
-10
lines changed
sql/core/src/test/scala/org/apache/spark/sql/parquet Expand file tree Collapse file tree 1 file changed +1
-10
lines changed Original file line number Diff line number Diff line change @@ -395,19 +395,10 @@ class ParquetQuerySuite extends QueryTest with FunSuiteLike with BeforeAndAfterA
395395 sql(" INSERT OVERWRITE INTO dest SELECT * FROM source" ).collect()
396396 val rdd_copy1 = sql(" SELECT * FROM dest" ).collect()
397397 assert(rdd_copy1.size === 100 )
398- assert(rdd_copy1(0 ).apply(0 ) === 1 )
399- assert(rdd_copy1(0 ).apply(1 ) === " val_1" )
400- // TODO: why does collecting break things? It seems InsertIntoParquet::execute() is
401- // executed twice otherwise?!
398+
402399 sql(" INSERT INTO dest SELECT * FROM source" )
403400 val rdd_copy2 = sql(" SELECT * FROM dest" ).collect().sortBy(_.getInt(0 ))
404401 assert(rdd_copy2.size === 200 )
405- assert(rdd_copy2(0 ).apply(0 ) === 1 )
406- assert(rdd_copy2(0 ).apply(1 ) === " val_1" )
407- assert(rdd_copy2(99 ).apply(0 ) === 50 )
408- assert(rdd_copy2(99 ).apply(1 ) === " val_50" )
409- assert(rdd_copy2(199 ).apply(0 ) === 100 )
410- assert(rdd_copy2(199 ).apply(1 ) === " val_100" )
411402 Utils .deleteRecursively(dirname)
412403 }
413404
You can’t perform that action at this time.
0 commit comments