Questions tagged with Amazon EMR

Amazon EMR is a cloud big data platform for running large-scale distributed data processing jobs, interactive SQL queries, and machine learning (ML) applications using open-source analytics frameworks such as Apache Spark, Apache Hive, and Presto.

Content language: English

Select up to 5 tags to filter
Sort by most recent

Browse through the questions and answers listed below or filter and sort to narrow down your results.

317 results
I have an EMR cluster and I have used the treasure data connector to read data from table into dataframe using pyspark. Now these tables that I'm trying to read have approximately 100 million to 500 m...
1
answers
0
votes
933
views
asked 8 months ago
Issue: PySpark works in the first cells (likely SparkSession creation) but throws import errors when using my Python files in later cells. Environment: AWS EMR ( Amazon EMR version emr-6.4.0 Installe...
1
answers
0
votes
678
views
asked 8 months ago
Let me know if this is something AWS EMR Studio does: 1. in Databricks community edition, and in Google Collab, one can fire up a simple Jupyter notrebook with an automatically started cluster (small ...
1
answers
0
votes
695
views
asked 8 months ago
Hi everyone, I am using AWS EMR to do some ETL operations on very large datasets (like millions/billions of records). I am using PySpark and reading the csv files using *spark.read.csv*. The results ...
1
answers
0
votes
940
views
asked 8 months ago
While running the serverless job run, I am getting below errror: "Number of cores specified by 'spark.driver.cores '7' is invalid".
2
answers
0
votes
566
views
asked 8 months ago
Hi I have a EMR with Hbase on S3 storage mode.I have a read replica cluster pointing to same S3 bucket. Now when I add record in primary cluster and flush table on primary, and then run refresh_hfiles...
1
answers
0
votes
571
views
asked 8 months ago
Hi I am getting error while launching EMR with Hbase as S3Storage and WAL backup enabled . Caused by: java.lang.RuntimeException: createWal failed for wal WALMetadata(WALWorkspace=testworkspace2, Ta...
1
answers
0
votes
691
views
asked 8 months ago
I have a Python package saved in CodeCommit and need to use it in the notebook attached to my EMR cluster workspace. The package is already successfully installed via bootstrap. To do this, in my .sh ...
1
answers
0
votes
587
views
asked 9 months ago
I have a Serverless EMR appication, I am submitting a spark job via python script. I have packaged all the dependencies an an the script to an s3 bucket. When I execute the job the spark job is runnin...
2
answers
0
votes
667
views
asked 9 months ago
Hello, I configured iceberg formatted table with transaction in hive on EMR 6.4.1. When I insert data into the table, the operation get stuck, without any error. Any insights are highly appreciate...
Accepted AnswerAmazon EMR
1
answers
0
votes
517
views
asked 9 months ago
I've started seeing the following error on JupyterHub on EMR `TypeError: required field "type_ignores" missing from Module` from the simplest commands ![the command](/media/postImages/original/IM0G...
2
answers
0
votes
576
views
asked 9 months ago
Hi Team, We have EMR 6.10 cluster where flink jobs submitted to existing application. Container was running in task node in my case. Then I resized the task instance group from 1 to 0 in task instance...
Accepted AnswerAmazon EMR
1
answers
0
votes
529
views
asked 9 months ago