diff --git a/src/frontend/org/voltdb/iv2/JoinProducer.java b/src/frontend/org/voltdb/iv2/JoinProducer.java
index <HASH>..<HASH> 100644
--- a/src/frontend/org/voltdb/iv2/JoinProducer.java
+++ b/src/frontend/org/voltdb/iv2/JoinProducer.java
@@ -103,6 +103,7 @@ public class JoinProducer extends JoinProducerBase implements TaskLog {
     @Override
     public TaskLog constructTaskLog(String voltroot)
     {
+        m_taskLog = initializeTaskLog(voltroot, m_partitionId);
         return this;
     }
 
@@ -157,30 +158,31 @@ public class JoinProducer extends JoinProducerBase implements TaskLog {
                 JOINLOG.trace("P" + m_partitionId + " received first fragment");
             }
             m_receivedFirstFragment = true;
+            m_taskLog.logTask(message);
         }
     }
 
     @Override
     public TransactionInfoBaseMessage getNextMessage() throws IOException
     {
-        return null;
+        return m_taskLog.getNextMessage();
     }
 
     @Override
     public void setEarliestTxnId(long txnId)
     {
-
+        m_taskLog.setEarliestTxnId(txnId);
     }
 
     @Override
     public boolean isEmpty() throws IOException
     {
-        return true;
+        return m_taskLog.isEmpty();
     }
 
     @Override
     public void close() throws IOException
     {
-
+        m_taskLog.close();
     }
 }
ENG-<I>: Add task log to the JoinProducer.