search

dockerzhang / incubator-inlong

Apache InLong - a one-stop data streaming platform
https://inlong.apache.org/
Apache License 2.0
0 stars 0 forks source link

[INLONG-102] Fix question [TUBEMQ-101] [Optimize code] #102

Closed dockerzhang closed 3 years ago

dockerzhang commented 3 years ago

Because the core module uses jdk1.7, this code cannot use 'putIfAbsent'

addrMap4Failover.putIfAbsent(tmpNodeAddrInfo.getHostPortStr(), tmpNodeAddrInfo);

We should use the original

if (addrMap4Failover.get(tmpNodeAddrInfo.getHostPortStr()) == null) {
    addrMap4Failover.put(tmpNodeAddrInfo.getHostPortStr(), tmpNodeAddrInfo);
}

 

JIRA link - [INLONG-102] created by viviel