JanYork commented on issue #836:
URL:
https://github.com/apache/rocketmq-clients/issues/836#issuecomment-2360795537
2024-09-19 19:53:36 INFO ClientHousekeepingScheduledThread1 - clear handle
of this client when client unregister. group:task-to-pool,
clientChannelInfo:ClientChannelInfo
[channel=GrpcClientChannel{clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo,
remoteAddress=169.254.95.59:54910, localAddress=169.254.95.59:8081},
clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo, language=HTTP, version=473,
lastUpdateTimestamp=1726746690044]
2024-09-19 19:53:36 INFO ClientHousekeepingScheduledThread1 - remove grpc
channel when client unregister. group:task-to-pool,
clientChannelInfo:ClientChannelInfo
[channel=GrpcClientChannel{clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo,
remoteAddress=169.254.95.59:54910, localAddress=169.254.95.59:8081},
clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo, language=HTTP, version=473,
lastUpdateTimestamp=1726746690044], removed:true
2024-09-19 19:53:36 INFO ClientHousekeepingScheduledThread1 - remove
remoting channel when client unregister. clientChannelInfo:ClientChannelInfo
[channel=GrpcClientChannel{clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo,
remoteAddress=169.254.95.59:54910, localAddress=169.254.95.59:8081},
clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo, language=HTTP, version=473,
lastUpdateTimestamp=1726746690044]
2024-09-19 19:53:36 INFO GrpcClientSettingsManagerCleaner - remove unused
grpc client settings. group:null, settings:client_type: SIMPLE_CONSUMER
access_point {
scheme: IPv4
addresses {
host: "127.0.0.1"
port: 8081
}
}
backoff_policy {
max_attempts: 17
customized_backoff {
next {
seconds: 1
}
next {
seconds: 5
}
next {
seconds: 10
}
next {
seconds: 30
}
next {
seconds: 60
}
next {
seconds: 120
}
next {
seconds: 180
}
next {
seconds: 240
}
next {
seconds: 300
}
next {
seconds: 360
}
next {
seconds: 420
}
next {
seconds: 480
}
next {
seconds: 540
}
next {
seconds: 600
}
next {
seconds: 1200
}
next {
seconds: 1800
}
next {
seconds: 3600
}
next {
seconds: 7200
}
}
}
request_timeout {
seconds: 3
}
subscription {
group {
name: "task-to-pool"
}
subscriptions {
topic {
name: "task-processing"
}
expression {
type: TAG
expression: "task-to-pool"
}
}
fifo: false
receive_batch_size: 32
long_polling_timeout {
seconds: 30
}
}
user_agent {
language: NODE_JS
version: "1.0.0"
platform: "darwin"
hostname: "JanYorkMacBook-Pro.local"
}
2024-09-19 19:53:49 ERROR GrpcConsumerThreadPool-7 - internal server error
java.lang.NullPointerException: Cannot invoke
"apache.rocketmq.v2.Settings.getSubscription()" because "settings" is null
at
org.apache.rocketmq.proxy.grpc.v2.consumer.ReceiveMessageActivity.receiveMessage(ReceiveMessageActivity.java:63)
at
org.apache.rocketmq.proxy.grpc.v2.DefaultGrpcMessingActivity.receiveMessage(DefaultGrpcMessingActivity.java:117)
at
org.apache.rocketmq.proxy.grpc.v2.GrpcMessagingApplication.lambda$receiveMessage$14(GrpcMessagingApplication.java:278)
at
org.apache.rocketmq.proxy.grpc.v2.GrpcMessagingApplication$GrpcTask.run(GrpcMessagingApplication.java:442)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
2024-09-19 19:53:49 ERROR GrpcRequestExecutorThread-42 - telemetry on error
io.grpc.StatusRuntimeException: CANCELLED: client cancelled
at io.grpc.Status.asRuntimeException(Status.java:530)
at
io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:291)
at
io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at
io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at
io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at
io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at
io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at
io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at
org.apache.rocketmq.proxy.grpc.interceptor.GlobalExceptionInterceptor$1.onCancel(GlobalExceptionInterceptor.java:65)
at
io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at
io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at
io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at
io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
at
io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:378)
at
io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:365)
at
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:923)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
--
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]
