diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/states/endpoint/HeartbeatEndpointTask.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/states/endpoint/HeartbeatEndpointTask.java index da2034d93c2d..911b4b1536c2 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/states/endpoint/HeartbeatEndpointTask.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/states/endpoint/HeartbeatEndpointTask.java @@ -147,8 +147,12 @@ public EndpointStateMachine.EndPointStates call() throws Exception { rpcEndpoint.setLastSuccessfulHeartbeat(ZonedDateTime.now()); rpcEndpoint.zeroMissedCount(); } catch (IOException ex) { - // put back the reports which failed to be sent - putBackReports(requestBuilder); + // don't resend reports to recon as it could be down for days + // DN is expected to work fine without recon and not go OOM + if (!rpcEndpoint.isPassive()) { + // put back the reports which failed to be sent + putBackReports(requestBuilder); + } rpcEndpoint.logIfNeeded(ex); } finally {