【 使用环境 】flink cdc 3.0.1 从 oceanbase 4.3.1 oracle
ObOracleMessageDeserializationSchema obMysqlMessageDesc = new ObOracleMessageDeserializationSchema(jdbcConf,StartupOptions.initial());
OceanBaseSource.Builder<String> obBuilder = OceanBaseSource.<String>builder()
.rsList("192.168.1.2:2882:2881")
.startupOptions(StartupOptions.latest())
.username("TEST_ORACLE@ob_oracle")
.password("Test123")
.tenantName("ob_oracle")
.tableList("TEST_ORACLE.T1")
.databaseName("TEST_ORACLE")
.tableName("T1")
.hostname("192.168.1.2")
.port(2881)
.compatibleMode("oracle")
.jdbcDriver("com.oceanbase.jdbc.Driver")
.logProxyHost("192.168.1.2")
.logProxyPort(2983)
.connectTimeout(Duration.ofSeconds(30000))
.serverTimeZone(serverTimeZone)
.configUrl("http://192.168.1.2:8080/services?Action=ObRootServiceInfo&User_ID=alibaba&UID=ocpmaster&ObRegion=test_2")
.workingMode("memory")
.deserializer(obMysqlMessageDesc);
SourceFunction<String> obOracleSource = obBuilder.build();
StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();
env.setParallelism(1);
env.addSource(obOracleSource).print(">->");
env.disableOperatorChaining();
env.setRestartStrategy(RestartStrategies.noRestart());
env.execute("ob-oracle-job-demo");
【 使用版本 】
com.oceanbase
oceanbase-client
2.4.8
org.apache.flink
flink-connector-oceanbase-cdc
3.1.0
org.apache.flink
flink-shaded-guava
【问题描述从 oceanbase 4.3.1 oracle 租户 增量读取数据报错502 ，e sys_user 字段不能为空
【复现路径】问题出现前后相关操作
【附件及日志】