-
Notifications
You must be signed in to change notification settings - Fork 107
Description
不清楚是否是因为key里有乱码。该报错中提到的阈值能否调整?乱码key能否跳过?
报错如下:
2024-02-19 09:32:37.843|[ WARN ]|[threadPoolTaskExecutor-63] -> MemoryAndSqliteTaskStatusManger#brokenStatusAndLog:211 | 任务Id【71D030FF17DF42E082833B9EDF508404】任务 启动/运行异常停止 ,Class【class syncer.transmission.queue.SendCommandWithOutQueue】,异常原因【被抛弃key数量到达阈值[1],exception reason[null->RdbCommandSendStrategy-> AofCommandSendStrategy->DbMappingStrategy->OffsetUpdateStrategy->DataAnalysisStrategy->SentinelCommandFileterStrategy->CommandProcessingTimeCalculationStrategy]】 2024-02-19 09:32:37.844|[ERROR ]|[threadPoolTaskExecutor-63] -> SendCommandWithOutQueue#run:188 | [71D030FF17DF42E082833B9EDF508404]抛弃 command:[STRING] key:��^@^Et^@ ^\IOT_INSTRUCT_SEQ:10019990034 value [class syncer.replica.event.iter.datatype.BatchedKeyValuePairEvent:"Nw=="] ,class:[class syncer.replica.event.iter.datatype.Batche dKeyStringValueStringEvent]:原因[null->RdbCommandSendStrategy->AofCommandSendStrategy->DbMappingStrategy->OffsetUpdateStrategy->DataAnalysisStrategy->SentinelCommandFi leterStrategy->CommandProcessingTimeCalculationStrategy] syncer.transmission.exception.StartegyNodeException: null->RdbCommandSendStrategy->AofCommandSendStrategy->DbMappingStrategy->OffsetUpdateStrategy->DataAnalysisStrateg y->SentinelCommandFileterStrategy->CommandProcessingTimeCalculationStrategy at syncer.transmission.strategy.commandprocessing.impl.CommandProcessingTimeCalculationStrategy.run(CommandProcessingTimeCalculationStrategy.java:85) at syncer.transmission.strategy.commandprocessing.ProcessingRunStrategyChain.run(ProcessingRunStrategyChain.java:57) at syncer.transmission.queue.SendCommandWithOutQueue.run(SendCommandWithOutQueue.java:78) at syncer.transmission.task.RedisDataSyncTransmissionTask$1.onEvent(RedisDataSyncTransmissionTask.java:227) at syncer.replica.listener.ValueDumpIterableEventListener.onEvent(ValueDumpIterableEventListener.java:65) at syncer.replica.listener.AbstractReplicationListener.doEventListener(AbstractReplicationListener.java:57) at syncer.replica.replication.AbstractReplication.submitEvent(AbstractReplication.java:146) at syncer.replica.parser.RedisSyncerRdbParser.parse(RedisSyncerRdbParser.java:207) at syncer.replica.protocol.DefaultSyncRedisProtocol$2.handle(DefaultSyncRedisProtocol.java:215) at syncer.replica.parser.protocol.ProtocolReplyParser.parse(ProtocolReplyParser.java:102) at syncer.replica.protocol.DefaultSyncRedisProtocol.reply(DefaultSyncRedisProtocol.java:263) at syncer.replica.protocol.DefaultSyncRedisProtocol.parseDump(DefaultSyncRedisProtocol.java:202)