file not found error

0

Hello,

Im trying with EMR Serverless, switching from EMR getting below error

Traceback (most recent call last):
  File "/tmp/spark-07b8331c-566b-43e9-bf1a-f0a77cb86420/spark_main.py", line 7, in <module>
    from app.parsers.core_signal_parser import CoreSignalDataParser
  File "<frozen importlib._bootstrap>", line 983, in _find_and_load
  File "<frozen importlib._bootstrap>", line 967, in _find_and_load_unlocked
  File "<frozen importlib._bootstrap>", line 668, in _load_unlocked
  File "<frozen importlib._bootstrap>", line 638, in _load_backward_compatible
  File "/tmp/spark-07b8331c-566b-43e9-bf1a-f0a77cb86420/sources_5dbc92a.zip/app/parsers/core_signal_parser.py", line 29, in <module>
  File "<frozen importlib._bootstrap>", line 983, in _find_and_load
  File "<frozen importlib._bootstrap>", line 967, in _find_and_load_unlocked
  File "<frozen importlib._bootstrap>", line 668, in _load_unlocked
  File "<frozen importlib._bootstrap>", line 638, in _load_backward_compatible
  File "/tmp/spark-07b8331c-566b-43e9-bf1a-f0a77cb86420/sources_5dbc92a.zip/app/formatter/candidate_formatter.py", line 11, in <module>
  File "<frozen importlib._bootstrap>", line 983, in _find_and_load
  File "<frozen importlib._bootstrap>", line 967, in _find_and_load_unlocked
  File "<frozen importlib._bootstrap>", line 668, in _load_unlocked
  File "<frozen importlib._bootstrap>", line 638, in _load_backward_compatible
  File "/tmp/spark-07b8331c-566b-43e9-bf1a-f0a77cb86420/sources_5dbc92a.zip/app/parsers/general_parser.py", line 23, in <module>
  File "<frozen importlib._bootstrap>", line 983, in _find_and_load
  File "<frozen importlib._bootstrap>", line 967, in _find_and_load_unlocked
  File "<frozen importlib._bootstrap>", line 668, in _load_unlocked
  File "<frozen importlib._bootstrap>", line 638, in _load_backward_compatible
  File "/tmp/spark-07b8331c-566b-43e9-bf1a-f0a77cb86420/sources_5dbc92a.zip/app/core/config.py", line 120, in <module>
  File "/tmp/spark-07b8331c-566b-43e9-bf1a-f0a77cb86420/sources_5dbc92a.zip/app/core/config.py", line 86, in __init__
FileNotFoundError: [Errno 2] No such file or directory: 'config.json'

I had tried to pass files with --files s3://{S3_BUCKET}/emr/pyspark/code/users/devops/processing_source_code/config.json No luck, can anyone help with this

Ashwath
asked 11 days ago72 views
1 Answer
0
Accepted Answer

Hello there,

I understand that you want to read the file which has been passed to EMR serverless using --files or --conf spark.files. In EMR serverless, the files are placed in a temporary location which is not the python execution location hence the error.

A workaround for the issue in EMR serverless is to use pyspark.SparkFiles.get

An example code snippet on how to use it is as below.

import pyspark
from pyspark.sql import SparkSession
from pyspark import SparkFiles
spark = SparkSession.builder \
                    .appName('').enableHiveSupport() \
                    .getOrCreate()

path = SparkFiles.get("config.json")
f = open(path, "r")
print(f.read())
spark.stop()

i hope the above resolves your issue and please revert if the workaround is not working for you.

Have a great day ahead.

AWS
answered 11 days ago
AWS
SUPPORT ENGINEER
reviewed 11 days ago

You are not logged in. Log in to post an answer.

A good answer clearly answers the question and provides constructive feedback and encourages professional growth in the question asker.

Guidelines for Answering Questions