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

DBZ-8187 Don't close transformations in EmbeddedEngine

Browse Source 
`EmbeddedEngine` can be stopped and started again. Closing the
transfomation chain may cause the issue when engine is started again
and already closed transformations are applied to stream of data.

Restore original behavior of `EmbeddedEngine` and don't close the
transformation chain in this engine.
This commit is contained in:
Vojtech Juranek 2024-08-30 10:56:26 +02:00 committed by Jiri Pechanec
parent e0e6664a15
commit 4b5cf5e56c
1 changed files with 0 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java
View File

@ -483,15 +483,6 @@ public void run() {
finally { finally {
// Close the offset storage and finally the connector ... // Close the offset storage and finally the connector ...
stopOffsetStoreAndConnector(connector, connectorClassName, offsetStore, connectorCallback); stopOffsetStoreAndConnector(connector, connectorClassName, offsetStore, connectorCallback);
// Close the transformation chain.
if (transformations != null) {
try {
transformations.close();
}
catch (IOException e) {
fail("Failed to close transformations: ", e);
}
}
} }
} }
catch (EmbeddedEngineRuntimeException e) { catch (EmbeddedEngineRuntimeException e) {