Skip to content
Closed
Changes from 11 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,8 @@ List<String> buildClassPath(String appClassPath) throws IOException {

Set<String> cp = new LinkedHashSet<>();
addToClassPath(cp, appClassPath);

addToClassPath(cp, getenv("SPARK_DAEMON_CLASSPATH"));
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think it would be better to only support this env variable for daemon process like HistoryServer, ExternalShuffleService and others, like what we did for SPARK_DAEMON_JAVA_OPTS. Currently with your fix normal Spark application will also honor this env variable.

Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I agree with you on this. I have made the necessary changes.


addToClassPath(cp, getConfDir());

boolean prependClasses = !isEmpty(getenv("SPARK_PREPEND_CLASSES"));
Expand Down