Skip to content

Commit

Permalink
Merge pull request debezium#27 in N4FRA/debezium from DSCON-117_DBCon…
Browse files Browse the repository at this point in the history 
…nector_exception to master

Squashed commit of the following:

commit 6ec5d5e0ea10fd26c6116d74baff67389b522794
Author: AndreyIg <gnyiny@gmail.com>
Date:   Fri Feb 14 16:06:20 2020 -0800

    ARGO-219310, address oldest scn = -1

commit cc71c7e524ba97d74e329725f81c4ac654bfabab
Merge: 1eb6ce1b 081731f
Author: AndreyIg <gnyiny@gmail.com>
Date:   Fri Feb 14 16:02:40 2020 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium into DSCON-117_DBConnector_exception

commit 1eb6ce1bb2b8e13aac93891c3dfe25fe7ed58985
Merge: da3066c2 8f53bba
Author: AndreyIg <gnyiny@gmail.com>
Date:   Mon Feb 3 16:11:32 2020 -0800

    fix DSCON-117 DBConnector exception

commit da3066c2b23bcbce4f5043b5a161657cd6483633
Author: AndreyIg <gnyiny@gmail.com>
Date:   Mon Feb 3 16:06:47 2020 -0800

    DSCON-117, DBConnector exception while incremental loading1

commit 2cb8126b258cae75547dd2fc9b45177533169fa9
Author: AndreyIg <gnyiny@gmail.com>
Date:   Mon Feb 3 13:45:38 2020 -0800

    fix smallest scn calculation

commit 4bf0b69
Merge: 8023485 605d22f
Author: AndreyIg <gnyiny@gmail.com>
Date:   Fri Jan 24 07:37:32 2020 -0800

    Merge branch 'master' into DBZ-137_candidate_merge_branch

commit 605d22f
Merge: 276c19b e68ada6
Author: AndreyIg <gnyiny@gmail.com>
Date:   Fri Jan 24 07:32:11 2020 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit 276c19b
Merge: 9b5a3f3 bc8e4be
Author: AndreyIg <gnyiny@gmail.com>
Date:   Mon Jan 20 14:32:44 2020 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit 8023485
Author: AndreyIg <gnyiny@gmail.com>
Date:   Mon Jan 20 14:24:12 2020 -0800

    fix setting supplemental logging for new table

commit f16f3a5
Merge: 91b00f8 9b5a3f3
Author: AndreyIg <gnyiny@gmail.com>
Date:   Wed Jan 15 13:44:36 2020 -0800

    Merge branch 'master' into DBZ-137_candidate_merge_branch

commit 9b5a3f3
Merge: 9b0ee98 f9de59c
Author: AndreyIg <gnyiny@gmail.com>
Date:   Wed Jan 15 13:41:38 2020 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit 91b00f8
Author: AndreyIg <gnyiny@gmail.com>
Date:   Mon Jan 6 16:09:22 2020 -0800

    DBZ-137_fix_oldest_scn_issue

commit 9b0ee98
Merge: 7ab9af3 0fe3cf3
Author: AndreyIg <gnyiny@gmail.com>
Date:   Fri Dec 27 11:55:19 2019 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit 7ab9af3
Merge: 90979c1 d8872ce
Author: AndreyIg <gnyiny@gmail.com>
Date:   Fri Dec 27 11:48:18 2019 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit 90979c1
Merge: d174eab 4086b3e
Author: AndreyIg <gnyiny@gmail.com>
Date:   Fri Dec 13 13:39:26 2019 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit d174eab
Merge: 0894de1 7e77a83
Author: AndreyIg <gnyiny@gmail.com>
Date:   Mon Dec 9 08:58:41 2019 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit 0894de1
Merge: 8353b85 12021bd
Author: AndreyIg <gnyiny@gmail.com>
Date:   Wed Nov 27 15:12:39 2019 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit 8353b85
Merge: c6f361f b69f88c
Author: AndreyIg <gnyiny@gmail.com>
Date:   Wed Nov 27 14:57:47 2019 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit c6f361f
Merge: 7b499a3 7c9497a
Author: AndreyIg <gnyiny@gmail.com>
Date:   Tue Nov 26 15:27:32 2019 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

commit 7b499a3
Merge: ff19baa 5be9ef5
Author: AndreyIg <gnyiny@gmail.com>
Date:   Fri Nov 22 14:09:47 2019 -0800

    Merge branch 'master' of http://git.navis.lan/scm/n4fra/debezium

... and 6 more commits
  • Loading branch information
Ignatenko Andrey committed Feb 15, 2020
1 parent 081731f commit 27eb9af
Showing 1 changed file with 9 additions and 5 deletions.
14 changes: 9 additions & 5 deletions ...c/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLRecoverableException;
import java.time.Duration;
import java.time.Instant;
import java.util.Map;
Expand Down Expand Up @@ -188,10 +189,10 @@ public void execute(ChangeEventSourceContext context) throws InterruptedExceptio
}
} catch (Throwable e) {
if (connectionProblem(e)) {
LOGGER.warn("Disconnection occurred. {} ", e);
LOGGER.warn("Disconnection occurred. {} ", e.toString());
continue;
}
LOGGER.error("Mining session was stopped due to the {} ", e);
LOGGER.error("Mining session was stopped due to the {} ", e.toString());
throw new RuntimeException(e);
} finally {
LOGGER.info("lastProcessedScn={}, nextScn={}, offsetContext.getScn()={}", lastProcessedScn, nextScn, offsetContext.getScn());
Expand All @@ -211,10 +212,13 @@ private boolean connectionProblem (Throwable e){
if (e.getMessage() == null || e.getCause() == null) {
return false;
}
return e.getMessage().startsWith("ORA-03135") ||
e.getMessage().startsWith("ORA-12543") ||
return e.getMessage().startsWith("ORA-03135") || // connection lost contact
e.getMessage().startsWith("ORA-12543") || // TNS:destination host unreachable
e.getMessage().startsWith("ORA-00604") || // error occurred at recursive SQL level 1
e.getMessage().startsWith("ORA-01089") || // Oracle immediate shutdown in progress
e.getCause() instanceof IOException ||
e instanceof SQLRecoverableException ||
e.getMessage().toUpperCase().startsWith("NO MORE DATA TO READ FROM SOCKET") ||
e.getCause().getCause() instanceof NetException;

}
}

0 comments on commit 27eb9af

Please sign in to comment.