Custom Emitter keeps logging CuratorDruidNodeDiscoveryProvider

[Jeet Patel]

Hi all,

I'm building a custom emitter where I get the DruidNode and set a @Self 
annotation to it in my emitter module, shown below:

  @Provides
  @ManageLifecycle
  @Named(EMITTER_TYPE)
  public Emitter getEmitter(MyEmitterConfig myEmitterConfig, ObjectMapper 
mapper, @Self DruidNode druidNode)
  {
    return new HubbleEmitter(myEmitterConfig, mapper, druidNode);
  }


In the main MyEmitter class, I pass the DruidNode in the constructor so that I 
can use the object as shown below:

public MyEmitter(
      MyEmitterConfig myEmitterConfig,
      ObjectMapper mapper,
      DruidNode druidNode
  )
  {
    this.mapper = mapper;
    this.myEmitterConfig = myEmitterConfig;
    this.druidNode = druidNode;
    this.healthCheck = new DruidHealthCheck(this.myEmitterConfig, 
this.druidNode.getServiceName(), this.druidNode.getUriToUse().toString(), 
this.druidNode.getHost());
    log.info("Constructed MyEmitter");
  }

Now I've created a DruidHealthCheck class, in which I've a method 
(checkDruidNodeHealth) which calls the /status/selfDiscovered endpoint. The 
method returns 1 if status == 200 else 0.

Now in the start() method of MyEmitter class, I have following:

@Override
  public void start()
  {
    exec.scheduleAtFixedRate(
        healthCheck::checkDruidNodeHealth,
        10000,
        10000,
        TimeUnit.MILLISECONDS
    );
  }

So every 10 seconds, the /status/selfDiscovered endpoint will be called which 
will return either 1 or 0.

Now, wherever the executor calls the method `checkDruidNodeHealth` following is 
printed in service logs after the lifecycle is started:

2021-08-26T09:51:05,109 INFO [main] 
org.apache.druid.java.util.common.lifecycle.Lifecycle - Successfully started 
lifecycle [module]
2021-08-26T09:51:14,306 INFO [qtp589489519-126] 
org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - 
Node[http://localhost:8082] of role[broker] appeared.
2021-08-26T09:51:24,113 INFO [qtp589489519-125] 
org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - 
Node[http://localhost:8082] of role[broker] appeared.

Can someone please help me with this. Why this is happening? Every scheduled 
fix rate `CuratorDruidNodeDiscoveryProvider` logs in the service.

Thank you :)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@druid.apache.org
For additional commands, e-mail: dev-h...@druid.apache.org