修复checker检测keeperContainer时的一个bug (ctripcorp#768)

* 修复checker检测keeperContainer时的一个bug

* 修复checker校验空keepercontainer时未考虑dc问题

---------

Co-authored-by: yifuzhou <[email protected]>

Author: passerbyzed

redis/redis-checker/src/main/java/com/ctrip/xpipe/redis/checker/impl/KeeperContainerInfoReporter.java

@@ -110,13 +110,15 @@ public void reportKeeperContainerInfo() {
             Map<String, Map<DcClusterShardActive, Long>> collectedInfos = keeperFlowCollector.getHostPort2InputFlow();
             Map<String, Map<DcClusterShardActive, Long>> hostPort2InputFlow = new HashMap<>();
             for (DcMeta dcMeta : metaCache.getXpipeMeta().getDcs().values()) {
-                dcMeta.getKeeperContainers().forEach(keeperContainerMeta -> {
-                    if (collectedInfos.containsKey(keeperContainerMeta.getIp())) {
-                        hostPort2InputFlow.put(keeperContainerMeta.getIp(), collectedInfos.get(keeperContainerMeta.getIp()));
-                    } else {
-                        hostPort2InputFlow.put(keeperContainerMeta.getIp(), new ConcurrentHashMap<>());
-                    }
-                });
+                if (CURRENT_IDC.equalsIgnoreCase(dcMeta.getId())) {
+                    dcMeta.getKeeperContainers().forEach(keeperContainerMeta -> {
+                        if (collectedInfos.containsKey(keeperContainerMeta.getIp())) {
+                            hostPort2InputFlow.put(keeperContainerMeta.getIp(), collectedInfos.get(keeperContainerMeta.getIp()));
+                        } else {
+                            hostPort2InputFlow.put(keeperContainerMeta.getIp(), new ConcurrentHashMap<>());
+                        }
+                    });
+                }
             }
             Map<DcClusterShard, Long> dcClusterShardUsedMemory = redisUsedMemoryCollector.getDcClusterShardUsedMemory();
             List<KeeperContainerUsedInfoModel> result = new ArrayList<>(hostPort2InputFlow.keySet().size());