Skip to content

Commit e940c6f

Browse files
committed
Revert code
1 parent a65d5c6 commit e940c6f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -514,7 +514,7 @@ class SparkSession private(
514514
@Experimental
515515
@InterfaceStability.Evolving
516516
def range(start: Long, end: Long): Dataset[java.lang.Long] = {
517-
range(start, end, step = 1)
517+
range(start, end, step = 1, numPartitions = sparkContext.defaultParallelism)
518518
}
519519

520520
/**
@@ -527,7 +527,7 @@ class SparkSession private(
527527
@Experimental
528528
@InterfaceStability.Evolving
529529
def range(start: Long, end: Long, step: Long): Dataset[java.lang.Long] = {
530-
new Dataset(self, Range(start, end, step, None), Encoders.LONG)
530+
range(start, end, step, numPartitions = sparkContext.defaultParallelism)
531531
}
532532

533533
/**

0 commit comments

Comments
 (0)