Skip to content

Commit bcbf519

Browse files
author
Ashutosh Gupta
committed
Addressed comments
1 parent d2316b4 commit bcbf519

File tree

3 files changed

+15
-28
lines changed

3 files changed

+15
-28
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/src/test/java/org/apache/hadoop/yarn/server/timelineservice/reader/TestTimelineReaderWebServicesBasicAcl.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -134,22 +134,22 @@ void testTimelineReaderManagerAclsWhenEnabled()
134134
TimelineReaderWebServices
135135
.checkAccess(manager, adminUgi, entities, userKey, true);
136136
// admin is allowed to view other entities
137-
assertTrue(entities.size() == 10);
137+
assertEquals(10, entities.size());
138138

139139
// incoming ugi is user1Ugi asking for entities
140140
// only user1 entities are allowed to view
141141
entities = createEntities(5, userKey);
142142
TimelineReaderWebServices
143143
.checkAccess(manager, user1Ugi, entities, userKey, true);
144-
assertTrue(entities.size() == 1);
144+
assertEquals(1, entities.size());
145145
assertEquals(user1, entities.iterator().next().getInfo().get(userKey));
146146

147147
// incoming ugi is user2Ugi asking for entities
148148
// only user2 entities are allowed to view
149149
entities = createEntities(8, userKey);
150150
TimelineReaderWebServices
151151
.checkAccess(manager, user2Ugi, entities, userKey, true);
152-
assertTrue(entities.size() == 1);
152+
assertEquals(1, entities.size());
153153
assertEquals(user2, entities.iterator().next().getInfo().get(userKey));
154154
}
155155

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/src/test/java/org/apache/hadoop/yarn/server/timelineservice/reader/TestTimelineReaderWebServicesUtils.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -31,15 +31,13 @@
3131
import org.apache.hadoop.yarn.server.timelineservice.reader.filter.TimelinePrefixFilter;
3232

3333
import static org.junit.jupiter.api.Assertions.assertEquals;
34-
import static org.junit.jupiter.api.Assertions.assertNotNull;
3534
import static org.junit.jupiter.api.Assertions.assertNull;
3635
import static org.junit.jupiter.api.Assertions.fail;
3736

3837
public class TestTimelineReaderWebServicesUtils {
3938
private static void verifyFilterList(String expr, TimelineFilterList list,
40-
TimelineFilterList expectedList) throws Exception {
41-
assertNotNull(list);
42-
assertEquals(list, expectedList);
39+
TimelineFilterList expectedList) {
40+
assertEquals(expectedList, list);
4341
}
4442

4543
@Test

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/src/test/java/org/apache/hadoop/yarn/server/timelineservice/storage/TestFileSystemTimelineWriterImpl.java

Lines changed: 10 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -44,11 +44,12 @@
4444
import org.apache.hadoop.yarn.util.timeline.TimelineUtils;
4545

4646
import static org.junit.jupiter.api.Assertions.assertEquals;
47+
import static org.junit.jupiter.api.Assertions.assertFalse;
4748
import static org.junit.jupiter.api.Assertions.assertTrue;
4849

4950
public class TestFileSystemTimelineWriterImpl {
5051
@TempDir
51-
public File tmpFolder;
52+
private File tmpFolder;
5253

5354
/**
5455
* Unit test for PoC YARN 3264.
@@ -111,11 +112,10 @@ void testWriteEntityToFile() throws Exception {
111112
assertTrue(fs.exists(path),
112113
"Specified path(" + fileName + ") should exist: ");
113114
FileStatus fileStatus = fs.getFileStatus(path);
114-
assertTrue(!fileStatus.isDirectory(),
115-
"Specified path should be a file");
115+
assertFalse(fileStatus.isDirectory(), "Specified path should be a file");
116116
List<String> data = readFromFile(fs, path);
117117
// ensure there's only one entity + 1 new line
118-
assertTrue(data.size() == 2, "data size is:" + data.size());
118+
assertEquals(2, data.size(), "data size is:" + data.size());
119119
String d = data.get(0);
120120
// confirm the contents same as what was written
121121
assertEquals(d, TimelineUtils.dumpTimelineRecordtoJSON(entity));
@@ -131,11 +131,10 @@ void testWriteEntityToFile() throws Exception {
131131
assertTrue(fs.exists(path2),
132132
"Specified path(" + fileName + ") should exist: ");
133133
FileStatus fileStatus2 = fs.getFileStatus(path2);
134-
assertTrue(!fileStatus2.isDirectory(),
135-
"Specified path should be a file");
134+
assertFalse(fileStatus2.isDirectory(), "Specified path should be a file");
136135
List<String> data2 = readFromFile(fs, path2);
137136
// ensure there's only one entity + 1 new line
138-
assertTrue(data2.size() == 2, "data size is:" + data2.size());
137+
assertEquals(2, data2.size(), "data size is:" + data2.size());
139138
String metricToString = data2.get(0);
140139
// confirm the contents same as what was written
141140
assertEquals(metricToString,
@@ -195,10 +194,9 @@ void testWriteMultipleEntities() throws Exception {
195194
assertTrue(fs.exists(path),
196195
"Specified path(" + fileName + ") should exist: ");
197196
FileStatus fileStatus = fs.getFileStatus(path);
198-
assertTrue(!fileStatus.isDirectory(),
199-
"Specified path should be a file");
197+
assertFalse(fileStatus.isDirectory(), "Specified path should be a file");
200198
List<String> data = readFromFile(fs, path);
201-
assertTrue(data.size() == 3, "data size is:" + data.size());
199+
assertEquals(3, data.size(), "data size is:" + data.size());
202200
String d = data.get(0);
203201
// confirm the contents same as what was written
204202
assertEquals(d, TimelineUtils.dumpTimelineRecordtoJSON(entity));
@@ -252,10 +250,9 @@ void testWriteEntitiesWithEmptyFlowName() throws Exception {
252250
assertTrue(fs.exists(path),
253251
"Specified path(" + fileName + ") should exist: ");
254252
FileStatus fileStatus = fs.getFileStatus(path);
255-
assertTrue(!fileStatus.isDirectory(),
256-
"Specified path should be a file");
253+
assertFalse(fileStatus.isDirectory(), "specified path should be a file");
257254
List<String> data = readFromFile(fs, path);
258-
assertTrue(data.size() == 2, "data size is:" + data.size());
255+
assertEquals(2, data.size(), "data size is:" + data.size());
259256
String d = data.get(0);
260257
// confirm the contents same as what was written
261258
assertEquals(d, TimelineUtils.dumpTimelineRecordtoJSON(entity));
@@ -280,12 +277,4 @@ private List<String> readFromFile(FileSystem fs, Path path)
280277
return data;
281278
}
282279

283-
private static File newFolder(File root, String... subDirs) throws IOException {
284-
String subFolder = String.join("/", subDirs);
285-
File result = new File(root, subFolder);
286-
if (!result.mkdirs()) {
287-
throw new IOException("Couldn't create folders " + root);
288-
}
289-
return result;
290-
}
291280
}

0 commit comments

Comments
 (0)