code: @SuppressWarnings("rawtypes")
      @Override
      public void open(Map conf, TopologyContext context, SpoutOutputCollector collector)
      {
          super.open(conf, context, collector);
  
          this.taskId = context.getThisComponentId() + "_" + context.getThisTaskId();
  
          if (this.reloadConfig)
          {
              if (conf.containsKey(StormConfigGenerator.INIT_CONFIG_KEY))
              {
                  String watchPath = conf.get(StormConfigGenerator.INIT_CONFIG_KEY).toString();
                  String logFormat = "Config reload watch start. : WatchPath={0}, Interval(Sec)={1}";
                  logger.info(MessageFormat.format(logFormat, watchPath, this.reloadConfigIntervalSec));
  
                  this.watcher = new ConfigFileWatcher(watchPath, this.reloadConfigIntervalSec);
                  this.watcher.init();
              }
          }
  
          onOpen(conf, context);
      }
docs: Initialize method called after extracted for worker processes.<br>
  <br>
  Initialize task id.
  
  @param conf Storm configuration
  @param context Topology context
  @param collector SpoutOutputCollector