问题一:您好,flink cdc请教一个问题,同步oracle的数据报错,使用配置如下:?
您好,请教一个问题,同步oracle的数据报错,使用配置如下:
cdc版本:flink-sql-connector-oracle-cdc-2.3-SNAPSHOT.jar:2.3-SNAPSHOT
驱动版本:ojdbc8-23.2.0.0.jar
Oracle 版本: Oracle Database 11g Enterprise Edition Release 11.2.0.4.0 - 64bit Production
flink sql:
CREATE TABLE IF NOT EXISTS oracle_table (
STORE_ID BIGINT,
STORE_CODE STRING,
STORE_NAME STRING,
STORE_STATUS INT,
PRIMARY KEY (STORE_ID) NOT ENFORCED
) WITH (
'connector' = 'oracle-cdc',
'hostname' = '192.168.252.107',
'port' = '1521',
'username' = 'conn_uat',
'password' = 'xxxx',
'database-name' = 'CONN_UAT',
'schema-name' = 'strc',
'table-name' = 'CHL_STORE_T'
);
报错:
Caused by: oracle.net.ns.NetException: Listener refused the connection with the following error:
ORA-12514, TNS:listener does not currently know of service requested in connect descriptor
已做验证:
本地连接oracle数据库没有问题
1、通过程序连接(驱动版本ojdbc8-23.2.0.0.jar)没问题;
2、使用data grip也可以正常连接(Driver: Oracle JDBC driver (ver. 21.5.0.0.0, JDBC4.3)):
参考回答:
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572300
问题二:我直接用Flink CDC代码消费kafka数据没问题,大家有遇到过这种问题不?
我直接用Flink CDC代码消费kafka数据没问题,
但是用flinksql消费kafka数报警告,大家有遇到过这种问题不?
2023-11-17 09:45:39 WARN (org.apache.kafka.clients.consumer.ConsumerConfig:logUnused) - The configuration 'partition.discovery.interval.ms' was supplied but isn't a known config.
参考回答:
这个是ddl写错了吧,connecter信息,只要格式没错,就不会报语法错误的,你看看kafka的conf是不是前面要加一个 properties.
properties.partition.discovery.interval.ms这样试试
scan.topic-partition-discovery.interval
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572299
问题三:Flink CDC这个是啥问题呀?
Flink CDC这个是啥问题呀?
参考回答:
错误消息 "ORA-65040: operation not allowed from within a pluggable database" 表明您正在尝试在一个可插拔数据库 (Pluggable Database) 中执行不允许的操作。这是因为在 Oracle 数据库中,只有 root 容器才能执行某些特定的操作。
要解决此问题,请尝试以下两种方法之一:
- 更改为根容器:使用 SQL 命令来切换到根容器并重新执行操作。例如,可以使用
ALTER SESSION SET CONTAINER = cdb$root
命令进入根容器。 - 修改操作:如果可能,请修改操作以使之能够在可插拔数据库中执行。例如,如果是查询语句,则可以尝试使用视图或者函数等其他方式来规避限制。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572297
问题四:Flink CDC sqlserver的cdc报这个,用的2.4版本cdc?
Flink CDC sqlserver的cdc报这个,用的2.4版本cdc
参考回答:
在 Flink CDC SQLServer 的日志中,出现了一个错误,提示"Please check database history topic configuration and re-execute the script"。这可能意味着 Flink CDC SQLServer 的数据库历史主题配置存在问题,需要重新执行数据库脚本。
在 Flink CDC SQLServer 的配置文件中,通常会包含一个 SQLServerSourceTabletConfig 类的实例,用于配置源表连接、源表模式、源表代理模式等信息。在 Flink CDC SQLServer 的源代码中,可以查看 SQLServerSourceTabletConfig 类的源代码,以了解该类的详细配置信息。
在 Flink CDC SQLServer 的源代码中,可以查看 SQLServerSourceTabletConfig 类的源代码,以了解该类的详细配置信息。例如,在 Flink CDC SQLServer 的源代码中,可以查看 SQLServerSourceTabletConfig 类的构造函数,以了解该类的配置参数。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572294
问题五:Flink CDC还是报这个错误,参数我都看了,都是默认值28800s?
Flink CDC还是报这个错误,wait_timeout和interactive_timeout参数我都看了,都是默认值28800s?
参考回答:
你就是错误就是wait_timeout或者interactive_timeout引起的,另外不可能默认这么大28800s,我们这边最多我见过的2s
你这个错误就是时间超过了wait_timeout
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572293