From 44b79439c261b254b866d9a1ff61840fadca8964 Mon Sep 17 00:00:00 2001
From: Anton Panasenko <apanasenko@twitter.com>
Date: Wed, 28 Nov 2018 11:34:02 -0800
Subject: [PATCH] Prepare sourceCall by scheme on each switch of inputIterator
 in TupleEntrySchemeIterator

---
 .../src/main/java/cascading/tuple/TupleEntrySchemeIterator.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/cascading-core/src/main/java/cascading/tuple/TupleEntrySchemeIterator.java b/cascading-core/src/main/java/cascading/tuple/TupleEntrySchemeIterator.java
index 3149b02e59..a7f5cecad2 100644
--- a/cascading-core/src/main/java/cascading/tuple/TupleEntrySchemeIterator.java
+++ b/cascading-core/src/main/java/cascading/tuple/TupleEntrySchemeIterator.java
@@ -165,6 +165,7 @@ private TupleEntry getNext() throws IOException
     if( !hasWaiting && inputIterator.hasNext() )
       {
       sourceCall.setInput( wrapInput( inputIterator.next() ) );
+      scheme.sourcePrepare( flowProcess, sourceCall );
 
       return getNext();
       }