RedisSyncer是一个多任务的redis数据同步工具，可灵活的满足Redis间的数据同步、迁移需求; redissyncer is a redis synchronization tool, used in redis single instance and cluster synchronization
2023-05-25 20:01:09.796|[ERROR ]|[threadPoolTaskExecutor-19] -> SendCommandWithOutQueue#run:161 | [D65B467DC68A403DB0DC80B516254E30]抛弃key:SETxx:lock ,class:[class syncer.replica.datatype.command.DefaultCommand]:原因[For input string: "ex"->AofCommandSendStrategy->DbMappingStrategy->OffsetUpdateStrategy->DataAnalysisStrategy->SentinelCommandFileterStrategy->CommandProcessingTimeCalculationStrategy]
syncer.transmission.exception.StartegyNodeException: For input string: "ex"->AofCommandSendStrategy->DbMappingStrategy->OffsetUpdateStrategy->DataAnalysisStrategy->SentinelCommandFileterStrategy->CommandProcessingTimeCalculationStrategy
at syncer.transmission.strategy.commandprocessing.impl.CommandProcessingTimeCalculationStrategy.run(CommandProcessingTimeCalculationStrategy.java:187)
at syncer.transmission.strategy.commandprocessing.ProcessingRunStrategyChain.run(ProcessingRunStrategyChain.java:57)
at syncer.transmission.queue.SendCommandWithOutQueue.run(SendCommandWithOutQueue.java:77)
at syncer.transmission.task.RedisDataSyncTransmissionTask$1.onEvent(RedisDataSyncTransmissionTask.java:218)
at syncer.replica.listener.ValueDumpIterableEventListener.onEvent(ValueDumpIterableEventListener.java:54)
at syncer.replica.listener.AbstractReplicationListener.doEventListener(AbstractReplicationListener.java:57)
at syncer.replica.replication.AbstractReplication.submitEvent(AbstractReplication.java:147)
at syncer.replica.retry.SocketReplicationRetrier.open(SocketReplicationRetrier.java:139)
at syncer.replica.retry.AbstractReplicationRetrier.retry(AbstractReplicationRetrier.java:40)
at syncer.replica.retry.SocketReplicationRetrier.retry(SocketReplicationRetrier.java:170)
at syncer.replica.replication.SocketReplication.open(SocketReplication.java:120)
at syncer.replica.replication.RedisReplication.open(RedisReplication.java:256)
at syncer.transmission.task.RedisDataSyncTransmissionTask.run(RedisDataSyncTransmissionTask.java:251)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2023-05-25 20:01:09.796|[ERROR ]|[threadPoolTaskExecutor-19] -> SendCommandWithOutQueue#run:161 | [D65B467DC68A403DB0DC80B516254E30]抛弃key:SETxx:lock ,class:[class syncer.replica.datatype.command.DefaultCommand]:原因[For input string: "ex"->AofCommandSendStrategy->DbMappingStrategy->OffsetUpdateStrategy->DataAnalysisStrategy->SentinelCommandFileterStrategy->CommandProcessingTimeCalculationStrategy] syncer.transmission.exception.StartegyNodeException: For input string: "ex"->AofCommandSendStrategy->DbMappingStrategy->OffsetUpdateStrategy->DataAnalysisStrategy->SentinelCommandFileterStrategy->CommandProcessingTimeCalculationStrategy at syncer.transmission.strategy.commandprocessing.impl.CommandProcessingTimeCalculationStrategy.run(CommandProcessingTimeCalculationStrategy.java:187) at syncer.transmission.strategy.commandprocessing.ProcessingRunStrategyChain.run(ProcessingRunStrategyChain.java:57) at syncer.transmission.queue.SendCommandWithOutQueue.run(SendCommandWithOutQueue.java:77) at syncer.transmission.task.RedisDataSyncTransmissionTask$1.onEvent(RedisDataSyncTransmissionTask.java:218) at syncer.replica.listener.ValueDumpIterableEventListener.onEvent(ValueDumpIterableEventListener.java:54) at syncer.replica.listener.AbstractReplicationListener.doEventListener(AbstractReplicationListener.java:57) at syncer.replica.replication.AbstractReplication.submitEvent(AbstractReplication.java:147) at syncer.replica.retry.SocketReplicationRetrier.open(SocketReplicationRetrier.java:139) at syncer.replica.retry.AbstractReplicationRetrier.retry(AbstractReplicationRetrier.java:40) at syncer.replica.retry.SocketReplicationRetrier.retry(SocketReplicationRetrier.java:170) at syncer.replica.replication.SocketReplication.open(SocketReplication.java:120) at syncer.replica.replication.RedisReplication.open(RedisReplication.java:256) at syncer.transmission.task.RedisDataSyncTransmissionTask.run(RedisDataSyncTransmissionTask.java:251) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)