回答情况：
提问时间：
问题标签：
我尝试在本地部署的Flink Docker集群上部署一个Apache光束管道。(RemoteStreamEnvironment.java:178)org.apache.flink.streaming.api.e
浏览 80修改于2020-10-16得票数 1
我试图在上运行一个简单的Apache管道。当我运行主类来部署管道时，我会得到一个奇怪的404错误。这条管道在上运行良好。我使用参数--runner=FlinkRunner, --flinkMaster=localhost:8081运行main，我可以在http://localhost:8081上看到Flink仪表板。部署失败的原因如下：
Unrecognised token 'failure': was expecting ('true', 'false
浏览 0修改于2018-09-14得票数 1
回答已采纳
Dockerfile如下：RUN chmod a+x /custom-docker-entrypoint.sh
COPY --chown=flink:flink --from=build /target/*.jar
浏览 8提问于2022-09-05得票数 1
回答已采纳
我刚刚将我的flink从1.9.1升级到1.11.2 (使用docker) --当我尝试升级到1.11.1并重新运行我的作业时，已经有许多flink作业在1.9.1版本中运行，它会显示错误。2020-11-12 06:49:17,731 WARN org.apache.zookeeper.ClientCnxn []
这是部署我的flink作业后的错误：
由:未
浏览 5修改于2020-11-12得票数 0
回答已采纳
我在docker中运行Flink。Exists Flink Plan Visualizer https://flink.apache.org/visualizer/我可以在本地使用平面可视化工具(当在docker中运行Flink时)？
浏览 15提问于2021-02-11得票数 0
回答已采纳
我正在使用Linux中的Docker运行一个带有单个节点的Flink独立集群。我已经在Flink 1.10.0和JDK8的生产环境中运行了一段时间的前一个版本，我能够让S3在那里正常运行。现在，我正在尝试更新到一个较新的版本，使用本地S3实现在我的开发机器上运行Docker。",
"org.apache.flink" % "flink-s3-fs-hadoop" % flinkVersion % "prov
浏览 65提问于2020-09-29得票数 1
docker镜像部署了一个flink集群。:404) at org.apache.flink.client.cli.CliFrontend.runProgramorg.apache.flink.client.cli.CliFrontend.parseParame
浏览 23修改于2019-01-10得票数 2
回答已采纳
我已经成功地使用可移植运行程序和作业服务成功地运行了Beam管道，该服务指向在Docker容器中运行的本地Flink服务器。我实现了在我的Flink容器中挂载Docker套接字，并将Flink作为根进程运行，因此类DockerEnvironmentFactory可以创建Python线束容器。不幸的是，当Flink在Kubernetes中运行时，我不能使用相同的解决方案。此外，我不想使用我的荚中的Docker命令创建Python工具容器。是否有一种方法可以部署</
浏览 0修改于2019-09-10得票数 3
我想在Apache上使用Apache运行Python代码。apache站点在Apache上启动Python代码的命令如下：下面讨论了在Apache上使用Apache执行代码的不同方法。我希望这个代码在没有Docker的情况下运行
浏览 6提问于2020-03-01得票数 0
docker run --net=host apache/beam_flink1.13_job_server:latestfrom apache_beam.io.kafka: Unable to pull docker image apache/beam_java8_sdk:2.31.0, cause: Cannot run program "docker": error:
浏览 1提问于2021-07-15得票数 1
我有Flink (任务经理和作业经理)和Kafka作为码头图像运行在我的mac上。org.apache.flink.runtime.JobException(SchedulerBase.java:679)
at org.apache.flink</em
浏览 1修改于2021-11-24得票数 1
回答已采纳
我部署了Flink kubernetes操作符，在为“Flink deployment”部署自定义资源时，我需要向部署规范中添加几个元数据标签，因为我们的组织有一个允许few钩子来验证自定义标签，如'app_id‘、'env’等，以便在部署对象中。CRD是https:/github.com/apache/flink-kubernetes-operator/blob/main/
浏览 23修改于2022-11-07得票数 0
我已经构建了Flink的快照版本，并希望将其部署到我的私有nexus存储库。/botech-common-snapshots/</url> </distributionManagement>未能执行项目力-阴影上的目标org.apache
浏览 0修改于2021-01-12得票数 0
在独立kubernetes模式(会话集群)中部署flink之后，我无法使用flink GUI上传任何新作业。在单击+Add New按钮并选择jar file之后，进度条结束，不会发生任何事情。我有一个全新的、干净的Apache Flink集群在Kubernetes集群上运行。我已经使用了docker集线器镜像，并且尝试了两个不同的版本： *1.13.2-scala_2.12-java8, and
1.13-scala_2.11-java8* 但两个版本的结果是相同的。我的部署</
浏览 31提问于2021-09-01得票数 0
回答已采纳
org.apache.flink.table.sources.CsvBatchTableSourceFactoryorg.apache.flink.table.filesystem.FileSy
浏览 14修改于2020-10-15得票数 1
org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2685)我猜想，为flinkCOPY Tools&
浏览 3提问于2019-11-21得票数 0
有没有一个地方我们可以快速参考和查看Apache beam和运行时环境(Flink，Spark等)之间的版本兼容性。我正在以一种艰难的方式学习它：我不确定我的问题有多少是由版本错误造成的。目前我使用的是光束2.4.0，看看flink runner pom ()，它使用的是flink 1.4.0 jars。所以我假设Apache beam 2.4.0可以与Apache Flink 1.4.0一起工作。这是正确的解释吗？
不幸的是，Flink 1.4.0
浏览 0提问于2018-06-14得票数 0
我可以将流部署到Apache的独立安装(使用一个JobManager和多个TaskManagers)，没有问题： at org.apache.flink.client.CliFrontend.executeProgramDetached(CliFrontend.java:844)
at org.apache.flink.client.CliFront
浏览 7修改于2016-04-14得票数 1
回答已采纳
我们已经用1.4版本部署了一个新的Flink实例。在尝试从旧的1.2.1部署恢复保存点时，尝试还原的所有作业都会出现相同的错误：
org.apache.flink.runtime.execution.SuppressRestartsException:at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanage
浏览 6提问于2018-01-04得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号