nihalpot commented on code in PR #41791:
URL: https://github.com/apache/spark/pull/41791#discussion_r1251310369
##########
connector/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceProviderSuite.scala:
##########
@@ -62,6 +140,7 @@ class KafkaSourceProviderSuite extends SparkFunSuite {
stream => {
assert(expected.toLong ===
stream.kafkaOffsetReader.offsetFetchAttemptIntervalMs)
})
+ SparkEnv.set(null)
Review Comment:
Yeah this was initially part of the `beforeAll` command on line 35 but I
removed it since the new tests rely on the spark env config set by the
`SharedSparkSession`, I moved it here since the spark config gets modified by
the methods in this test to maintain consistency with what the rest of the
tests expect.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
