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: [email protected]
For additional commands, e-mail: [email protected]
