TEST

changgyoopark-db · Jan 22, 2025 · fa2abbc · fa2abbc
1 parent 646295b
commit fa2abbc
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/python/pyspark/sql/tests/test_dataframe.py b/python/pyspark/sql/tests/test_dataframe.py
@@ -442,6 +442,7 @@ def test_extended_hint_types(self):
         with io.StringIO() as buf, redirect_stdout(buf):
             hinted_df.explain(True)
             explain_output = buf.getvalue()
+            self.assertEqual(str(explain_output), "hi")
             self.assertGreaterEqual(explain_output.count("1.2345"), 1)
             self.assertGreaterEqual(explain_output.count("what"), 1)
             self.assertGreaterEqual(explain_output.count("itworks"), 1)

diff --git a/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SessionHolder.scala b/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SessionHolder.scala
@@ -478,7 +478,8 @@ case class SessionHolder(userId: String, sessionId: String, session: SparkSessio
               plan
             } else {
               // Make sure that the plan is fully analyzed before being cached.
-              qe.analyzed
+              // qe.analyzed
+              plan
             }
           }
           cache.put(rel, analyzedPlan)