[
https://issues.apache.org/jira/browse/TEZ-3616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fei Hui updated TEZ-3616:
-------------------------
Attachment: TEZ-3616.002.patch
[~aplusplus] Thanks your suggestions. [~Sonia] Thanks your testing
Deep into the code, I find the following code does not work because we do not
mock the MergeManager of merge thread. So that "Simulate artificial delay" does
not work.
{code}
doAnswer(new Answer() {
@Override public Object answer(InvocationOnMock invocationOnMock)
throws Throwable {
//Simulate artificial delay so that interrupting thread can get a
chance
Thread.sleep(2000);
return invocationOnMock.callRealMethod();
}
{code}
Update the patch,.
Tests pass continuously with 20 more times. And "Simulate artificial delay"
works
> TestMergeManager#testLocalDiskMergeMultipleTasks fails intermittently
> ----------------------------------------------------------------------
>
> Key: TEZ-3616
> URL: https://issues.apache.org/jira/browse/TEZ-3616
> Project: Apache Tez
> Issue Type: Bug
> Affects Versions: 0.9.0
> Environment: Ubuntu 14.04
> Reporter: Sonia Garudi
> Assignee: Fei Hui
> Labels: ppc64le, x86
> Attachments: TEZ-3616.001.patch, TEZ-3616.002.patch
>
>
> In tez-runtime-library project, the
> TestMergeManager#testLocalDiskMergeMultipleTasks test fails intermittently
> with the following error:
> testLocalDiskMergeMultipleTasks(org.apache.tez.runtime.library.common.shuffle.orderedgrouped.TestMergeManager)
> Time elapsed: 1.395 sec <<< FAILURE!
> java.lang.AssertionError: Values should be different. Actual: 1
> at org.junit.Assert.fail(Assert.java:88)
> at org.junit.Assert.failEquals(Assert.java:185)
> at org.junit.Assert.assertNotEquals(Assert.java:161)
> at org.junit.Assert.assertNotEquals(Assert.java:198)
> at org.junit.Assert.assertNotEquals(Assert.java:209)
> at
> org.apache.tez.runtime.library.common.shuffle.orderedgrouped.TestMergeManager.testLocalDiskMergeMultipleTasks(TestMergeManager.java:878)
> at
> org.apache.tez.runtime.library.common.shuffle.orderedgrouped.TestMergeManager.testLocalDiskMergeMultipleTasks(TestMergeManager.java:628)
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)