我需要通过获取全量数据以及增量数据
logproxyclient 只能获取增量数据
LogProxyClientTest 方法运行重复报日志
17:07:40.911 [Thread-0] INFO com.oceanbase.clogproxy.client.connection.ClientStream - Try to reconnect
17:07:40.913 [Thread-0] INFO com.oceanbase.clogproxy.client.connection.ClientStream - Reconnect successfully
17:07:40.913 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - ClientId: test: rootserver_list=192.168.85.160:2882:2881, cluster_id=, cluster_user=root@sys, cluster_password=, , sys_user=, sys_password=, tb_white_list=sys.test.t1, tb_black_list=|, start_timestamp=0, start_timestamp_us=0, timezone=+08:00, working_mode=memory connecting LogProxy: 192.168.85.160:2983
17:07:41.000 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Connected to LogProxyServer, ip:172.17.0.1, version:4e2bd4f05b7a6b1c2fc3cd7172e548bb86f6d4b2
17:07:42.002 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Channel closed with ClientId: test, LogProxy: 192.168.85.160:2983
17:07:42.913 [Thread-0] INFO com.oceanbase.clogproxy.client.connection.ClientStream - Try to reconnect
17:07:42.915 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - ClientId: test: rootserver_list=192.168.85.160:2882:2881, cluster_id=, cluster_user=root@sys, cluster_password=, , sys_user=, sys_password=, tb_white_list=sys.test.t1, tb_black_list=|, start_timestamp=0, start_timestamp_us=0, timezone=+08:00, working_mode=memory connecting LogProxy: 192.168.85.160:2983
17:07:42.915 [Thread-0] INFO com.oceanbase.clogproxy.client.connection.ClientStream - Reconnect successfully
17:07:43.002 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Connected to LogProxyServer, ip:172.17.0.1, version:4e2bd4f05b7a6b1c2fc3cd7172e548bb86f6d4b2
17:07:43.771 [log-proxy-client-worker-1-thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Channel closed with ClientId: test, LogProxy: 192.168.85.160:2983
17:07:44.673 [Thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientStream - Try to stop this client
17:07:44.916 [Thread-0] INFO com.oceanbase.clogproxy.client.connection.ClientStream - Client process thread exit
17:07:44.917 [Thread-1] INFO com.oceanbase.clogproxy.client.connection.ClientStream - Client stopped successfully
oblogproxy 也重复报日志
W20230530 16:26:27.058614 119940 communicator.cpp:499] <<< Fork after, unlock
E20230530 16:26:29.167836 17111 communicator.cpp:312] No such channel. fd=10
W20230530 16:26:29.167860 17111 arranger.cpp:183] Failed to send error response message. client=10
W20230530 16:26:29.167879 17111 communicator.cpp:267] No channel found of peer: file_desc:10,
W20230530 16:26:29.167887 17111 source_invoke.cpp:158] — SourceWaiter remove oblogreader for pid: 17110
W20230530 16:26:29.167892 17111 source_invoke.cpp:181] — oblogreader WaiterThread(120142) exit for pid: 17110
W20230530 16:26:31.085978 119940 communicator.cpp:492] >>> Fork preparing, fetching lock…
W20230530 16:26:31.085991 119940 communicator.cpp:494] — Fork prepared, fetched lock
W20230530 16:26:31.088589 119940 communicator.cpp:499] <<< Fork after, unlock
E20230530 16:26:31.987104 17327 communicator.cpp:312] No such channel. fd=10
W20230530 16:26:31.987179 17327 arranger.cpp:183] Failed to send error response message. client=10
W20230530 16:26:31.987216 17327 communicator.cpp:267] No channel found of peer: file_desc:10,
W20230530 16:26:31.987231 17327 source_invoke.cpp:158] — SourceWaiter remove oblogreader for pid: 17326
W20230530 16:26:31.987238 17327 source_invoke.cpp:181] — oblogreader WaiterThread(120144) exit for pid: 17326
W20230530 16:26:33.054000 119940 communicator.cpp:492] >>> Fork preparing, fetching lock…
W20230530 16:26:33.054010 119940 communicator.cpp:494] — Fork prepared, fetched lock
W20230530 16:26:33.056990 119940 communicator.cpp:499] <<< Fork after, unlock
E20230530 16:26:34.133023 17465 communicator.cpp:312] No such channel. fd=10
W20230530 16:26:34.133075 17465 arranger.cpp:183] Failed to send error response message. client=10
W20230530 16:26:34.133100 17465 communicator.cpp:267] No channel found of peer: file_desc:10,
W20230530 16:26:34.133111 17465 source_invoke.cpp:158] — SourceWaiter remove oblogreader for pid: 17464
W20230530 16:26:34.133116 17465 source_invoke.cpp:181] — oblogreader WaiterThread(120146) exit for pid: 17464
W20230530 16:26:35.089646 119940 communicator.cpp:492] >>> Fork preparing, fetching lock…
W20230530 16:26:35.089664 119940 communicator.cpp:494] — Fork prepared, fetched lock
W20230530 16:26:35.093477 119940 communicator.cpp:499] <<< Fork after, unlock
不知道还缺什么数据。增量数据也没有获取到