时间戳

首页 > 解决方案 > 我们如何将 HDFS Alpakka 默认路径 /tmp/alpakka 更改为其他子目录？在此路径上面临写权限问题

hdfs - 我们如何将 HDFS Alpakka 默认路径 /tmp/alpakka 更改为其他子目录？在此路径上面临写权限问题

问题描述

我们如何将 Alpakka 默认路径 /tmp/alpakka 更改为其他子目录？在此路径上面临写入权限问题。虽然我给 pathGenerator 提供了不同的路径，但它仍然使用 /tmp/alpakka，然后写入给定的路径。

val pathGen = FilePathGenerator{
        case (_, _) => s"$appendedPath/$filename"
      }
      val settings = HdfsWritingSettings().withPathGenerator(pathGen)

它跳过默认 /tmp/alpakka 并直接写入我的路径“$appendedPath/$filename”的任何方式

标签： hdfsstreamingalpakka

解决方案

推荐阅读