bowenliang123 commented on PR #4733:
URL: https://github.com/apache/kyuubi/pull/4733#issuecomment-1521848398

   cc @iodone @wForget 
   
   I am looking for proper timing to close event handlers for Kyuubi Server. 
But repeated errors comes in the irreverent places.
   
   As I tried to close event handlers via `EventBus.close()` in KyuubiSever's 
`stop()` or `stopServer`,
   the `get operation log` test case failed, which is completely unrelated to 
Kafka logger introduced in this PR, and it also never uses the Kafka logger in 
context. 
   
   If you guys have any idea for this, feel free to ping me any time. Thanks.
   
   ```
   java.lang.IllegalStateException: Cannot perform operation after producer has 
been closed
        at 
org.apache.kafka.clients.producer.KafkaProducer.throwIfProducerClosed(KafkaProducer.java:892)
 ~[kafka-clients-2.8.1.jar:?]
        at 
org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:901) 
~[kafka-clients-2.8.1.jar:?]
        at 
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885) 
~[kafka-clients-2.8.1.jar:?]
        at 
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:773) 
~[kafka-clients-2.8.1.jar:?]
        at 
org.apache.kyuubi.events.handler.KafkaLoggingEventHandler.apply(KafkaLoggingEventHandler.scala:50)
 ~[kyuubi-events_2.12-1.8.0-SNAPSHOT.jar:?]
        at 
org.apache.kyuubi.events.handler.KafkaLoggingEventHandler.apply(KafkaLoggingEventHandler.scala:31)
 ~[kyuubi-events_2.12-1.8.0-SNAPSHOT.jar:?]
        at 
org.apache.kyuubi.events.EventBus$EventBusLive.$anonfun$post$4(EventBus.scala:87)
 ~[kyuubi-events_2.12-1.8.0-SNAPSHOT.jar:?]
        at 
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) 
~[scala-library-2.12.17.jar:?]
   - get operation log *** FAILED ***
     
scala.collection.JavaConverters.asScalaBufferConverter[String](logRowSet.getLogRowSet()).asScala.exists(((x$1:
 String) => x$1.contains("show tables"))) was false 
(OperationsResourceSuite.scala:107)
   ```


-- 
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]

Reply via email to