|
@@ -2368,7 +2368,7 @@ public class DFSOutputStream extends FSOutputSummer
|
|
}
|
|
}
|
|
|
|
|
|
@VisibleForTesting
|
|
@VisibleForTesting
|
|
- ExtendedBlock getBlock() {
|
|
|
|
|
|
+ synchronized ExtendedBlock getBlock() {
|
|
return streamer.getBlock();
|
|
return streamer.getBlock();
|
|
}
|
|
}
|
|
|
|
|
|
@@ -2386,7 +2386,7 @@ public class DFSOutputStream extends FSOutputSummer
|
|
* @return The times have retried to recover pipeline, for the same packet.
|
|
* @return The times have retried to recover pipeline, for the same packet.
|
|
*/
|
|
*/
|
|
@VisibleForTesting
|
|
@VisibleForTesting
|
|
- int getPipelineRecoveryCount() {
|
|
|
|
|
|
+ synchronized int getPipelineRecoveryCount() {
|
|
return streamer.pipelineRecoveryCount;
|
|
return streamer.pipelineRecoveryCount;
|
|
}
|
|
}
|
|
}
|
|
}
|