Member since
09-29-2022
16
Posts
1
Kudos Received
1
Solution
My Accepted Solutions
Title | Views | Posted |
---|---|---|
5297 | 11-25-2022 09:34 PM |
04-06-2023
01:19 PM
@pankshiv1809 Can you share the spark-submit conf for UPSS_PROMO_PROMOTIONS Spark JOB ? JConsole, which helps to detect performance problems in the code including java.lang.OutOfMemoryErrors. Depending on the available memory on your cluster you can then re-adjust as suggested by @RangaReddy
... View more
04-06-2023
12:58 PM
@pankshiv1809 Can you share a more detailed log and background on your environment,Python versions etc Geoffrey
... View more
03-30-2023
04:38 AM
Use the following tool to generate no of executors: https://rangareddy.github.io/SparkConfigurationGenerator/ In order to calculate the driver memory/executor memory we need to start with 1g, 2g, 4g, 8g .... and executor-cores you can set 3-5 and number of executor it will depend on data how much you are processing.
... View more
03-30-2023
04:35 AM
Hi @pankshiv1809 To run application faster, we need to tune the resources, spark code and cluster. To solve any kind of performance issues, you need to go through the Spark UI and understand jobs, stages and executors. After that you need to tune the resources like driver and executor memory and no of executors and separate queue to process the data. If you want to know other techniques raise the Cloudera case, we will help to further.
... View more
01-17-2023
11:03 PM
Hello @pankshiv1809 Since we haven't heard from your side concerning the Post, We are marking the Post as Solved. If you have any further ask, Feel free to update the Post & we shall get back to you accordingly. Regards, Smarak
... View more
12-13-2022
11:25 PM
I am trying to retrive hadoop table "select * from stg_db_kafka. limit 5 ;" betting the given error SQL Error: java.io.IOException: java.lang.RuntimeException: hdfs://NDC3HDPPROD/warehouse/tablespace/external/hive/stg_db_kafka.db/stg_prepaid_rated_usage_kafka/partitioncolumn=20220823085257/part-00002-7afffe68-eccb-4f9b-8f98-ac0a182c8e26.c000.snappy.parquet is not a Parquet file (too small length: 4) Could some one help me to fix it.
... View more
Labels:
- Labels:
-
Apache Kafka
11-25-2022
09:34 PM
GM Asish... Thanks for sharing difference between two parameter. Will take note on tez.task.resource.memory.mb should be set < hive.tez.container.size Appreciate for your support. Regards, Pankaj shivankar
... View more
11-17-2022
02:09 AM
@pankshiv1809 was your question answered? Make sure to mark the answer as the accepted solution. If you find a reply useful, say thanks by clicking on the thumbs up button.
... View more