You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hive.apache.org by gu...@apache.org on 2014/06/19 01:20:06 UTC

svn commit: r1603665 - /hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezTask.java

Author: gunther
Date: Wed Jun 18 23:20:06 2014
New Revision: 1603665

URL: http://svn.apache.org/r1603665
Log:
HIVE-7252: TestTezTask.testSubmit fails in trunk (Gunther Hagleitner, reviewed by Ashutosh)

Modified:
    hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezTask.java

Modified: hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezTask.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezTask.java?rev=1603665&r1=1603664&r2=1603665&view=diff
==============================================================================
--- hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezTask.java (original)
+++ hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezTask.java Wed Jun 18 23:20:06 2014
@@ -159,7 +159,8 @@ public class TestTezTask {
     session = mock(TezSession.class);
     sessionState = mock(TezSessionState.class);
     when(sessionState.getSession()).thenReturn(session);
-    when(session.submitDAG(any(DAG.class))).thenThrow(new SessionNotRunning(""))
+    when(session.submitDAG(any(DAG.class), any(Map.class)))
+      .thenThrow(new SessionNotRunning(""))
       .thenReturn(mock(DAGClient.class));
   }
 
@@ -205,7 +206,7 @@ public class TestTezTask {
     // validate close/reopen
     verify(sessionState, times(1)).open(any(HiveConf.class));
     verify(sessionState, times(1)).close(eq(false));  // now uses pool after HIVE-7043
-    verify(session, times(2)).submitDAG(any(DAG.class));
+    verify(session, times(2)).submitDAG(any(DAG.class), any(Map.class));
   }
 
   @Test