java - 構造化ストリーミングによる S3 チェックポイント

Question

私は Apache Spark (Structured Streaming) で与えられた提案を試しました: S3 チェックポイントのサポート

私はまだこの問題に直面しています。以下は私が得るエラーです

17/07/06 17:04:56 WARN FileSystem: "s3n" is a deprecated filesystem 
name. Use "hdfs://s3n/" instead.
Exception in thread "main" java.lang.IllegalArgumentException: 
java.net.UnknownHostException: s3n

コードの一部としてこのようなものがあります

SparkSession spark = SparkSession
    .builder()
    .master("local[*]")
    .config("spark.hadoop.fs.defaultFS","s3")
    .config("spark.hadoop.fs.s3.impl", "org.apache.hadoop.fs.s3native.NativeS3FileSystem")
    .config("spark.hadoop.fs.s3n.awsAccessKeyId","<my-key>")
    .config("spark.hadoop.fs.s3n.awsSecretAccessKey","<my-secret-key>")
    .appName("My Spark App")
    .getOrCreate();

そして、チェックポイントディレクトリは次のように使用されています:

StreamingQuery line = topicValue.writeStream()
   .option("checkpointLocation","s3n://<my-bucket>/checkpointLocation/")

どんな助けでも大歓迎です。前もって感謝します！