Skip to content
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

Profiler may crash if driverLog is not accessible #725

Closed
wants to merge 1 commit into from

Conversation

kuhushukla
Copy link
Collaborator

Fixes #698

@amahussein amahussein added feature request New feature or request core_tools Scope the core module (scala) labels Jan 16, 2024
import com.nvidia.spark.rapids.tool.EventLogPathProcessor

import org.apache.spark.internal.Logging
import org.apache.spark.sql.rapids.tool.AppFilterImpl
import org.apache.spark.sql.rapids.tool.util.RapidsToolsConfUtil


Copy link
Collaborator Author

Choose a reason for hiding this comment

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

shall remove

@kuhushukla kuhushukla marked this pull request as ready for review January 17, 2024 19:37
Copy link
Collaborator

@parthosa parthosa left a comment

Choose a reason for hiding this comment

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

Thanks @kuhushukla.

@@ -78,7 +80,15 @@ object ProfileMain extends Logging {

val profiler = new Profiler(hadoopConf, appArgs, enablePB)
if (driverLog.nonEmpty) {
profiler.profileDriver(driverLog, eventLogFsFiltered.isEmpty)
val dLogPath = new org.apache.hadoop.fs.Path(driverLog)
Copy link
Collaborator

Choose a reason for hiding this comment

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

@amahussein Regarding the comment in issue description,

Furthermore, the class is not using hadoop API to load the files, which means that only files on local path can be processed.

Is this referring to the use case when the driver logs can be located in cloud storage directories (s3, dbfs), similar to what we have for event logs?

In that case, we might have to use a similar approach as processing event logs

Copy link
Collaborator

Choose a reason for hiding this comment

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

Yes, this is exactly what this issue is about.
It does not make sense to me that we process eventlogs on remote storage but we are asking the user to download the driver-logs locally.

@amahussein
Copy link
Collaborator

Closing this PR as it became out dated it was not tested

@amahussein amahussein closed this May 28, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
core_tools Scope the core module (scala) feature request New feature or request
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[BUG] Profiler may crash if driverLog is not accessible
3 participants