diagnose如下，时间不压缩的很严格的情况下他自动分析没有结果，所以就缩减到了这1分钟的
[root@cdh81-78 192.168.81.78-19000:connector_v2:np_7p3n9ey197og-incr_trans-1-0:0000000373]# ./connector_utils.sh diagnose -s ‘2026-06-09T10:43:00’ -e ‘2026-06-09T10:44:10’
java -cp /home/ds/plugins/jdbc_connector/tools/connector-command.jar com.oceanbase.oms.connector.command.Command diagnose -t 192.168.81.78-19000:connector_v2:np_7p3n9ey197og-incr_trans-1-0:0000000373 -s 2026-06-09T10:43:00 -e 2026-06-09T10:44:10
10:51:38,399 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback-test.xml]
10:51:38,399 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [logback.xml] at [jar:file:/u01/ds/plugins/jdbc_connector/tools/connector-command.jar!/logback.xml]
10:51:38,407 |-INFO in ch.qos.logback.core.joran.spi.ConfigurationWatchList@215be6bb - URL [jar:file:/u01/ds/plugins/jdbc_connector/tools/connector-command.jar!/logback.xml] is not of type file
10:51:38,463 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - debug attribute not set
10:51:38,467 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - About to instantiate appender of type [ch.qos.logback.core.ConsoleAppender]
10:51:38,469 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as [STDOUT]
10:51:38,472 |-INFO in ch.qos.logback.core.joran.action.NestedComplexPropertyIA - Assuming default type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property
10:51:38,499 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - About to instantiate appender of type [ch.qos.logback.core.rolling.RollingFileAppender]
10:51:38,502 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as [INFO]
10:51:38,507 |-INFO in c.q.l.core.rolling.TimeBasedRollingPolicy@1144648478 - Will use gz compression
10:51:38,508 |-INFO in c.q.l.core.rolling.TimeBasedRollingPolicy@1144648478 - Will use the pattern ./logs/connector-command.%d{yyyy-MM-dd}.log for the active file
10:51:38,510 |-INFO in c.q.l.core.rolling.DefaultTimeBasedFileNamingAndTriggeringPolicy - The date pattern is ‘yyyy-MM-dd’ from file name pattern ‘./logs/connector-command.%d{yyyy-MM-dd}.log.gz’.
10:51:38,510 |-INFO in c.q.l.core.rolling.DefaultTimeBasedFileNamingAndTriggeringPolicy - Roll-over at midnight.
10:51:38,513 |-INFO in c.q.l.core.rolling.DefaultTimeBasedFileNamingAndTriggeringPolicy - Setting initial period to Tue Jun 09 10:51:32 CST 2026
10:51:38,514 |-WARN in ch.qos.logback.core.rolling.RollingFileAppender[INFO] - This appender no longer admits a layout as a sub-component, set an encoder instead.
10:51:38,514 |-WARN in ch.qos.logback.core.rolling.RollingFileAppender[INFO] - To ensure compatibility, wrapping your layout in LayoutWrappingEncoder.
10:51:38,514 |-WARN in ch.qos.logback.core.rolling.RollingFileAppender[INFO] - See also http://logback.qos.ch/codes.html#layoutInsteadOfEncoder for details
10:51:38,515 |-INFO in ch.qos.logback.core.rolling.RollingFileAppender[INFO] - Active log file name: ./logs/connector-command.log
10:51:38,515 |-INFO in ch.qos.logback.core.rolling.RollingFileAppender[INFO] - File property is set to [./logs/connector-command.log]
10:51:38,515 |-INFO in ch.qos.logback.classic.joran.action.LoggerAction - Setting level of logger [stdout] to INFO
10:51:38,515 |-INFO in ch.qos.logback.classic.joran.action.LoggerAction - Setting additivity of logger [stdout] to false
10:51:38,516 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction - Attaching appender named [STDOUT] to Logger[stdout]
10:51:38,516 |-INFO in ch.qos.logback.classic.joran.action.RootLoggerAction - Setting level of ROOT logger to INFO
10:51:38,516 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction - Attaching appender named [INFO] to Logger[ROOT]
10:51:38,516 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - End of configuration.
10:51:38,516 |-INFO in ch.qos.logback.classic.joran.JoranConfigurator@5dfcfece - Registering current configuration as safe fallback point
ERROR StatusLogger Log4j2 could not find a logging implementation. Please add log4j-core to the classpath. Using SimpleLogger to log to the console…
2026-06-09 10:51:39 INFO status:FINISHED
[Metrics]
[DataFlow]
[Delay]
delay:0ms,sourceDelay:72880ms
sinkDelay:108880ms
delayTrend:53s->62s->71s->80s->89s->98s->108s
[ERROR_LOG]
STOPPED
[GcMetrics]
youngMem:4096M,fullMem:4096M,heap:703M/8192M,noHeapUsed:82M
[youngGc-ParNew]costMsAvg:1.25,countPreSec:0.03
[fullGc-ConcurrentMarkSweep]costMsAvg:0.0,countPreSec:0.0
[Kafka]
[COORDINATOR_QUEUE]
waitRecords:16332.0,readyBatch:853.0,totalRecordsInQueue:22277.0,sourceRecordAccumulate:367.0
sourceBlock:false,sinkBlock:true
[RPS]
Rps[last:597.0,avg:518.0]
Iops[last:2.32M,avg:2.01M]
RPS_TREND[423->410->435->570->602->592->597]
[SinkMetrics]
execute/Record:15.0ms,commit/Batch:3.0ms,sinkBatchSizeAvg:43.17
execute(p99)/Record:20.0ms,commit(p99)/Batch:4.0ms
lastSinkThread:8/8
shardTime:0.0ms
[store]
MYSQL_np_7p3n9ey197og_7p3n9z4i8528-1-0:rps:147.719,iops:0.362M,delay:0.435s,connNum:1
[Scene] JdbcWriteSlowScene
prev:sink.workerNum=8
post:sink.workerNum=64
affect:增加目的端线程数，提高并发效率，但是需要注意 4C 以下的机器不推荐该修改
comment:目的端线程数
我先设置了一个按8算的，4~8G