code: @SuppressWarnings("rawtypes")
      private void initCleaner(Map conf) throws IOException {
          final ScheduledExecutorService scheduExec = data.getScheduExec();
  
          if (!data.isLaunchedCleaner()) {
              // Schedule Nimbus inbox cleaner/nimbus/inbox jar
              String dir_location = StormConfig.masterInbox(conf);
              int inbox_jar_expiration_secs = JStormUtils.parseInt(conf.get(Config.NIMBUS_INBOX_JAR_EXPIRATION_SECS), 3600);
              CleanRunnable r2 = new CleanRunnable(dir_location, inbox_jar_expiration_secs);
  
              int cleanup_inbox_freq_secs = JStormUtils.parseInt(conf.get(Config.NIMBUS_CLEANUP_INBOX_FREQ_SECS), 600);
  
              scheduExec.scheduleAtFixedRate(r2, 0, cleanup_inbox_freq_secs, TimeUnit.SECONDS);
              data.setLaunchedCleaner(true);
              LOG.info("Successfully init " + dir_location + " cleaner");
          } else {
              LOG.info("cleaner thread has been started already");
          }
      }
docs: Right now, every 600 seconds, nimbus will clean jar under /LOCAL-DIR/nimbus/inbox,
  which is the uploading topology directory