回答情况：
提问时间：
问题标签：
基本上，我希望将Flink自定义JAR文件部署到新的AWS EMR集群中。这是我所做的事情的总结。我创建了一个新的AWS EMR集群。第4步:安全-提供了我的EC2密钥对。
一旦集群创建就绪，我就会SSHed到EC2机器，并尝试部署自定义jar文件。下面是我每次尝试通过CLI部署它时遇到的不同错误。SLF4J: Found binding in [jar:file:/usr/lib/flink/lib/slf<e
浏览 0提问于2018-10-09得票数 0
回答已采纳
我可以将流部署到Apache的独立安装(使用一个JobManager和多个TaskManagers)，没有问题：但是，当我运行相同的命令并部署到独立的HA集群时，这个命令会引发错误： at org.apache.flink</e
浏览 7修改于2016-04-14得票数 1
回答已采纳
我正在使用Kubernetes中的Flink操作符在应用模式下部署Apache集群，并且存在权限问题。我已经将Filestore实例挂载为ReadWriteMany卷。/f6dc4b42c99ac5d25f4be4771a9c6889/chk-1
at org.apache.flink.core.fs.local.LocalFileSystem.create(LocalFileSystem.java:262) ~[flink
浏览 2修改于2022-08-23得票数 0
我正在尝试向Kubernates中部署的ververica平台提交作业，但我收到了下面的消息，我向Flink standalone提交了相同的代码，它的工作正常！！Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.2.data-type=VARCHAR(255)schema.3.data-type=DATE
schema.3.
浏览 74修改于2020-07-12得票数 1
回答已采纳
当在本地运行时(从junit测试和minicluster)，它可以工作，但是当部署在k8s中时，它会抛出一个异常，说它找不到合适的驱动程序。_2.12-1.13.5-stream1.jar:/flink/lib/flink-table_2.12-1.13.5-stream1.jar:/flink/lib/log4j-1.2-api-2.16.0.jar:/flink/lib/log4</em
浏览 16修改于2022-05-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
我是flink的新手，我部署了我的flink应用程序，它基本上执行简单的模式匹配。它部署在库伯奈特斯集群，拥有1 JM和6 TM。我每10分钟发送一次4.4k和200k大小的消息，并执行负载测试。:136) at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext在
浏览 4修改于2020-12-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
回答已采纳
我正在尝试将Flink stateful函数部署为flink jar，并遵循了here的说明。然而，我得到的错误是，即使我在pom中添加了依赖项，程序入口点类也没有在jar中找到。运行： bin/flink run -c org.apache.flink.statefun.flink.core.StatefulFunctionsJob flink-statefun/statefun-examples: The program
浏览 237提问于2020-12-23得票数 2
在EMR上部署flink应用程序时出现此错误 at java.lang.Class.forName(Class.java:348)
at org.apache.hadoop.util.RunJar.r
浏览 2提问于2019-12-15得票数 0
docker镜像部署了一个flink集群。我登录到JobManager机器，找到上传的uber-jar，然后使用以下命令运行作业： flink run -c myapps.Test \ at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:798)
at org.apac
浏览 23修改于2019-01-10得票数 2
回答已采纳
我尝试使用LocalCollectionOutputFormat，它在本地工作，但是当我在集群上部署作业时，我得到了一个NullPointerException --这并不奇怪。GlobalConfiguration.includeConfiguration(configuration);
DataSource<Tuple4<readCsvFile(args[0])
.types(String.class, String.cla
浏览 3修改于2015-05-01得票数 4
回答已采纳
(ByteToMessageDecoder.java:389) ~[flink-dist_2.11-1.13.2.jar:1.13.2] at org.apache.flink.shaded.netty4(AbstractEvent
浏览 32修改于2022-02-22得票数 0
at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChanne
浏览 64提问于2020-05-03得票数 1
回答已采纳
]2021-12-11 21:55:14,001 DE
浏览 54修改于2021-12-15得票数 0
回答已采纳
我目前有一个运行在独立Kubernetes (v1.16)中的Flink (1.12)集群。出于我们的目的，我们采用了application cluster模式部署。为了测试，我将作业并行度设置为2(这将启动两个JobManagers，其中一个应该是备用的) 当尝试将其部署到K8时，JobManager pods会立即失败，并出现以下错误-除了似乎缺少了一些东西从而导致external address 100.107.0.5:6123, bind address 0.0.0.0:6123.
2021-08-20 12:06:56,956 I
浏览 77提问于2021-08-24得票数 0
在本地环境中，它工作正常，但是当我在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作为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
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号