File tree Expand file tree Collapse file tree
sdks/java/testing/load-tests Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -96,6 +96,19 @@ if (isSparkRunner) {
9696 }
9797}
9898
99+ def sparkJvmArgs () {
100+ def testJavaVer = project. findProperty(' testJavaVersion' ) ? (project. property(' testJavaVersion' ) as int ) : JavaVersion . current(). majorVersion. toInteger()
101+ if (testJavaVer >= 17 ) {
102+ return [
103+ " --add-opens=java.base/sun.nio.ch=ALL-UNNAMED" ,
104+ " --add-opens=java.base/java.nio=ALL-UNNAMED" ,
105+ " --add-opens=java.base/java.util=ALL-UNNAMED" ,
106+ " --add-opens=java.base/java.lang.invoke=ALL-UNNAMED"
107+ ]
108+ }
109+ return []
110+ }
111+
99112def getLoadTestArgs = {
100113 def loadTestArgs = project. findProperty(loadTestArgsProperty) ?: " "
101114 def loadTestArgsList = new ArrayList<String > ()
@@ -133,6 +146,7 @@ task run(type: JavaExec) {
133146 // Disable UI
134147 systemProperty " spark.ui.enabled" , " false"
135148 systemProperty " spark.ui.showConsoleProgress" , " false"
149+ jvmArgs + = sparkJvmArgs()
136150 }
137151
138152 mainClass = project. findProperty(mainClassProperty)
You can’t perform that action at this time.
0 commit comments