diff --git a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala index ba5eb790cea9c..a567a915daf66 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala @@ -652,7 +652,7 @@ class Dataset[T] private[sql]( * @group basic * @since 2.4.0 */ - def isEmpty: Boolean = withAction("isEmpty", select().queryExecution) { plan => + def isEmpty: Boolean = withAction("isEmpty", select().limit(1).queryExecution) { plan => plan.executeTake(1).isEmpty }