Uploaded image for project: 'Jenkins'
  1. Jenkins
  2. JENKINS-52343

Fix exceptions of closeRead() method in KafkaClassicCommandTransport

XMLWordPrintable

      We have the following logs when the agent is deleted from the UI 

      SEVERE: Unexpected error in channel testSEVERE: Unexpected error in channel test
java.lang.IllegalStateException: This consumer has already been closed. at org.apache.kafka.clients.consumer.KafkaConsumer.acquireAndEnsureOpen(KafkaConsumer.java:1811) at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1216) at io.jenkins.plugins.remotingkafka.commandtransport.KafkaClassicCommandTransport.closeRead(KafkaClassicCommandTransport.java:74) at hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:90)

Jul 03, 2018 1:34:21 PM hudson.remoting.SynchronousCommandTransport$ReaderThread lambda$new$0
SEVERE: Uncaught exception in SynchronousCommandTransport.ReaderThread Thread[Channel reader thread: test,5,main]
java.lang.IllegalStateException: This consumer has already been closed. at org.apache.kafka.clients.consumer.KafkaConsumer.acquireAndEnsureOpen(KafkaConsumer.java:1811) at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1216) at io.jenkins.plugins.remotingkafka.commandtransport.KafkaClassicCommandTransport.closeRead(KafkaClassicCommandTransport.java:74) at hudson.remoting.Channel.terminate(Channel.java:1031) at hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:99)

Exception: java.lang.IllegalStateException thrown from the UncaughtExceptionHandler in thread "Channel reader thread: test"

          [JENKINS-52343] Fix exceptions of closeRead() method in KafkaClassicCommandTransport

          Pham Vu Tuan created issue -
          Pham Vu Tuan made changes -
          Epic Link New: JENKINS-51943 [ 191430 ]
          Pham Vu Tuan made changes -
          Description Original: We have the following logs when the agent is deleted from the UI 
          {code:java}
          Jul 03, 2018 1:34:21 PM hudson.remoting.SynchronousCommandTransport$ReaderThread runJul 03, 2018 1:34:21 PM hudson.remoting.SynchronousCommandTransport$ReaderThread runSEVERE: Unexpected error in channel testjava.lang.IllegalStateException: This consumer has already been closed. at org.apache.kafka.clients.consumer.KafkaConsumer.acquireAndEnsureOpen(KafkaConsumer.java:1811) at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1216) at io.jenkins.plugins.remotingkafka.commandtransport.KafkaClassicCommandTransport.closeRead(KafkaClassicCommandTransport.java:74) at hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:90)
          Jul 03, 2018 1:34:21 PM hudson.remoting.SynchronousCommandTransport$ReaderThread lambda$new$0SEVERE: Uncaught exception in SynchronousCommandTransport.ReaderThread Thread[Channel reader thread: test,5,main]java.lang.IllegalStateException: This consumer has already been closed. at org.apache.kafka.clients.consumer.KafkaConsumer.acquireAndEnsureOpen(KafkaConsumer.java:1811) at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1216) at io.jenkins.plugins.remotingkafka.commandtransport.KafkaClassicCommandTransport.closeRead(KafkaClassicCommandTransport.java:74) at hudson.remoting.Channel.terminate(Channel.java:1031) at hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:99)
          {code}           		New: We have the following logs when the agent is deleted from the UI 
          {code:java}
          SEVERE: Unexpected error in channel testSEVERE: Unexpected error in channel test
          java.lang.IllegalStateException: This consumer has already been closed. at org.apache.kafka.clients.consumer.KafkaConsumer.acquireAndEnsureOpen(KafkaConsumer.java:1811) at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1216) at io.jenkins.plugins.remotingkafka.commandtransport.KafkaClassicCommandTransport.closeRead(KafkaClassicCommandTransport.java:74) at hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:90)

          Jul 03, 2018 1:34:21 PM hudson.remoting.SynchronousCommandTransport$ReaderThread lambda$new$0
          SEVERE: Uncaught exception in SynchronousCommandTransport.ReaderThread Thread[Channel reader thread: test,5,main]
          java.lang.IllegalStateException: This consumer has already been closed. at org.apache.kafka.clients.consumer.KafkaConsumer.acquireAndEnsureOpen(KafkaConsumer.java:1811) at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1216) at io.jenkins.plugins.remotingkafka.commandtransport.KafkaClassicCommandTransport.closeRead(KafkaClassicCommandTransport.java:74) at hudson.remoting.Channel.terminate(Channel.java:1031) at hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:99)

          Exception: java.lang.IllegalStateException thrown from the UncaughtExceptionHandler in thread "Channel reader thread: test"{code}
          Pham Vu Tuan made changes -
          Status Original: Open [ 1 ] New: In Progress [ 3 ]
          Pham Vu Tuan made changes -
          Status Original: In Progress [ 3 ] New: In Review [ 10005 ]
          Pham Vu Tuan made changes -
          Resolution New: Done [ 10000 ]
          Status Original: In Review [ 10005 ] New: Resolved [ 5 ]

            pvtuan10 Pham Vu Tuan
            pvtuan10 Pham Vu Tuan
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: