File tree 1 file changed +4
-0
lines changed
flink-yarn-tests/src/test/java/org/apache/flink/yarn
1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change 40
40
import java .time .Duration ;
41
41
import java .util .Collections ;
42
42
43
+ import static org .apache .flink .configuration .CoreOptions .FLINK_JVM_OPTIONS ;
43
44
import static org .apache .flink .yarn .configuration .YarnConfigOptions .CLASSPATH_INCLUDE_USER_JAR ;
44
45
import static org .apache .flink .yarn .util .TestUtils .getTestJarPath ;
45
46
@@ -136,6 +137,9 @@ private Configuration createDefaultConfiguration(
136
137
configuration .set (CLASSPATH_INCLUDE_USER_JAR , userJarInclusion );
137
138
configuration .set (PipelineOptions .JARS , Collections .singletonList (userJar .toString ()));
138
139
140
+ // Apply the JVM arguments that were set for unit tests to any Flink JVMs
141
+ configuration .set (FLINK_JVM_OPTIONS , System .getProperty ("surefire.module.config" ));
142
+
139
143
return configuration ;
140
144
}
141
145
}
You can’t perform that action at this time.
0 commit comments