This is an automated email from the ASF dual-hosted git repository.
kabhwan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 4e374687071 [SPARK-39748][SQL][FOLLOWUP] Add missing origin logical
plan on DataFrame.checkpoint on building LogicalRDD
4e374687071 is described below
commit 4e3746870718015ccded31e944e0afd9ad7729a3
Author: Jungtaek Lim <[email protected]>
AuthorDate: Wed Jul 13 11:39:36 2022 +0900
[SPARK-39748][SQL][FOLLOWUP] Add missing origin logical plan on
DataFrame.checkpoint on building LogicalRDD
### What changes were proposed in this pull request?
This PR adds missing origin logical plan on building LogicalRDD in
DataFrame.checkpoint, via review comment
https://github.com/apache/spark/pull/37161#discussion_r919204026.
### Why are the changes needed?
This is missing spot on previous PR and viirya helped to find out.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
N/A
Closes #37167 from HeartSaVioR/SPARK-39748-FOLLOWUP.
Authored-by: Jungtaek Lim <[email protected]>
Signed-off-by: Jungtaek Lim <[email protected]>
---
sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 f45c27d3007..7f5efd85e3b 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
@@ -705,7 +705,7 @@ class Dataset[T] private[sql](
LogicalRDD(
logicalPlan.output,
internalRdd,
- None,
+ Some(queryExecution.analyzed),
outputPartitioning,
physicalPlan.outputOrdering,
isStreaming
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
