-
Notifications
You must be signed in to change notification settings - Fork 28.7k
[SPARK-44242] Improve Max Heap not set check #41806
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
e072703
to
30d72e2
Compare
launcher/src/main/java/org/apache/spark/launcher/SparkSubmitCommandBuilder.java
Outdated
Show resolved
Hide resolved
launcher/src/main/java/org/apache/spark/launcher/SparkSubmitCommandBuilder.java
Outdated
Show resolved
Hide resolved
3a19cd3
to
2f2ec2f
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good to me.
+CC @LuciferYang
launcher/src/main/java/org/apache/spark/launcher/SparkSubmitCommandBuilder.java
Outdated
Show resolved
Hide resolved
@ashangit Java linter check failed, please fix it when you have time |
public void testCheckJavaOptionsThrowException() throws Exception { | ||
Map<String, String> env = new HashMap<>(); | ||
List<String> sparkSubmitArgs = Arrays.asList( | ||
parser.MASTER, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
indentation: should be 2 space too
public void testCheckJavaOptions() throws Exception { | ||
Map<String, String> env = new HashMap<>(); | ||
List<String> sparkSubmitArgs = Arrays.asList( | ||
parser.MASTER, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ditto
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, pending ci
@ashangit Can you rebase the code or re-trigger GA? Some testing tasks failed |
Currently if any Xmx string is available in the driver java options even if not related to Max Heap setting the job sumission failed
4aeea91
to
644a928
Compare
Test seems now stuck on pyspak-sql one: https://github.com/ashangit/spark/actions/runs/5451917791/jobs/9918773466#logs without any logs after 4H |
You can try canceling the running GA task and then re-trigger the failed one |
@mridulm can we merge this PR? |
Ah, I thought @LuciferYang might have merged this one :-) |
Merged to master. |
Sorry, I forgot about that… |
Just kidding @LuciferYang :-) |
### What changes were proposed in this pull request? Currently if any Xmx string is available in the driver java options even if not related to Max Heap setting the job sumission failed For Ex. this command failed `./bin/spark-submit --class org.apache.spark.examples.SparkPi --conf "spark.driver.extraJavaOptions=-Dtest=Xmx" examples/jars/spark-examples_2.12-3.4.1.jar 100` ### Why are the changes needed? The command should any failed if the -Xmx argument is set not if it is part of another parameter or string ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added a unitary test Closes apache#41806 from ashangit/nfraison/SPARK-44242. Authored-by: Nicolas Fraison <nicolas.fraison@datadoghq.com> Signed-off-by: Mridul Muralidharan <mridul<at>gmail.com>
### What changes were proposed in this pull request? Currently if any Xmx string is available in the driver java options even if not related to Max Heap setting the job sumission failed For Ex. this command failed `./bin/spark-submit --class org.apache.spark.examples.SparkPi --conf "spark.driver.extraJavaOptions=-Dtest=Xmx" examples/jars/spark-examples_2.12-3.4.1.jar 100` ### Why are the changes needed? The command should any failed if the -Xmx argument is set not if it is part of another parameter or string ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added a unitary test Closes apache#41806 from ashangit/nfraison/SPARK-44242. Authored-by: Nicolas Fraison <nicolas.fraison@datadoghq.com> Signed-off-by: Mridul Muralidharan <mridul<at>gmail.com>
### What changes were proposed in this pull request? Currently if any Xmx string is available in the driver java options even if not related to Max Heap setting the job sumission failed For Ex. this command failed `./bin/spark-submit --class org.apache.spark.examples.SparkPi --conf "spark.driver.extraJavaOptions=-Dtest=Xmx" examples/jars/spark-examples_2.12-3.4.1.jar 100` ### Why are the changes needed? The command should any failed if the -Xmx argument is set not if it is part of another parameter or string ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added a unitary test Closes apache#41806 from ashangit/nfraison/SPARK-44242. Authored-by: Nicolas Fraison <nicolas.fraison@datadoghq.com> Signed-off-by: Mridul Muralidharan <mridul<at>gmail.com>
### What changes were proposed in this pull request? Currently if any Xmx string is available in the driver java options even if not related to Max Heap setting the job sumission failed For Ex. this command failed `./bin/spark-submit --class org.apache.spark.examples.SparkPi --conf "spark.driver.extraJavaOptions=-Dtest=Xmx" examples/jars/spark-examples_2.12-3.4.1.jar 100` ### Why are the changes needed? The command should any failed if the -Xmx argument is set not if it is part of another parameter or string ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added a unitary test Closes apache#41806 from ashangit/nfraison/SPARK-44242. Authored-by: Nicolas Fraison <nicolas.fraison@datadoghq.com> Signed-off-by: Mridul Muralidharan <mridul<at>gmail.com> Co-authored-by: Nicolas Fraison <nicolas.fraison@datadoghq.com>
What changes were proposed in this pull request?
Currently if any Xmx string is available in the driver java options even if not related to Max Heap setting the job sumission failed
For Ex. this command failed
./bin/spark-submit --class org.apache.spark.examples.SparkPi --conf "spark.driver.extraJavaOptions=-Dtest=Xmx" examples/jars/spark-examples_2.12-3.4.1.jar 100
Why are the changes needed?
The command should any failed if the -Xmx argument is set not if it is part of another parameter or string
Does this PR introduce any user-facing change?
No
How was this patch tested?
Added a unitary test