<?xml version="1.0" encoding="UTF-8"?>
<rss xmlns:content="http://purl.org/rss/1.0/modules/content/" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:taxo="http://purl.org/rss/1.0/modules/taxonomy/" version="2.0">
  <channel>
    <title>topic ERROR - Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages. in Data Engineering</title>
    <link>https://community.databricks.com/t5/data-engineering/error-remote-rpc-client-disassociated-likely-due-to-containers/m-p/31354#M22814</link>
    <description>&lt;P&gt;I get the below error when trying to run multi-threading - fails towards the end of the run. My guess is it's related to memory/worker config. I've seen some solutions involving modifying the number of workers or CPU on the cluster - however that's not an option for me. If I can't change any cluster configs, what's the best way to resolve this error - decrease the max workers on my thread pool executor? &lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;PRE&gt;&lt;CODE&gt;from concurrent.futures import ThreadPoolExecutor
&amp;nbsp;
with ThreadPoolExecutor() as executor:
  executor.map(func, arg)
  .
  .
  .
&amp;nbsp;
Error:
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 1573.0 failed 4 times, most recent failure: Lost task 0.3 in stage 1573.0 (TID #####) (##.###.###.### executor 87): ExecutorLostFailure (executor 87 exited caused by one of the running tasks) Reason: Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.&lt;/CODE&gt;&lt;/PRE&gt;&lt;P&gt;&lt;/P&gt;</description>
    <pubDate>Mon, 19 Sep 2022 18:19:43 GMT</pubDate>
    <dc:creator>pjp94</dc:creator>
    <dc:date>2022-09-19T18:19:43Z</dc:date>
    <item>
      <title>ERROR - Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.</title>
      <link>https://community.databricks.com/t5/data-engineering/error-remote-rpc-client-disassociated-likely-due-to-containers/m-p/31354#M22814</link>
      <description>&lt;P&gt;I get the below error when trying to run multi-threading - fails towards the end of the run. My guess is it's related to memory/worker config. I've seen some solutions involving modifying the number of workers or CPU on the cluster - however that's not an option for me. If I can't change any cluster configs, what's the best way to resolve this error - decrease the max workers on my thread pool executor? &lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;PRE&gt;&lt;CODE&gt;from concurrent.futures import ThreadPoolExecutor
&amp;nbsp;
with ThreadPoolExecutor() as executor:
  executor.map(func, arg)
  .
  .
  .
&amp;nbsp;
Error:
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 1573.0 failed 4 times, most recent failure: Lost task 0.3 in stage 1573.0 (TID #####) (##.###.###.### executor 87): ExecutorLostFailure (executor 87 exited caused by one of the running tasks) Reason: Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.&lt;/CODE&gt;&lt;/PRE&gt;&lt;P&gt;&lt;/P&gt;</description>
      <pubDate>Mon, 19 Sep 2022 18:19:43 GMT</pubDate>
      <guid>https://community.databricks.com/t5/data-engineering/error-remote-rpc-client-disassociated-likely-due-to-containers/m-p/31354#M22814</guid>
      <dc:creator>pjp94</dc:creator>
      <dc:date>2022-09-19T18:19:43Z</dc:date>
    </item>
    <item>
      <title>Re: ERROR - Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.</title>
      <link>https://community.databricks.com/t5/data-engineering/error-remote-rpc-client-disassociated-likely-due-to-containers/m-p/31355#M22815</link>
      <description>&lt;P&gt;Since I don't have permissions to change cluster configurations, the only solution that ended up working was setting a max thread count to about half of the actual max so I don't overload the containers. However, open to any other optimization ideas!&lt;/P&gt;</description>
      <pubDate>Mon, 19 Sep 2022 19:56:47 GMT</pubDate>
      <guid>https://community.databricks.com/t5/data-engineering/error-remote-rpc-client-disassociated-likely-due-to-containers/m-p/31355#M22815</guid>
      <dc:creator>pjp94</dc:creator>
      <dc:date>2022-09-19T19:56:47Z</dc:date>
    </item>
  </channel>
</rss>

