我正在使用AWS EMR 5.0,Spark 2.0,Scala 2.11,S3 - 使用KMS(SSE-custom key),Parquet文件加密。我可以讀取加密的地板文件 - 沒問題。但是,當我寫作時,我會收到警告。簡化的代碼如下所示:AWS EMR寫入KMS加密S3實木複合地板文件
val headerHistory = spark.read.parquet("s3://<my bucket>/header_1473640645")
headerHistory.write.parquet("s3://<my bucket>/temp/")
而是生成一個警告:
16/09/15 13點11分十一秒WARN S3V4AuthErrorRetryStrategy:嘗試重新發送請求到我的bucket.s3.amazonaws.com通過AWS V4認證。爲避免將來出現此警告,請使用特定於區域的端點來訪問位於需要V4簽名的區域中的存儲桶。
我需要一個選項嗎?我需要設置一些環境變量嗎?