回答情况：
提问时间：
问题标签：
我可以将流部署到Apache的独立安装(使用一个JobManager和多个TaskManagers)，没有问题：从Flink仪表板部署对独立的HA集群很好。当我仅通过Flink CLI进行部署时，就会出现这样的问题。更新
我清除了动物园管理员，清除了Flink在磁盘上使用的目录，并重新部署了Flink独立的
浏览 7修改于2016-04-14得票数 1
回答已采纳
我目前正在开发一个Flink应用程序，它使用一些Hadoop依赖项将数据写入S3位置。在本地环境中，它工作正常，但是当我在EMR集群上部署这个Flink应用程序时，它会抛出一个与兼容性问题相关的异常。at org.apache.flink.api.java.typeutils.TypeExtractor.createHadoopWritableTypeInfo(TypeExtractor.java:2025) at org.apache.flin
浏览 0修改于2018-02-09得票数 3
回答已采纳
1回答
当我更改状态的模式并重新部署应用程序时，我得到了以下异常at org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.tryRegisterStateTable:128)
at org.apache.flink.
浏览 1提问于2018-03-10得票数 1
回答已采纳
我正在尝试向Kubernates中部署的ververica平台提交作业，但我收到了下面的消息，我向Flink standalone提交了相同的代码，它的工作正常！！Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.1.data-type=BIGINT schema.2.data-type=VARCHAR(255)
schema.
浏览 74修改于2020-07-12得票数 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
我正在flink集群上部署作业。此外，如果部署了作业并且S3 URL的类型为：提交成功。" %% "flink-scala" % "1.10.0" % "provided"
"org.apache.flink" %
浏览 5修改于2020-04-22得票数 0
基本上，我希望将Flink自定义JAR文件部署到新的AWS EMR集群中。这是我所做的事情的总结。我创建了一个新的AWS EMR集群。均为m3.xlarge型。
... 10 more
即
浏览 0提问于2018-10-09得票数 0
回答已采纳
我尝试在本地部署的Flink Docker集群上部署一个Apache光束管道。(RemoteStreamEnvironment.java:178)org.apache.flink.streaming.api.environmen
浏览 80修改于2020-10-16得票数 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
回答已采纳
是否可以使用Apache附带的BucketingSink将数据写入s3？当部署到EMR5.4.0而不是s3时，我可以写入hdfs。at org.ap
浏览 2修改于2017-04-11得票数 0
回答已采纳
在EMR上部署flink应用程序时出现此错误 at java.lang.Class.forName(Class.java:348)
at org.apache.hadoop.util.RunJar.r
浏览 2提问于2019-12-15得票数 0
我使用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
回答已采纳
我正在尝试为我的Flink程序部署一个生产集群。我使用的是一个安装了Flink 1.3.2的标准hadoop-core EMR集群，使用YARN来运行它。:350) at org.apache.flink.core.fs.Path.getFileSystem(Path.java:293)
at org.apach
浏览 1修改于2017-10-02得票数 1
我试图在集群上运行Flink作业。这项工作在我的开发(本地)环境上运行良好。但是，当我使用命令将它部署到集群上时： at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:785)
at org.apache.flink.client.cli.CliFrontend.runProgramorg.apache.flink.clien
浏览 1提问于2018-07-23得票数 1
回答已采纳
我有一个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
回答已采纳
$runJob$3(Dispatcher.java:415) ~[flink-dist_2.12-1.13.2.jar:1.13.2]2021-2-用于Kubernetes<em
浏览 54修改于2021-12-15得票数 0
回答已采纳
我正在使用Apache，并且在我的Flink任务节点上得到了这个错误。当我重新启动我的Flink节点并重新部署作业时，它运行得很好。当时这些经纪人似乎也很好。at org.apache.flink.api.common.functions.util.FunctionUtils.openFu
浏览 13修改于2020-02-20得票数 0
回答已采纳
(LocalDirAllocator.java:200) at org.apache.flink.fs.shaded.hadoop3.org.apac
浏览 44提问于2020-01-16得票数 0
我正在使用Kubernetes中的Flink操作符在应用模式下部署Apache集群，并且存在权限问题。我已经将Filestore实例挂载为ReadWriteMany卷。/f6dc4b42c99ac5d25f4be4771a9c6889/chk-1
at org.apache.flink.core.fs.local.LocalFileSystem.create(LocalFileSystem.java:262) ~[flink-dist_2.12-1.13.6.
浏览 2修改于2022-08-23得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号