{"record":{"id":"ca910a9c1ed4fee0","repo":"pinpoint-apm/pinpoint","slug":"receive-unexpected-response-result","errorCode":null,"errorMessage":"Receive unexpected response: result = {}","messagePattern":"Receive unexpected response: result = (.+?)","errorType":"console","errorClass":null,"httpStatus":null,"severity":"error","filePath":"realtime/realtime-collector/src/main/java/com/navercorp/pinpoint/realtime/collector/controller/ClusterPointController.java","lineNumber":202,"sourceCode":"            response = request0(grpcAgentConnection, checkCount);\n        } catch (StatusRuntimeException e) {\n            logger.warn(\"Exception occurred while request message. message:{}\", e.getMessage(), e);\n            if (e.getStatus().getCode() == Status.CANCELLED.getCode()) {\n                clearConnection();\n                return CheckConnectionStatusResult.FAIL_AND_CLEAR_CONNECTION;\n            }\n            return CheckConnectionStatusResult.FAIL;\n        } catch (ClusterException e) {\n            logger.warn(\"Exception occurred while request message. message:{}\", e.getMessage(), e);\n            clearConnection();\n            return CheckConnectionStatusResult.FAIL_AND_CLEAR_CONNECTION;\n        }\n        try {\n            PCmdEchoResponse result = response.get(3000, TimeUnit.MILLISECONDS);\n            if (result.getMessage().equals(\"PING\")) {\n                return CheckConnectionStatusResult.SUCCESS;\n            }\n            logger.warn(\"Receive unexpected response: result = {}\", result);\n        } catch (Exception cause) {\n            logger.warn(\"Failed while request message. message:{}\", cause.getMessage(), cause);\n            return CheckConnectionStatusResult.FAIL;\n        }\n\n        return CheckConnectionStatusResult.FAIL;\n    }\n\n    private void clearConnection() {\n    }\n\n    // If the occur exception in connection, do not retry\n    // Multiple attempts only at timeout\n    private CompletableFuture<PCmdEchoResponse> request0(GrpcAgentConnection conn, int maxCount) {\n        Mono<PCmdEchoResponse> mono = Mono.create(sink -> {\n            long sinkId = this.echoSinkRepository.put(sink);\n            sink.onDispose(() -> {\n                this.echoSinkRepository.invalidate(sinkId);","sourceCodeStart":184,"sourceCodeEnd":220,"githubUrl":"https://github.com/pinpoint-apm/pinpoint/blob/744c3d3075e595656abb1ae331ad2c0e4c9eb996/realtime/realtime-collector/src/main/java/com/navercorp/pinpoint/realtime/collector/controller/ClusterPointController.java#L184-L220","documentation":"Warn log in ClusterPointController.request: the collector received an unexpected response object from the agent over the cluster gRPC channel (result did not match an expected response type), so the connection check cannot interpret it.","triggerScenarios":"Thrown at realtime/realtime-collector/src/main/java/com/navercorp/pinpoint/realtime/collector/controller/ClusterPointController.java:202 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Check for agent/collector version mismatch on the cluster protocol","Verify the response type dispatcher handles the agent's reply type","Re-run the connection check or re-register the cluster point"],"exampleFix":null,"handlingStrategy":"fallback","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"744c3d3075e595656abb1ae331ad2c0e4c9eb996","analyzedAt":"2026-09-07T18:48:45.289Z","contentChangedAt":"2026-09-07T18:48:45.289Z","schemaVersion":2},"datasetVersion":"2026-09-17T15:17:12.973Z"}