automq
automq copied to clipboard
Executor await timeout when shutdown
2024-01-22 02:36:23.383 | beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
| | 2024-01-22 02:36:23.383 | Stopping socket server request processors (kafka.network.SocketServer) |
| | 2024-01-22 02:36:23.391 | Not processing HandleCommitsEvent because the event queue is closed. (kafka.server.metadata.BrokerMetadataListener) |
| | 2024-01-22 02:36:23.391 | [BrokerToControllerChannelManager broker=95 name=heartbeat]: Shutdown completed (kafka.server.BrokerToControllerRequestThread) |
| | 2024-01-22 02:36:23.391 | [BrokerToControllerChannelManager broker=95 name=heartbeat]: Stopped (kafka.server.BrokerToControllerRequestThread) |
| | 2024-01-22 02:36:23.393 | Broker to controller channel manager for heartbeat shutdown (kafka.server.BrokerToControllerChannelManagerImpl) |
| | 2024-01-22 02:36:23.395 | Node 95 disconnected. (org.apache.kafka.clients.NetworkClient) |
| | 2024-01-22 02:36:23.400 | Stopped socket server request processors (kafka.network.SocketServer) |
| | 2024-01-22 02:36:23.400 | [data-plane Kafka Request Handler on Broker 95], shutting down (kafka.server.KafkaRequestHandlerPool) |
| | 2024-01-22 02:36:23.402 | [ExpirationReaper-95-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) |
| | 2024-01-22 02:36:23.402 | [data-plane Kafka Request Handler on Broker 95], shut down completely (kafka.server.KafkaRequestHandlerPool) |
| | 2024-01-22 02:36:23.403 | Shutdown complete. (kafka.server.KafkaApis) |
| | 2024-01-22 02:36:23.403 | [ExpirationReaper-95-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) |
| | 2024-01-22 02:36:23.403 | [ExpirationReaper-95-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) |
| | 2024-01-22 02:36:23.404 | stop partitions Set() (kafka.server.ReplicaManager) |
| | 2024-01-22 02:36:23.405 | all partitions are closed after 1 ms (kafka.server.ReplicaManager) |
| | 2024-01-22 02:36:23.407 | await streamObjectCompactionExecutor timeout 10s (com.automq.stream.s3.S3StreamClient) |
| | 2024-01-22 02:36:24.407 | wait streams[[]] closed cost 1000ms (com.automq.stream.s3.S3StreamClient) |
| | 2024-01-22 02:36:24.407 | waiting streams close, closed 0 / all 0, closing[[]] (com.automq.stream.s3.S3StreamClient) |
| | 2024-01-22 02:36:24.410 | block WAL service shutdown gracefully: true, cost: 2 ms (com.automq.stream.s3.wal.BlockWALService) |
| | 2024-01-22 02:36:24.410 | await backgroundExecutor timeout 10s (com.automq.stream.s3.S3Storage) |
| | 2024-01-22 02:36:24.411 | closed event queue. (org.apache.kafka.queue.KafkaEventQueue) |
| | 2024-01-22 02:36:24.411 | S3Client shutdown successfully (kafka.log.stream.s3.DefaultS3Client) |
| | 2024-01-22 02:36:24.411 | Broker to controller channel manager for s3stream-to-controller shutdown (kafka.server.BrokerToControllerChannelManagerImpl) |
| | 2024-01-22 02:36:24.411 | [BrokerToControllerChannelManager broker=95 name=s3stream-to-controller]: Shutdown completed (kafka.server.BrokerToControllerRequestThread) |
| | 2024-01-22 02:36:24.411 | [BrokerToControllerChannelManager broker=95 name=s3stream-to-controller]: Stopped (kafka.server.BrokerToControllerRequestThread) |
| | 2024-01-22 02:36:24.411 | [BrokerToControllerChannelManager broker=95 name=s3stream-to-controller]: Shutting down (kafka.server.BrokerToControllerRequestThread) |
| | 2024-01-22 02:36:24.412 | beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue) |
| | 2024-01-22 02:36:24.413 | closed event queue. (org.apache.kafka.queue.KafkaEventQueue) |
| | 2024-01-22 02:36:24.416 | Shutting down. (kafka.coordinator.transaction.TransactionCoordinator)