Skip to content

Commit e42fef9

Browse files
committed
YARN-11796. Accept extra JDK 17 options in tests
1 parent cd8f18b commit e42fef9

File tree

2 files changed

+23
-0
lines changed

2 files changed

+23
-0
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/TestLinuxContainerExecutorWithMocks.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@
5353
import org.apache.hadoop.conf.Configuration;
5454
import org.apache.hadoop.fs.FileUtil;
5555
import org.apache.hadoop.fs.Path;
56+
import org.apache.hadoop.util.Shell;
5657
import org.apache.hadoop.util.StringUtils;
5758
import org.apache.hadoop.yarn.api.records.ApplicationAttemptId;
5859
import org.apache.hadoop.yarn.api.records.ApplicationId;
@@ -311,6 +312,12 @@ public void testStartLocalizer() throws IOException {
311312
.build());
312313

313314
List<String> result=readMockParams();
315+
316+
if (Shell.isJavaVersionAtLeast(17)) {
317+
assertTrue(result.remove("--add-exports=java.base/sun.net.dns=ALL-UNNAMED"));
318+
assertTrue(result.remove("--add-exports=java.base/sun.net.util=ALL-UNNAMED"));
319+
}
320+
314321
assertThat(result).hasSize(26);
315322
assertThat(result.get(0)).isEqualTo(YarnConfiguration.
316323
DEFAULT_NM_NONSECURE_MODE_LOCAL_USER);

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/TestContainerLocalizer.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -751,6 +751,10 @@ public void testAdminOptionsPrecedeUserDefinedJavaOptions() throws Exception {
751751
" userOption1 userOption2");
752752
List<String> javaOpts = localizer.getJavaOpts(conf);
753753

754+
if (Shell.isJavaVersionAtLeast(17)) {
755+
assertTrue(javaOpts.remove("--add-exports=java.base/sun.net.dns=ALL-UNNAMED"));
756+
assertTrue(javaOpts.remove("--add-exports=java.base/sun.net.util=ALL-UNNAMED"));
757+
}
754758
assertEquals(4, javaOpts.size());
755759
assertTrue(javaOpts.get(0).equals("adminOption1"));
756760
assertTrue(javaOpts.get(1).equals("adminOption2"));
@@ -768,6 +772,10 @@ public void testAdminOptionsPrecedeDefaultUserOptions() throws Exception {
768772
"adminOption1 adminOption2");
769773
List<String> javaOpts = localizer.getJavaOpts(conf);
770774

775+
if (Shell.isJavaVersionAtLeast(17)) {
776+
assertTrue(javaOpts.remove("--add-exports=java.base/sun.net.dns=ALL-UNNAMED"));
777+
assertTrue(javaOpts.remove("--add-exports=java.base/sun.net.util=ALL-UNNAMED"));
778+
}
771779
assertEquals(3, javaOpts.size());
772780
assertTrue(javaOpts.get(0).equals("adminOption1"));
773781
assertTrue(javaOpts.get(1).equals("adminOption2"));
@@ -784,6 +792,10 @@ public void testUserOptionsWhenAdminOptionsAreNotDefined() throws Exception {
784792
"userOption1 userOption2");
785793
List<String> javaOpts = localizer.getJavaOpts(conf);
786794

795+
if (Shell.isJavaVersionAtLeast(17)) {
796+
assertTrue(javaOpts.remove("--add-exports=java.base/sun.net.dns=ALL-UNNAMED"));
797+
assertTrue(javaOpts.remove("--add-exports=java.base/sun.net.util=ALL-UNNAMED"));
798+
}
787799
assertEquals(2, javaOpts.size());
788800
assertTrue(javaOpts.get(0).equals("userOption1"));
789801
assertTrue(javaOpts.get(1).equals("userOption2"));
@@ -797,6 +809,10 @@ public void testJavaOptionsWithoutDefinedAdminOrUserOptions() throws Exception {
797809
Configuration conf = new Configuration();
798810
List<String> javaOpts = localizer.getJavaOpts(conf);
799811

812+
if (Shell.isJavaVersionAtLeast(17)) {
813+
assertTrue(javaOpts.remove("--add-exports=java.base/sun.net.dns=ALL-UNNAMED"));
814+
assertTrue(javaOpts.remove("--add-exports=java.base/sun.net.util=ALL-UNNAMED"));
815+
}
800816
assertEquals(1, javaOpts.size());
801817
assertTrue(javaOpts.get(0).equals("-Xmx256m"));
802818
}

0 commit comments

Comments
 (0)