[
https://issues.apache.org/jira/browse/SPARK-41447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuyouZZ updated SPARK-41447:
-----------------------------
Description:
When restarting the history server, the previous logic is to execute
{{checkForLogs}} first, which will cause the expired event log files to be
parsed, and then execute {{checkAndCleanLog}} to delete parsed info, which is
unnecessary.If there are a large number of expired log files in the log
directory, it will affect the speed of replay.
In order to avoid this, we can put {{cleanLogs}} before {{{}checkForLogs{}}}.
In addition, since {{cleanLogs}} is executed before {{{}checkForLogs{}}}, when
the history server is starting, the expired log info may not exist in the
listing db, so we need to clean up these log files in {{{}cleanLogs{}}}.
was:
When restarting the history server, the previous logic is to execute
`checkForLogs` first, which will cause the expired event log files to be
parsed, and then execute `checkAndCleanLog` to delete parsed info, which is
unnecessary.
If there are a large number of expired log files in the log directory, it will
seriously affect the speed of replay.
In order to avoid this, we can put `cleanLogs` before `checkForLogs`. In
addition, since`cleanLogs` is executed before `checkForLogs`, when the history
server is starting, the expired log info may not exist in the listing db, so we
need to clean up these log files in `cleanLogs`.
> clean up expired event log files that don't exist in listing db
> ---------------------------------------------------------------
>
> Key: SPARK-41447
> URL: https://issues.apache.org/jira/browse/SPARK-41447
> Project: Spark
> Issue Type: Improvement
> Components: Spark Core
> Affects Versions: 3.4.0
> Reporter: shuyouZZ
> Priority: Major
>
> When restarting the history server, the previous logic is to execute
> {{checkForLogs}} first, which will cause the expired event log files to be
> parsed, and then execute {{checkAndCleanLog}} to delete parsed info, which is
> unnecessary.If there are a large number of expired log files in the log
> directory, it will affect the speed of replay.
> In order to avoid this, we can put {{cleanLogs}} before {{{}checkForLogs{}}}.
> In addition, since {{cleanLogs}} is executed before {{{}checkForLogs{}}},
> when the history server is starting, the expired log info may not exist in
> the listing db, so we need to clean up these log files in {{{}cleanLogs{}}}.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
