|
@@ -57,9 +57,10 @@ public class PipelineActionHandler
|
|
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 {}",
|
|
|
|
- action.getAction(), pipeline, report.getDatanodeDetails());
|
|
|
|
- pipelineManager.finalizeAndDestroyPipeline(pipeline, true);
|
|
|
|
|
|
+ LOG.info("Received pipeline action {} for {} from datanode {}. " +
|
|
|
|
+ "Reason : {}", action.getAction(), pipeline,
|
|
|
|
+ report.getDatanodeDetails(),
|
|
|
|
+ action.getClosePipeline().getDetailedReason());
|
|
} catch (IOException ioe) {
|
|
} catch (IOException ioe) {
|
|
LOG.error("Could not execute pipeline action={} pipeline={} {}",
|
|
LOG.error("Could not execute pipeline action={} pipeline={} {}",
|
|
action, pipelineID, ioe);
|
|
action, pipelineID, ioe);
|