Uh oh!
There was an error while loading. Please reload this page.
[SPARK-19450] Replace askWithRetry with askSync. - #16790
Conversation
jinxing64
commented
Feb 17, 2017
#16690 (comment) causes the build to produce lots of deprecation warnings. |
srowen
commented
Feb 17, 2017
If it was just an internal API that's not supposed to be used not, and |
@srowen Both |
vanzin
commented
Feb 17, 2017
ok to test |
vanzin
commented
Feb 17, 2017
The change LGTM pending tests. |
SparkQA
commented
Feb 17, 2017
Test build #73069 has finished for PR 16790 at commit
|
vanzin
commented
Feb 18, 2017
retest this please |
SparkQA
commented
Feb 18, 2017
Test build #73084 has finished for PR 16790 at commit
|
srowen
commented
Feb 19, 2017
Merged to master |
jinxing64
commented
Feb 19, 2017
## What changes were proposed in this pull request? `askSync` is already added in `RpcEndpointRef` (see SPARK-19347 and apache#16690 (comment)) and `askWithRetry` is marked as deprecated. As mentioned SPARK-18113(apache#16503 (comment)): >askWithRetry is basically an unneeded API, and a leftover from the akka days that doesn't make sense anymore. It's prone to cause deadlocks (exactly because it's blocking), it imposes restrictions on the caller (e.g. idempotency) and other things that people generally don't pay that much attention to when using it. Since `askWithRetry` is just used inside spark and not in user logic. It might make sense to replace all of them with `askSync`. ## How was this patch tested? This PR doesn't change code logic, existing unit test can cover. Author: jinxing <jinxing@meituan.com> Closesapache#16790 from jinxing64/SPARK-19450.
…rpc.retry.wait` configs ### What changes were proposed in this pull request? This PR cleans up the `spark.rpc.numRetries` and `spark.rpc.retry.wait` configs, both of which are unused. ### Why are the changes needed? Since SPARK-19450 / #16790 in Spark 2.2.0, both of these configurations are unused and setting them has no effect. Marking the configs as deprecated and cleaning them up from the docs helps to avoid user confusion. In addition, this cleanup slightly improves the performance of constructing `RpcEndpointRef`s because it removes two unused fields that were initialized by reading the deprecated configs. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? n/a Closes#36645 from JoshRosen/cleanup-unused-rpc-configs. Authored-by: Josh Rosen <joshrosen@databricks.com> Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
What changes were proposed in this pull request?
askSyncis already added inRpcEndpointRef(see SPARK-19347 and #16690 (comment)) andaskWithRetryis marked as deprecated.As mentioned SPARK-18113(#16503 (comment)):
Since
askWithRetryis just used inside spark and not in user logic. It might make sense to replace all of them withaskSync.How was this patch tested?
This PR doesn't change code logic, existing unit test can cover.