Enrico Minack created SPARK-55447:
-------------------------------------
Summary: Deleting blocks via BlockManagerMaster and blocking =
false is still blocking
Key: SPARK-55447
URL: https://issues.apache.org/jira/browse/SPARK-55447
Project: Spark
Issue Type: Bug
Components: Spark Core
Affects Versions: 4.2.0
Reporter: Enrico Minack
Calling {{BlockManagerMaster}} methods {{removeRdd}}, {{removeShuffle}} and
{{removeBroadcast}} with {{blocking = false}} still blocks.
These methods call {{driverEndpoint.askSync}}, which (as the name implies}}
waits for the future's result:
{code}
def askSync[T: ClassTag](message: Any): T = askSync(message, defaultAskTimeout)
def askSync[T: ClassTag](message: Any, timeout: RpcTimeout): T = {
val future = ask[T](message, timeout)
timeout.awaitResult(future)
}
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
