Skip to content

Commit a4d231d

Browse files
laurenyunadiaya
authored andcommitted
Add regional S3 endpoint to PySpark notebooks (aws#421)
1 parent 8efffe3 commit a4d231d

5 files changed

+5
-0
lines changed

sagemaker-spark/pyspark_mnist/pyspark_mnist_custom_estimator.ipynb

+1
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@
9494
"import boto3\n",
9595
"\n",
9696
"region = boto3.Session().region_name\n",
97+
"spark._jsc.hadoopConfiguration().set('fs.s3a.endpoint', 's3.{}.amazonaws.com'.format(region))\n",
9798
"\n",
9899
"trainingData = spark.read.format('libsvm')\\\n",
99100
" .option('numFeatures', '784')\\\n",

sagemaker-spark/pyspark_mnist/pyspark_mnist_kmeans.ipynb

+1
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,7 @@
9595
"import boto3\n",
9696
"\n",
9797
"region = boto3.Session().region_name\n",
98+
"spark._jsc.hadoopConfiguration().set('fs.s3a.endpoint', 's3.{}.amazonaws.com'.format(region))\n",
9899
"\n",
99100
"trainingData = spark.read.format('libsvm')\\\n",
100101
" .option('numFeatures', '784')\\\n",

sagemaker-spark/pyspark_mnist/pyspark_mnist_pca_kmeans.ipynb

+1
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@
9494
"import boto3\n",
9595
"\n",
9696
"region = boto3.Session().region_name\n",
97+
"spark._jsc.hadoopConfiguration().set('fs.s3a.endpoint', 's3.{}.amazonaws.com'.format(region))\n",
9798
"\n",
9899
"trainingData = spark.read.format('libsvm')\\\n",
99100
" .option('numFeatures', '784')\\\n",

sagemaker-spark/pyspark_mnist/pyspark_mnist_pca_mllib_kmeans.ipynb

+1
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,7 @@
9898
"import boto3\n",
9999
"\n",
100100
"region = boto3.Session().region_name\n",
101+
"spark._jsc.hadoopConfiguration().set('fs.s3a.endpoint', 's3.{}.amazonaws.com'.format(region))\n",
101102
"\n",
102103
"trainingData = spark.read.format('libsvm')\\\n",
103104
" .option('numFeatures', '784')\\\n",

sagemaker-spark/pyspark_mnist/pyspark_mnist_xgboost.ipynb

+1
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,7 @@
9797
"import boto3\n",
9898
"\n",
9999
"region = boto3.Session().region_name\n",
100+
"spark._jsc.hadoopConfiguration().set('fs.s3a.endpoint', 's3.{}.amazonaws.com'.format(region))\n",
100101
"\n",
101102
"trainingData = spark.read.format('libsvm')\\\n",
102103
" .option('numFeatures', '784')\\\n",

0 commit comments

Comments
 (0)