big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDDS-1832 : Improve logging for PipelineActions handling in SCM and datanode. (Change to Error logging)

Browse Source 
Signed-off-by: Anu Engineer <aengineer@apache.org>
This commit is contained in:
Aravindan Vijayan 2019-08-02 11:04:52 -07:00 committed by Anu Engineer
parent 15545c8bf1
commit fc229b6490
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java
View File

@ -558,7 +558,7 @@ private void triggerPipelineClose(RaftGroupId groupId, String detail,
if (triggerHB) { if (triggerHB) {
context.getParent().triggerHeartbeat(); context.getParent().triggerHeartbeat();
} }
LOG.info( LOG.error(
"pipeline Action " + action.getAction() + " on pipeline " + pipelineID "pipeline Action " + action.getAction() + " on pipeline " + pipelineID
+ ".Reason : " + action.getClosePipeline().getDetailedReason()); + ".Reason : " + action.getClosePipeline().getDetailedReason());
} }

2
hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineActionHandler.java
View File

@ -57,7 +57,7 @@ public void onMessage(PipelineActionsFromDatanode report,
pipelineID = PipelineID. pipelineID = PipelineID.
getFromProtobuf(action.getClosePipeline().getPipelineID()); getFromProtobuf(action.getClosePipeline().getPipelineID());
Pipeline pipeline = pipelineManager.getPipeline(pipelineID); Pipeline pipeline = pipelineManager.getPipeline(pipelineID);
LOG.info("Received pipeline action {} for {} from datanode {}. " + LOG.error("Received pipeline action {} for {} from datanode {}. " +
"Reason : {}", action.getAction(), pipeline, "Reason : {}", action.getAction(), pipeline,
report.getDatanodeDetails(), report.getDatanodeDetails(),
action.getClosePipeline().getDetailedReason()); action.getClosePipeline().getDetailedReason());