Github user andrusha commented on a diff in the pull request:
https://github.com/apache/spark/pull/18355#discussion_r175379493
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala
---
@@ -364,12 +398,21 @@ object StateStore extends Logging {
private def coordinatorRef: Option[StateStoreCoordinatorRef] =
loadedProviders.synchronized {
val env = SparkEnv.get
if (env != null) {
- if (_coordRef == null) {
+ logInfo("Env is not null")
--- End diff --
@tdas could you say what's the reason to add this message on the "INFO"
level?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
