Fixed issue #39

orientechnologies · Jan 2, 2015 · ab60e0d · ab60e0d
1 parent 0fe8388
commit ab60e0d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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;
   }
 }