Jira: https://issues.apache.org/jira/browse/TEZ-3733
Build: https://builds.apache.org/job/PreCommit-TEZ-Build/2461/
###################################################################################
########################## LAST 60 LINES OF THE CONSOLE
###########################
[...truncated 351.64 KB...]
[ERROR] After correcting the problems, you can resume the build with the command
[ERROR] mvn <goals> -rf :tez-runtime-library
[INFO] Build failures were ignored.
{color:red}-1 overall{color}. Here are the results of testing the latest
attachment
http://issues.apache.org/jira/secure/attachment/12868606/TEZ-3733.1.patch
against master revision e3ee7a6.
{color:green}+1 @author{color}. The patch does not contain any @author
tags.
{color:red}-1 tests included{color}. The patch doesn't appear to include
any new or modified tests.
Please justify why no new tests are needed for this
patch.
Also please list what manual steps were performed to
verify this patch.
{color:green}+1 javac{color}. The applied patch does not increase the
total number of javac compiler warnings.
{color:green}+1 javadoc{color}. There were no new javadoc warning messages.
{color:green}+1 findbugs{color}. The patch does not introduce any new
Findbugs (version 3.0.1) warnings.
{color:green}+1 release audit{color}. The applied patch does not increase
the total number of release audit warnings.
{color:red}-1 core tests{color}. The patch failed these unit tests in :
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase
Test results:
https://builds.apache.org/job/PreCommit-TEZ-Build/2461//testReport/
Console output: https://builds.apache.org/job/PreCommit-TEZ-Build/2461//console
This message is automatically generated.
======================================================================
======================================================================
Adding comment to Jira.
======================================================================
======================================================================
Comment added.
6b28c2a1d39fd57c83f3695b0cb2610499f5873f logged out
======================================================================
======================================================================
Finished build.
======================================================================
======================================================================
Build step 'Execute shell' marked build as failure
Archiving artifacts
Compressed 3.46 MB of artifacts by 10.8% relative to #2459
[description-setter] Could not determine description.
Recording test results
Email was triggered for: Failure - Any
Sending email for trigger: Failure - Any
###################################################################################
############################## FAILED TESTS (if any)
##############################
4 tests failed.
FAILED:
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testAutoParallelism[test[class
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager]]
Error Message:
Wanted but not invoked:
vertexManagerPluginContext.reconfigureVertex(
<any>,
<any>,
<any>
);
-> at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testAutoParallelism(TestShuffleVertexManagerBase.java:420)
However, there were other interactions with this mock:
vertexManagerPluginContext.getUserPayload();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.initialize(ShuffleVertexManagerBase.java:752)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.vertexReconfigurationPlanned();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.initialize(ShuffleVertexManagerBase.java:759)
vertexManagerPluginContext.getInputVertexEdgeProperties();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:219)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex1",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex2",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex3",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:246)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex1"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex2"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex3"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager.computeRouting(ShuffleVertexManager.java:490)
vertexManagerPluginContext.doneReconfiguringVertex();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.determineParallelismAndApply(ShuffleVertexManagerBase.java:508)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.getNumOfTasksToScheduleAndLog(ShuffleVertexManagerBase.java:589)
vertexManagerPluginContext.scheduleTasks(
[org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@6158aa89,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@4243a4d,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@666f975a,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@2839ca40]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.schedulePendingTasks(ShuffleVertexManagerBase.java:540)
Stack Trace:
org.mockito.exceptions.verification.WantedButNotInvoked:
Wanted but not invoked:
vertexManagerPluginContext.reconfigureVertex(
<any>,
<any>,
<any>
);
-> at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testAutoParallelism(TestShuffleVertexManagerBase.java:420)
However, there were other interactions with this mock:
vertexManagerPluginContext.getUserPayload();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.initialize(ShuffleVertexManagerBase.java:752)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.vertexReconfigurationPlanned();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.initialize(ShuffleVertexManagerBase.java:759)
vertexManagerPluginContext.getInputVertexEdgeProperties();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:219)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex1",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex2",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex3",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:246)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex1"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex2"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex3"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager.computeRouting(ShuffleVertexManager.java:490)
vertexManagerPluginContext.doneReconfiguringVertex();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.determineParallelismAndApply(ShuffleVertexManagerBase.java:508)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.getNumOfTasksToScheduleAndLog(ShuffleVertexManagerBase.java:589)
vertexManagerPluginContext.scheduleTasks(
[org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@6158aa89,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@4243a4d,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@666f975a,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@2839ca40]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.schedulePendingTasks(ShuffleVertexManagerBase.java:540)
at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testAutoParallelism(TestShuffleVertexManagerBase.java:420)
FAILED:
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testTez978[test[class
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManager]]
Error Message:
vertexManagerPluginContext.reconfigureVertex(
2,
<any>,
<any>
);
Wanted 2 times:
-> at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testTez978(TestShuffleVertexManagerBase.java:367)
But was 1 time:
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.reconfigVertex(ShuffleVertexManagerBase.java:828)
Stack Trace:
org.mockito.exceptions.verification.TooLittleActualInvocations:
vertexManagerPluginContext.reconfigureVertex(
2,
<any>,
<any>
);
Wanted 2 times:
-> at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testTez978(TestShuffleVertexManagerBase.java:367)
But was 1 time:
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.reconfigVertex(ShuffleVertexManagerBase.java:828)
at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testTez978(TestShuffleVertexManagerBase.java:367)
FAILED:
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testAutoParallelism[test[class
org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager]]
Error Message:
Wanted but not invoked:
vertexManagerPluginContext.reconfigureVertex(
2,
<any>,
<any>
);
-> at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testAutoParallelism(TestShuffleVertexManagerBase.java:421)
However, there were other interactions with this mock:
vertexManagerPluginContext.getUserPayload();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.initialize(ShuffleVertexManagerBase.java:752)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.vertexReconfigurationPlanned();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.initialize(ShuffleVertexManagerBase.java:759)
vertexManagerPluginContext.getInputVertexEdgeProperties();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:219)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex1",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex2",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex3",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:246)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex1"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex2"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex3"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.reconfigureVertex(
4,
null,
{Vertex2={ CUSTOM : in >> PERSISTED >> out >>
org.apache.tez.dag.library.vertexmanager.FairShuffleEdgeManager }, Vertex1={
CUSTOM : in >> PERSISTED >> out >>
org.apache.tez.dag.library.vertexmanager.FairShuffleEdgeManager }}
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.reconfigVertex(ShuffleVertexManagerBase.java:828)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.doneReconfiguringVertex();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.determineParallelismAndApply(ShuffleVertexManagerBase.java:508)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.getNumOfTasksToScheduleAndLog(ShuffleVertexManagerBase.java:589)
vertexManagerPluginContext.scheduleTasks(
[org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@43bf30e7,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@3d23b070,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@7214a86b,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@2a3d4350]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.schedulePendingTasks(ShuffleVertexManagerBase.java:540)
Stack Trace:
org.mockito.exceptions.verification.WantedButNotInvoked:
Wanted but not invoked:
vertexManagerPluginContext.reconfigureVertex(
2,
<any>,
<any>
);
-> at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testAutoParallelism(TestShuffleVertexManagerBase.java:421)
However, there were other interactions with this mock:
vertexManagerPluginContext.getUserPayload();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.initialize(ShuffleVertexManagerBase.java:752)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.vertexReconfigurationPlanned();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.initialize(ShuffleVertexManagerBase.java:759)
vertexManagerPluginContext.getInputVertexEdgeProperties();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:219)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex1",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex2",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:221)
vertexManagerPluginContext.registerForVertexStateUpdates(
"Vertex3",
[CONFIGURED]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:225)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.onVertexStarted(ShuffleVertexManagerBase.java:246)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex1"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex2"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:766)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:769)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex3"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:775)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.handleVertexStateUpdate(ShuffleVertexManagerBase.java:779)
vertexManagerPluginContext.reconfigureVertex(
4,
null,
{Vertex2={ CUSTOM : in >> PERSISTED >> out >>
org.apache.tez.dag.library.vertexmanager.FairShuffleEdgeManager }, Vertex1={
CUSTOM : in >> PERSISTED >> out >>
org.apache.tez.dag.library.vertexmanager.FairShuffleEdgeManager }}
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.reconfigVertex(ShuffleVertexManagerBase.java:828)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.getVertexNumTasks(
"Vertex4"
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.updatePendingTasks(ShuffleVertexManagerBase.java:389)
vertexManagerPluginContext.doneReconfiguringVertex();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.determineParallelismAndApply(ShuffleVertexManagerBase.java:508)
vertexManagerPluginContext.getVertexName();
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.getNumOfTasksToScheduleAndLog(ShuffleVertexManagerBase.java:589)
vertexManagerPluginContext.scheduleTasks(
[org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@43bf30e7,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@3d23b070,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@7214a86b,
org.apache.tez.dag.api.VertexManagerPluginContext$ScheduleTaskRequest@2a3d4350]
);
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.schedulePendingTasks(ShuffleVertexManagerBase.java:540)
at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testAutoParallelism(TestShuffleVertexManagerBase.java:421)
FAILED:
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testTez978[test[class
org.apache.tez.dag.library.vertexmanager.FairShuffleVertexManager]]
Error Message:
vertexManagerPluginContext.reconfigureVertex(
2,
<any>,
<any>
);
Wanted 2 times:
-> at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testTez978(TestShuffleVertexManagerBase.java:367)
But was 1 time:
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.reconfigVertex(ShuffleVertexManagerBase.java:828)
Stack Trace:
org.mockito.exceptions.verification.TooLittleActualInvocations:
vertexManagerPluginContext.reconfigureVertex(
2,
<any>,
<any>
);
Wanted 2 times:
-> at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testTez978(TestShuffleVertexManagerBase.java:367)
But was 1 time:
-> at
org.apache.tez.dag.library.vertexmanager.ShuffleVertexManagerBase.reconfigVertex(ShuffleVertexManagerBase.java:828)
at
org.apache.tez.dag.library.vertexmanager.TestShuffleVertexManagerBase.testTez978(TestShuffleVertexManagerBase.java:367)
