【问题标题】:Where can I find my jar on Apache Flink server which I submitted using Apache Flink dashboard我在哪里可以找到我使用 Apache Flink 仪表板提交的 Apache Flink 服务器上的 jar
【发布时间】:2018-08-20 18:29:02
【问题描述】:

我开发了一个 Flink 作业并使用 Apache Flink 仪表板提交了我的作业。据我了解,当我提交作业时,我的 jar 应该在 Flink 服务器上可用。我试图找出我的罐子的路径,但无法。 Flink 是否将这些 jar 文件保存在服务器上?如果是,我在哪里可以找到?任何文件?请帮忙。谢谢!

【问题讨论】:

    标签: apache-flink


    【解决方案1】:

    JAR 文件在上传并存储在可以使用web.upload.dirconfiguration key 配置的目录中时会被重命名。

    如果未设置web.upload.dir参数,JAR文件将存储在jobmanager.web.tmpdir下的动态生成目录中(默认为System.getProperty("java.io.tmpdir"))。

    【讨论】:

    • 感谢 Fabian Hueske 帮助我!
    • 我的荣幸。如果它回答了您的问题,您可以接受答案。
    • 我查看了我的“jobmanager.web.tmpdir”目录并找到了我的 jar。尽管还有一个与此相关的问题。当我看到我的 Flink 仪表板时,我可以看到大约 10-12 个作业正在运行,但所有这些 jar 都不存在于“jobmanager.web.tmpdir”中。似乎当提交作业并从 Flink 仪表板中删除 jar 时,它也会从“jobmanager.web.tmpdir”目录中删除。我在哪里可以找到其他正在运行但从 Flink 仪表板中删除的 jar?
    • @Shailendra 在找到 Flink BlobServer 之前,我一直为同样的事情而烦恼。看起来 Flink 将 jar 存储在 System.getProperty("java.io.tmpdir") 下名为 blobStore-<hash> 的文件夹下,用于简单的本地设置。 jar 文件使用哈希重命名,不再以 .jar 结尾。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多