flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

flink-sql-connector-oracle-cdc-2.2.0 report ORA-01292

Open xiemingjin opened this issue 2 years ago • 8 comments

Describe the bug(Please use English) The following error occurs when restarting the Flink cluster

Caused by: java.sql.SQLException: ORA-01292: no log file has been specified for the current LogMiner session

Environment :

  • Flink version : flink-1.13.6
  • Flink CDC version: 2.2.0
  • Database and version: oracle11g

To Reproduce Steps to reproduce the behavior: 1、Oracle archive logs are deleted every 4 hours 2、Checkpoint every 10 minutes 3、The database table has not been operated on for more than 8 hours 4、restarting the Flink cluster 5、The error : Caused by: java.sql.SQLException: ORA-01292: no log file has been specified for the current LogMiner session Additional Description

xiemingjin avatar Apr 01 '22 02:04 xiemingjin

The bug also occured when Oracle user is runing backup command with RMAN tool. Connector configed as following parameters: 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true',

jtsunxp avatar Apr 05 '22 15:04 jtsunxp

@luoyuxia Could you take a look on this issue? Thanks

PatrickRen avatar Apr 19 '22 08:04 PatrickRen

i have the same questions,and the code running after many days occured this question,and the code has already add 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true',

cocojiejie avatar Jul 26 '22 07:07 cocojiejie

6147

t java. lang. Thread . run( Thread. java: 748) ~l ! :1.8.0_ _191]

6148 Caused by: java. sql. SQLException: ORA-01292: no log file has been specified for the current LogMiner session

6149

ORA-06512: at "SYS .DBMS_ _LOGMNR", line 5;

6150

ORA-06512: at line 1

6151

6152

at oracle. jdbc. driver . T4CTTIoer11. processError(T4CTTIoer11. java:509) ~[flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6153

at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11. java:461) ~[flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6154

at oracle . jdbc . driver . T4C80all. processError(T4C80all. java:1104) ~[flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

e Tct

6155

at oracle. jdbc. driver. T4CTTIfun. receive( T4CTTIfun. java:550) ~[ flink-sql -connector -oracle-cdc-2.2.1.jar:2.2.1]

6156

at oracle. jdbc . driver . T4CTTIfun. doRPC(T4CTTIfun.java:268) ~[flink-sql -connector-oracle-cdc-2.2.1. jar:2.2.1]

6157

at oracle. jdbc . driver. T4C80all. doOALL(T4C80all. java:655) ~[flink-sql -connector-oracle-cdc-2.2.1.jar:2.2.1]

6158

at oracle.jdbc.driver .T4CCallableStatement . do0all8(T4CCallableStatement .java:265) ~[flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6159

at oracle. jdbc. driver. T4CCallableStatement . do0all8(T4CCallableStatement . java:86) ~[ flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6160

at oracle. jdbc. driver . T4CCallableStatement . executeForRows (T4CCallableStatement. java:965) ~[flink-sql -connector-oracle-cdc-2.2.1. jar:2.2.1]

6161

at oracle. jdbc . driver . OracleStatement . doExecuteWithTimeout (OracleStatement. java : 1205) ~[ flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6162

at oracle.jdbc.driver.0raclePreparedStatement. executeInternal(0raclePreparedStatement.java:3666) ~[flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6163

at oracle. jdbc . driver . T4CCallableStatement . executeInternal(T4CCallableStatement . java:1358) ~[flink-sql-connector-oracle-cdlc-2.2.1.jar:2.2.1]

6164

at oracle. jdbc.driver . OraclePreparedStatement . execute (OraclePreparedStatement. java :3778) ~[flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6165

at oracle. jdbc. driver . OracleCallableStatement . execute(OracleCallableStatement . java :4251) ~[ flink-sql- connector-oracle-cdc-2.2.1. jar:2.2.1]

6166

at oracle.jdbc.driver.0raclePr

ementWrapper . execute(OraclePreparedStatementWrapper . java:1081) ~[flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6167

at io. debezium. connector . oracle. logminer . LogMinerHe lper . executeCallableStatement(LogMinerHelper . java:693) ~[flink-sql - connector-oracle-cdc-2.2.1. jar:2.2.1]

6168

at io.debezium. connector . oracle. logminer. LogMinerHe lper. startLogMining( LogMi nerHelper. java:236) ~[flink-sql-connector-oracle-cdc-2.2.1.jar:2.2.1]

6169

at io. debezium. connector . oracle . logminer. LogMinerStreamingChangeEventSource. execute(LogMinerStreamingChangeEventSource. java:177) ~[flink-sql-connector-oracle-cdc-2.2.1. jar:2.2.1]

6170

more

6171 Caused by: oracle . jdbc .OracleDatabaseException: ORA-01292: no log file has been specified for the current LogMiner session

6172 ORA-06512: at "SYS .DBMS_ LOGMNR", line 5

6173 ORA-06512: at line 1

cocojiejie avatar Jul 26 '22 07:07 cocojiejie

i have the same questions,and the code running after many days occured this question,and the code has already add 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true', but my flink version is 1.13.1 and cdc version is 2.1.1

wdzhanghao avatar Aug 10 '22 01:08 wdzhanghao

i have the same questions,and the code running after many days occured this question,and the code has already add 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true', but my flink version is 1.13.0 and cdc version is 2.1.0

1105748319 avatar Aug 10 '22 05:08 1105748319

i have the same questions,and the code running after many days occured this question,and the code has already add 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true', but my flink version is 1.13.6 and cdc version is 2.2.1

wl3207601 avatar Aug 23 '22 08:08 wl3207601

@leonardBang Could you take a look on this issue? Thanks

wl3207601 avatar Aug 23 '22 15:08 wl3207601

i have the same questions,and the code running after many days occured this question,and the code has already add 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true', but my flink version is 1.14.5 and cdc version is 2.2.1

MadaoRyan avatar Sep 26 '22 02:09 MadaoRyan

I have the same questions,and the code running after some days occured this question,and the code has already add 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true', but my flink version is 1.17.1 and cdc version is 2.4.0

yuandajn578 avatar Jul 16 '23 03:07 yuandajn578

i have the same questions 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true',

Oracle archive logs are deleted every 12 hours

ighack avatar Jul 24 '23 01:07 ighack

i meet same error , task do not restart

wsczm avatar Aug 17 '23 06:08 wsczm

@wuchong I hope you can give us some suggestions to solve this problem

wsczm avatar Aug 17 '23 06:08 wsczm

i meet same error

Syonnnnn avatar Aug 18 '23 08:08 Syonnnnn

i meet same error flink version is 1.17.1 and oracle-cdc version is 2.2.1

huanzui avatar Aug 30 '23 02:08 huanzui

It appears that the issue stems from the log file corresponding to the SCN range being cleared. This might be due to data consumption delays or issues causing data consumption to become stuck. Consequently, the error occurred when the log files within that SCN range were subsequently cleared.

hzjhjjyy avatar Aug 30 '23 08:08 hzjhjjyy

i meet same error after the task running a little while

spaceice123 avatar Nov 21 '23 01:11 spaceice123

Closing this issue because it was created before version 2.3.0 (2022-11-10). Please try the latest version of Flink CDC to see if the issue has been resolved. If the issue is still valid, kindly report it on Apache Jira under project Flink with component tag Flink CDC. Thank you!

PatrickRen avatar Feb 28 '24 15:02 PatrickRen