Fix bug in Tap

trinodb · Oct 24, 2012 · c055e38 · c055e38
1 parent 24c970c
commit c055e38
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/presto-main/src/main/java/com/facebook/presto/operator/tap/Tap.java b/presto-main/src/main/java/com/facebook/presto/operator/tap/Tap.java
@@ -95,12 +95,12 @@ public AdvanceResult advanceToPosition(long position)
 
         private void processCurrentValueIfNecessary(AdvanceResult advanceResult)
         {
-            if (tupleStreamPosition == null) {
-                tupleStreamPosition = Cursors.asTupleStreamPosition(getDelegate());
-            }
             switch (advanceResult) {
                 case SUCCESS:
                     if (getDelegate().getPosition() > measuredPosition) {
+                        if (tupleStreamPosition == null) {
+                            tupleStreamPosition = Cursors.asTupleStreamPosition(getDelegate());
+                        }
                         tupleValueSink.process(tupleStreamPosition);
                         measuredPosition = getDelegate().getCurrentValueEndPosition();
                     }