Finalize pipeline even if exception happen
@@ -172,9 +172,12 @@ public class OETLProcessor {
public void execute() {
configure();
begin();
+ try {
runExtractorAndPipeline();
+ } finally {
end();
}
+ }
private void configure() {}
