shameersss1 commented on a change in pull request #60:
URL: https://github.com/apache/tez/pull/60#discussion_r821872406
##########
File path:
tez-plugins/tez-aux-services/src/test/java/org/apache/tez/auxservices/TestShuffleHandler.java
##########
@@ -1312,6 +1313,86 @@ protected void sendError(ChannelHandlerContext ctx,
String message,
}
}
+ @Test
+ public void testVertexDelete() throws Exception {
+ final ArrayList<Throwable> failures = new ArrayList<Throwable>(1);
+ Configuration conf = new Configuration();
+ conf.setInt(ShuffleHandler.MAX_SHUFFLE_CONNECTIONS, 3);
+ conf.setInt(ShuffleHandler.SHUFFLE_PORT_CONFIG_KEY, 0);
+ conf.set(CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHENTICATION,
+ "simple");
+ UserGroupInformation.setConfiguration(conf);
+ File absLogDir = new File("target", TestShuffleHandler.class.
+ getSimpleName() + "LocDir").getAbsoluteFile();
+ conf.set(YarnConfiguration.NM_LOCAL_DIRS, absLogDir.getAbsolutePath());
+ ApplicationId appId = ApplicationId.newInstance(12345L, 1);
+ String appAttemptId = "attempt_12345_0001_1_00_000000_0_10003_0";
+ String user = "randomUser";
+ List<File> fileMap = new ArrayList<File>();
+ String vertexDirStr =
+ StringUtils.join(Path.SEPARATOR,
+ new String[] { absLogDir.getAbsolutePath(),
+ ShuffleHandler.USERCACHE, user,
+ ShuffleHandler.APPCACHE, appId.toString(),
"dag_1/output/" + appAttemptId});
+ File vertexDir = new File(vertexDirStr);
+ Assert.assertFalse("Vetex Directory should not exists",
vertexDir.exists());
Review comment:
ack. I will fix this in next revision.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@tez.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
