#

Junjie

2025-01-08 0bd50999a23853adefa7a8ad72a3f777ea189097

 src/main/java/com/zy/core/thread/impl/NyShuttleThread.java

@@ -106,7 +106,7 @@
                        continue;
                    }

                    Object object = redisUtil.get(RedisKeyType.SHUTTLE.key + slave.getId());
                    Object object = redisUtil.get(RedisKeyType.SHUTTLE_FLAG.key + slave.getId());
                    if (object == null) {
                        continue;
                    }
@@ -713,7 +713,7 @@
        ArrayList<NavigateNode> path = new ArrayList<>();
        if (shuttleProtocol.getTaskNo() != 0) {
            //存在任务，获取指令
            Object object = redisUtil.get(RedisKeyType.SHUTTLE.key + shuttleProtocol.getTaskNo());
            Object object = redisUtil.get(RedisKeyType.SHUTTLE_WORK_FLAG.key + shuttleProtocol.getTaskNo());
            if (object != null) {
                ShuttleRedisCommand redisCommand = null;
                try {