Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2482#discussion_r158762721
--- Diff:
storm-client/src/jvm/org/apache/storm/metric/FileBasedEventLogger.java ---
@@ -120,8 +127,30 @@ protected String buildLogMessage(EventInfo event) {
public void close() {
try {
eventLogWriter.close();
+
} catch (IOException ex) {
LOG.error("Error closing event log.", ex);
}
+
+ closeFlushScheduler();
+ }
+
+ private void closeFlushScheduler() {
+ if (flushScheduler != null) {
+ flushScheduler.shutdown();
+ try {
+ if (!flushScheduler.awaitTermination(1, TimeUnit.SECONDS))
{
--- End diff --
Most of cases in codebase we call shutdownNow() and doesn't wait more. I'll
follow the case.
---
