diff --git a/tunnel-server/src/main/java/com/alibaba/arthas/tunnel/server/cluster/RedisTunnelClusterStore.java b/tunnel-server/src/main/java/com/alibaba/arthas/tunnel/server/cluster/RedisTunnelClusterStore.java index 7a932cc56..9ff45d76f 100644 --- a/tunnel-server/src/main/java/com/alibaba/arthas/tunnel/server/cluster/RedisTunnelClusterStore.java +++ b/tunnel-server/src/main/java/com/alibaba/arthas/tunnel/server/cluster/RedisTunnelClusterStore.java @@ -37,6 +37,9 @@ public class RedisTunnelClusterStore implements TunnelClusterStore { try { ValueOperations opsForValue = redisTemplate.opsForValue(); String infoStr = opsForValue.get(prefix + agentId); + if (infoStr == null) { + throw new IllegalArgumentException("can not find info for agentId: " + agentId); + } AgentClusterInfo info = MAPPER.readValue(infoStr, AgentClusterInfo.class); return info; } catch (Throwable e) {