|
@@ -202,7 +202,6 @@ public class EditLogTailer {
|
|
}
|
|
}
|
|
|
|
|
|
public void stop() throws IOException {
|
|
public void stop() throws IOException {
|
|
- rollEditsRpcExecutor.shutdown();
|
|
|
|
tailerThread.setShouldRun(false);
|
|
tailerThread.setShouldRun(false);
|
|
tailerThread.interrupt();
|
|
tailerThread.interrupt();
|
|
try {
|
|
try {
|
|
@@ -210,6 +209,8 @@ public class EditLogTailer {
|
|
} catch (InterruptedException e) {
|
|
} catch (InterruptedException e) {
|
|
LOG.warn("Edit log tailer thread exited with an exception");
|
|
LOG.warn("Edit log tailer thread exited with an exception");
|
|
throw new IOException(e);
|
|
throw new IOException(e);
|
|
|
|
+ } finally {
|
|
|
|
+ rollEditsRpcExecutor.shutdown();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|