Skip to content

Commit 9a47c24

Browse files
wip
1 parent 1233064 commit 9a47c24

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed

spec/pyspark/script_pyspark.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,14 @@
55
import os
66
import pytest
77

8-
os.environ['JAVA_HOME'] = '/usr/lib/jvm/java-17-openjdk-amd64'
8+
# os.environ['JAVA_HOME'] = '/usr/lib/jvm/java-17-openjdk-amd64'
99

1010
session = boto3.Session()
1111
credentials = session.get_credentials().get_frozen_credentials()
1212

1313
s3_endpoint_url = 'https://br-se1.magaluobjects.com'
1414

15+
s3 = boto3.client('s3')
1516
def get_spark_session(path_style_access=True):
1617
try:
1718
builder = SparkSession.builder.appName("Demo") \

spec/pyspark/test_basic.py

+10
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
# make sure there is an AWS_PROFILE env var set and a configured aws profile with the name
2+
from pyspark.sql import SparkSession
3+
4+
def test_pyspark_session():
5+
spark = SparkSession.builder.appName("foo").getOrCreate()
6+
assert True
7+
8+
if __name__ == "__main__":
9+
pytest.main([__file__])
10+

0 commit comments

Comments
 (0)