<?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 Handling skew data in Spark Batches in Talend Studio</title>
    <link>https://community.qlik.com/t5/Talend-Studio/Handling-skew-data-in-Spark-Batches/m-p/2334390#M103063</link>
    <description>&lt;P&gt;Hello,&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;I've come to notice a certain spark batch job normally gets stuck in the 200th task of some stages (199/200) and I've been looking for causes of this, finding articles about data skewness and how to fix it, with spark code examples.&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Do apache spark batches have some kind of way to fix these kind of problems? Such as broadcasting tables or salting.&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;I'm currently using Talend Big Data R2020-09-7.3.1 with CDH 6.3.2 and Spark 2.4.&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Any help or take on the matter would be appreciated.&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Thanks.&lt;/P&gt;</description>
    <pubDate>Fri, 15 Nov 2024 22:20:20 GMT</pubDate>
    <dc:creator>J_Ruiz</dc:creator>
    <dc:date>2024-11-15T22:20:20Z</dc:date>
    <item>
      <title>Handling skew data in Spark Batches</title>
      <link>https://community.qlik.com/t5/Talend-Studio/Handling-skew-data-in-Spark-Batches/m-p/2334390#M103063</link>
      <description>&lt;P&gt;Hello,&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;I've come to notice a certain spark batch job normally gets stuck in the 200th task of some stages (199/200) and I've been looking for causes of this, finding articles about data skewness and how to fix it, with spark code examples.&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Do apache spark batches have some kind of way to fix these kind of problems? Such as broadcasting tables or salting.&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;I'm currently using Talend Big Data R2020-09-7.3.1 with CDH 6.3.2 and Spark 2.4.&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Any help or take on the matter would be appreciated.&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Thanks.&lt;/P&gt;</description>
      <pubDate>Fri, 15 Nov 2024 22:20:20 GMT</pubDate>
      <guid>https://community.qlik.com/t5/Talend-Studio/Handling-skew-data-in-Spark-Batches/m-p/2334390#M103063</guid>
      <dc:creator>J_Ruiz</dc:creator>
      <dc:date>2024-11-15T22:20:20Z</dc:date>
    </item>
    <item>
      <title>Re: Handling skew data in Spark Batches</title>
      <link>https://community.qlik.com/t5/Talend-Studio/Handling-skew-data-in-Spark-Batches/m-p/2334391#M103064</link>
      <description>&lt;P&gt;Hello,&lt;/P&gt;&lt;P&gt;Are you getting Spark Error java.lang.OutOfMemoryError when executing Talend BigData spark Batch job?&lt;/P&gt;&lt;P&gt;First of all, we'd like to check your job design first to fully investigate this issue.&lt;/P&gt;&lt;P&gt;And Is there any execution log from Talend side(Studio or job server) and any log from Hadoop side?&lt;/P&gt;&lt;P&gt;Best regards&lt;/P&gt;&lt;P&gt;Sabrina&lt;/P&gt;</description>
      <pubDate>Thu, 24 Nov 2022 04:19:17 GMT</pubDate>
      <guid>https://community.qlik.com/t5/Talend-Studio/Handling-skew-data-in-Spark-Batches/m-p/2334391#M103064</guid>
      <dc:creator>Anonymous</dc:creator>
      <dc:date>2022-11-24T04:19:17Z</dc:date>
    </item>
  </channel>
</rss>

