fix when manager restart, collect register error

[Ceilzcx]

What's changed?

#1709

Checklist

• I have read the Contributing Guide
• I have written the necessary doc or comment.
• I have added the necessary unit tests and all cases have passed.

Add or update API

• I have added the necessary e2e tests and all cases have passed.

[tomsun28]

if the collector is offline and re online throgh heartbeatProcessor, does we need add this.manageServer.getCollectorAndJobScheduler().collectorGoOnline(collector, collectorInfo); to re-dispath current collect jobs.

[tomsun28]

hi, i think this bug is due code here

    @Override
    public void collectorGoOnline(String identity, CollectorInfo collectorInfo) {
        Optional<Collector> collectorOptional = collectorDao.findCollectorByName(identity);
        Collector collector;
        if (collectorOptional.isPresent()) {
            collector = collectorOptional.get();
            if (collector.getStatus() == CommonConstants.COLLECTOR_STATUS_ONLINE) {
                return;
            }
            collector.setStatus(CommonConstants.COLLECTOR_STATUS_ONLINE);
            if (collectorInfo != null) {
                collector.setIp(collectorInfo.getIp());
                collector.setMode(collectorInfo.getMode());   
                collector.setMode(collectorInfo.getMode());
            }
        }

the

            if (collector.getStatus() == CommonConstants.COLLECTOR_STATUS_ONLINE) {
                return;
            }

when the main server shutdown, the all collector status is online. And when the main server startup, first will set all collector status offline in database, but if the collector online request is before the init offline, the online request will be ignored.

[tomsun28]

LGTM 👍