alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-720 Avoiding race condition where we tried to commit an offset to an already closed xout server

Browse Source
This commit is contained in:
Gunnar Morling 2018-07-13 12:38:52 +02:00 committed by Jiri Pechanec
parent 70d91e1ba5
commit 8ad452d60f
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleStreamingChangeEventSource.java
View File

@ -71,8 +71,10 @@ public void execute(ChangeEventSourceContext context) throws InterruptedExceptio
}
finally {
// 3. disconnect
if (xsOut != null) {
if (this.xsOut != null) {
try {
XStreamOut xsOut = this.xsOut;
this.xsOut = null;
xsOut.detach(XStreamOut.DEFAULT_MODE);
}
catch (StreamsException e) {