pinpoint-apm/pinpoint · error

Failed while request message. message

Error message

Failed while request message. message:{}

What it means

Warn log in ClusterPointController.request: a ClusterException occurred while sending the request to the pinned agent; the connection is cleared and the check returns FAIL_AND_CLEAR_CONNECTION, forcing re-registration.

Solutions

1. Check network/gRPC connectivity between collector and agent
2. Confirm the agent's cluster key is still registered and valid
3. Allow the connection to be re-established after clearing the stale one

When it happens

Trigger: Thrown at realtime/realtime-collector/src/main/java/com/navercorp/pinpoint/realtime/collector/controller/ClusterPointController.java:204 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of pinpoint-apm/pinpoint@744c3d3075 (2026-09-07). Data as JSON: /api/errors/007f0dde5b7dd18d. Report an issue: GitHub.

Appendix: source

Thrown at realtime/realtime-collector/src/main/java/com/navercorp/pinpoint/realtime/collector/controller/ClusterPointController.java:204

            logger.warn("Exception occurred while request message. message:{}", e.getMessage(), e);
            if (e.getStatus().getCode() == Status.CANCELLED.getCode()) {
                clearConnection();
                return CheckConnectionStatusResult.FAIL_AND_CLEAR_CONNECTION;
            }
            return CheckConnectionStatusResult.FAIL;
        } catch (ClusterException e) {
            logger.warn("Exception occurred while request message. message:{}", e.getMessage(), e);
            clearConnection();
            return CheckConnectionStatusResult.FAIL_AND_CLEAR_CONNECTION;
        }
        try {
            PCmdEchoResponse result = response.get(3000, TimeUnit.MILLISECONDS);
            if (result.getMessage().equals("PING")) {
                return CheckConnectionStatusResult.SUCCESS;
            }
            logger.warn("Receive unexpected response: result = {}", result);
        } catch (Exception cause) {
            logger.warn("Failed while request message. message:{}", cause.getMessage(), cause);
            return CheckConnectionStatusResult.FAIL;
        }

        return CheckConnectionStatusResult.FAIL;
    }

    private void clearConnection() {
    }

    // If the occur exception in connection, do not retry
    // Multiple attempts only at timeout
    private CompletableFuture<PCmdEchoResponse> request0(GrpcAgentConnection conn, int maxCount) {
        Mono<PCmdEchoResponse> mono = Mono.create(sink -> {
            long sinkId = this.echoSinkRepository.put(sink);
            sink.onDispose(() -> {
                this.echoSinkRepository.invalidate(sinkId);
            });
            conn.request(PCmdRequest.newBuilder()

View on GitHub (pinned to 744c3d3075)