【 使用环境 】 测试环境
【 OB or 其他组件 】OB 社区4.0版本,oblogproxy 1.1.1版本
【 使用版本 】OB 社区4.0版本
【问题描述】
·1.docker部署社区4.0版本,并且在宿主机部署了oblogproxy 1.1.1版本。启动都是正常的。
2.使用test租户连接oblogproxy ,具体代码如下
public static void main(String[] args) {
ObReaderConfig config = new ObReaderConfig();
// 设置OceanBase root server 地址列表,格式为(可以支持多个,用';'分隔):ip1:rpc_port1:sql_port1;ip2:rpc_port2:sql_port2
config.setRsList("10.168.1.71:2882:2881");
// 设置用户名和密码(非系统租户)
config.setUsername("rc@test");
config.setPassword("passw");
config.setSysUsername("oblogproxy@sys");
config.setSysPassword("passw");
// 设置启动位点(UNIX时间戳,单位s), 0表示从当前时间启动。
config.setStartTimestamp(0L);
// 设置订阅表白名单,格式为:tenant.db.table, '*'表示通配.
// config.setTableWhiteList("sys.test.orders");
config.setTableWhiteList("test.*.*");
// config.setTableWhiteList("sys.test.orders");
// 指定oblogproxy服务地址,创建实例.
LogProxyClient client = new LogProxyClient("10.168.1.71", 2983, config);
// 添加 RecordListener
client.addListener(new RecordListener() {
@Override
public void notify(LogMessage message) {
// 处理消息
System.out.println(message);
}
@Override
public void onException(LogProxyClientException e) {
// 处理错误
if (e.needStop()) {
// 不可恢复异常,需要停止Client
client.stop();
}
}
});
// 启动
client.start();
client.join();
}
idea连接报错截图
oblogproxy 的 run里启动的报错信息 ERROR文件
【复现路径】
【问题现象及影响】
这个 __all_virtual_server_clog_stat 表我看了确实是不存在的
【附件】