diff --git a/src/main/java/com/orientechnologies/orient/etl/transformer/OBlockTransformer.java b/src/main/java/com/orientechnologies/orient/etl/transformer/OBlockTransformer.java index 6383afdf2e0..61c1ffeaf6b 100644 --- a/src/main/java/com/orientechnologies/orient/etl/transformer/OBlockTransformer.java +++ b/src/main/java/com/orientechnologies/orient/etl/transformer/OBlockTransformer.java @@ -65,6 +65,8 @@ public void setPipeline(OETLPipeline iPipeline) { protected Object executeTransform(final Object input) { context.setVariable("input", input); - return block.execute(); + block.execute(); + + return input; } }