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. Alternatively, we could set it back to what it was at
the start which seems like a safer option.
--
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]
