rangadi commented on code in PR #41752: URL: https://github.com/apache/spark/pull/41752#discussion_r1260224491
########## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SessionHolder.scala: ########## @@ -47,6 +48,9 @@ case class SessionHolder(userId: String, sessionId: String, session: SparkSessio // foreachBatch() in Streaming. Lazy since most sessions don't need it. private lazy val dataFrameCache: ConcurrentMap[String, DataFrame] = new ConcurrentHashMap() + private lazy val listenerCache: ConcurrentMap[String, StreamingQueryListener] = Review Comment: Nm. I wanted to remove this comment. It is part of the StreamingQueryManager, not individual queries. Yes, we need to fix removing the listener. -- 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]
