diff --git a/python/pyspark/sql/tests/test_dataframe.py b/python/pyspark/sql/tests/test_dataframe.py index 706b8c0a8be81..e5a2689d6cae3 100644 --- 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 index 2e5ffe2cd5fd8..a25847d1f7591 100644 --- 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)