// If sendHeartbeat throws, fetchNewEvents and cleanup should still be called
        final AtomicBoolean fetchCalled = new AtomicBoolean(false);
        final AtomicBoolean cleanupCalled = new AtomicBoolean(false);
        final CoordinatorHelper helper = new CoordinatorHelper() {
            @Override
            public void sendHeartbeat() {

     */
    @PostConstruct
    public void init() {
        instanceId = ComponentUtil.getSystemHelper().getInstanceId();
        lastEventCheckTime = System.currentTimeMillis();

        sendHeartbeat();

        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final int interval = fessConfig.getCoordinatorPollIntervalAsInteger();