Tag: apache flink

Flink 1.2.1 – 当Flink在容器中运行时如何创build一个保存点？: 我有运行在Docker上的Flink 1.2.1，任务pipe理器作为Docker Swarm的一部分分布在不同的虚拟机上。我了解Flink中尚未提供Dynamic Scaling。因此，如果我想增加运行Flink的任务pipe理器的容器数量（向上扩展），我需要创build一个保存点，停止运行的作业，扩展我的任务pipe理器容器，然后恢复工作。我的问题是：如何创build一个保存点？该文档假定您正在使用命令行客户端，但我不认为我可以访问它，如果我在容器中运行Flink。 Web UI不允许您创build保存点。在这种情况下，我该怎么做？我正在使用官方Flink文档作为参考： https ： //ci.apache.org/projects/flink/flink-docs-release-1.2/setup/cli.html#savepoints 非常感谢您的帮助。

Docker Swarm上的Flink – 我需要检查Job Manager的IP地址来访问Web UI吗？: 在Docker Swarm集群中运行Flink JobManager和Flink TaskManager时，不能保证JobManager在任何特定的节点上运行。如果我想访问端口8080上的Web UI，是否需要找出哪台机器正在运行JobManager并转到http：// ip_address：8080 ？如果运行JobManager的节点改变了怎么办？看起来不像一个非常简单的工作方式。有没有办法强制容器化作业pipe理器在特定节点上运行？我目前正在使用Docker Swarm脚本创build服务： https ： //github.com/apache/flink/tree/master/flink-contrib/docker-flink 非常感谢你。

下载较新的图像为graphiteapp / graphite-statsd：最新: 我想要使用此处给出的步骤在docker上安装石墨 docker run -d\ –name graphite\ –restart=always\ -p 80:80\ -p 2003-2004:2003-2004\ -p 2023-2024:2023-2024\ -p 8125:8125/udp\ -p 8126:8126\ graphiteapp/graphite-statsd 这首先给了我下面的警告 Unable to find image 'graphiteapp/graphite-statsd:latest' locally latest: Pulling from graphiteapp/graphite-statsd 在完成所有的拉动之后，给了我下面的错误信息 Digest: sha256:3136b19fcdb9162c642cc1d2821172948346651a46b41ab63cc05c2962ea85c9 Status: Downloaded newer image for graphiteapp/graphite-statsd:latest 7af4b99efeb4bb7d0bc1ba1d8b4556d812adc87bc720c035998eeb54116e57f4 docker: Error response from daemon: driver failed programming external connectivity on endpoint graphite (de38efe3b7ee88976d044ffe9948839c8058b06408f46f9857e4e689d9883ce9): Error starting […]

在Docker磁盘上完全闪烁: 我在Docker中创build了一个非常小的集群（1个工作pipe理器3任务pipe理器）。我有2个工作（1stream和1批，当它完成时重新启动）。我有58G可用空间（大约30G使用）。当我启动聚合器时，工作经理开始吃光盘。一小时后，我的磁盘已满。但是当我检查FS（ du -su /*/ ）时，它只包含大约30G的文件。我不明白为什么会发生，数据在哪里。我试图检查jobmanager容器里面，但没有成功。任何想法？

Docker-Flink：在Docker Swarm的不同节点中，TaskManager无法findJobManager: 即使节点在同一子网中，也会发生这种情况。我正在使用Docker-Flink项目： https ： //github.com/apache/flink/tree/master/flink-contrib/docker-flink 我正在使用以下命令创build服务： docker network create -d overlay overlay docker service create –name jobmanager –env JOB_MANAGER_RPC_ADDRESS=jobmanager -p 8081:8081 –network overlay –constraint 'node.hostname == ubuntu-swarm-manager' flink jobmanager docker service create –name taskmanager –env JOB_MANAGER_RPC_ADDRESS=jobmanager –network overlay –constraint 'node.hostname != ubuntu-swarm-manager' flink taskmanager 这是我得到的错误： – Trying to register at JobManager akka.tcp://flink@jobmanager:6123/ user/jobmanager (attempt 4, […]