Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2773#discussion_r205973135
--- Diff:
storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStore.java ---
@@ -197,7 +198,7 @@ public void run() {
throw new RuntimeException(e);
}
}
- }, 0,
ObjectReader.getInt(conf.get(DaemonConfig.NIMBUS_CODE_SYNC_FREQ_SECS)));
+ }, 0,
ObjectReader.getInt(conf.get(DaemonConfig.NIMBUS_CODE_SYNC_FREQ_SECS))*1000);
--- End diff --
Nice catch!---
