Skip to content

Commit 1a52dbe

Browse files
committed
Address a comment and add few more words in comments
1 parent deacb17 commit 1a52dbe

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

python/pyspark/sql/tests.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3073,7 +3073,7 @@ def test_sparksession_with_stopped_sparkcontext(self):
30733073

30743074
class QueryExecutionListenerTests(unittest.TestCase, SQLTestUtils):
30753075
# These tests are separate because it uses 'spark.sql.queryExecutionListeners' which is
3076-
# static and immutable. This can't be set or unset.
3076+
# static and immutable. This can't be set or unset, for example, via `spark.conf`.
30773077

30783078
@classmethod
30793079
def setUpClass(cls):

sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import org.apache.spark.sql.execution.QueryExecution
2424
import org.apache.spark.sql.util.QueryExecutionListener
2525

2626

27-
class TestQueryExecutionListener extends QueryExecutionListener with Logging {
27+
class TestQueryExecutionListener extends QueryExecutionListener {
2828
override def onSuccess(funcName: String, qe: QueryExecution, durationNs: Long): Unit = {
2929
OnSuccessCall.isOnSuccessCalled.set(true)
3030
}

0 commit comments

Comments
 (0)