回答情况：
提问时间：
问题标签：
我们已经用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
回答已采纳
基本上，我希望将Flink自定义JAR文件部署到新的AWS EMR集群中。这是我所做的事情的总结。我创建了一个新的AWS EMR集群。一旦集群创建就绪，我就会SSHed到EC2机器，并尝试部署自定义jar文件。下面是我每次尝试通过CLI部署它时遇到的不同错误。Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
2018-10-09(Standa
浏览 0提问于2018-10-09得票数 0
回答已采纳
我已经创建了一个CICD进程来在flink服务器中部署我的flink应用程序。CD管道能够成功添加Jar，但无法提交jar。/flink-web-<someid>/flink-web-upload' 下面是完整的错误堆栈跟踪 2020-10-23 15:16:10,344 ERROR org.apache.flink.runtime.webmonitor.handlers.JarRunHand
浏览 163提问于2020-10-25得票数 0
我有一个Apache应用程序(使用Beam版本的EMR(emr-5.30.1) 2.23.0)，我试图在预装Flink(1.10.0)的AWS 上部署它。当我将应用程序部署到本地停靠flink集群上时，应用程序没有出现任何问题。(PackagedProgram.java:205)at org.apache</e
浏览 6提问于2020-10-03得票数 0
回答已采纳
我部署了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集群(Azure AKS)中部署Flink作业。作业群集在启动后立即中止，但任务管理器运行正常。 docker镜像创建成功，没有任何异常。- OS current user: flink2019-12-12 10<
浏览 79修改于2019-12-14得票数 2
我可以将流部署到Apache的独立安装(使用一个JobManager和多个TaskManagers)，没有问题： at org.apache.flink.client.CliFrontend.executeProgramDetached(CliFrontend.java:844)
at org.apache.flink.client.CliFront
浏览 7修改于2016-04-14得票数 1
回答已采纳
我尝试在本地部署的Flink Docker集群上部署一个Apache光束管道。(RemoteStreamEnvironment.java:178)org.apache.flink.streaming.api.environmen
浏览 80修改于2020-10-16得票数 1
在EMR上部署flink应用程序时出现此错误 at java.lang.Class.forName(Class.java:348)
at org.apache.hadoop.util.RunJar.r
浏览 2提问于2019-12-15得票数 0
当我们转到详细信息时，在UI中显示如下：Flink dashboard screenshot 作业中的日志显示以下内容： 2021-10-15 12:13:50,247 INFO org.apache.flink.runtime.jobmaster.JobMaster@3ae62e372021-10
浏览 449修改于2021-10-15得票数 1
回答已采纳
.2019-07-16 17:31:10,761 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint- 1.8/25.212-b04
2019-
浏览 0修改于2021-07-30得票数 0
但是，我目前正在尝试使用Flink on try (部署在Google上)来运行我的工作，当我试图取消它时，取消状态将永远持续，并且TaskManager中仍有一个插槽。这是我得到的日志：Attempting to cancelSink: TrackingDisplayPushErrorFlumeSink, Map -> Sink:
Tracking
浏览 4修改于2016-10-19得票数 2
回答已采纳
在本地环境中，它工作正常，但是当我在EMR集群上部署这个Flink应用程序时，它会抛出一个与兼容性问题相关的异常。at org.apache.flink.api.java.typeutils.TypeExtractor.createHadoopWritableTypeInfo(TypeExtractor.java:2025) at org.apache.flink.api.java.typeutils.TypeExtractor.privateGetForClass(Ty
浏览 0修改于2018-02-09得票数 3
回答已采纳
我有一个工作正常的嵌入式作业，我想部署更多的同地作业。这些新增的工作将收到来自旧工作的信息，并将其发送到kafka主题。:138) at org.apache.flink.client.cli.CliFrontend.run:895)
at org.apache.flink.client.
浏览 2提问于2020-05-03得票数 1
回答已采纳
我正在尝试将Flink stateful函数部署为flink jar，并遵循了here的说明。然而，我得到的错误是，即使我在pom中添加了依赖项，程序入口点类也没有在jar中找到。运行： bin/flink run -c org.apache.flink.statefun.flink.core.StatefulFunctionsJob flink-statefun/statefun-examplesorg.apache</e
浏览 237提问于2020-12-23得票数 2
我使用Kafka作为Flink job的数据源。当我将作业部署到flink集群作业管理器时，我收到一个错误ClassNotFoundException：Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSourcespring-boot-starter-test</artifactId>
浏览 489提问于2021-08-28得票数 0
回答已采纳
Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar2018-08-10/flink cancel 4c4f9564adc94cd38d
浏览 11提问于2018-08-10得票数 0
标题中都写道：诚挚的问候
浏览 1提问于2018-02-11得票数 1
1回答
当我更改状态的模式并重新部署应用程序时，我得到了以下异常at org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.tryRegisterStateTable(HeapKeyedStateBackend.java:142)
at org.
浏览 1提问于2018-03-10得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号