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!
---