尝试使用上传的jar启动新作业时出现Flink REST API POST错误
Flink是一个流式处理框架，它提供了REST API来管理和监控作业。当尝试使用上传的jar启动新作业时出现Flink REST API POST错误，可能有以下几个原因和解决方法：
- 作业jar包错误：请确保上传的jar包是正确的，并且包含了需要执行的作业代码和依赖项。可以通过本地运行jar包来验证其正确性。
- Flink REST API配置错误：请检查Flink集群的配置文件，确保REST API相关的配置项正确设置。具体的配置项包括
rest.port（REST API的端口号，默认为8081）和rest.address（REST API的绑定地址，默认为0.0.0.0）。 - 作业提交参数错误：在使用REST API提交作业时，需要提供一些必要的参数，如作业名称、作业入口类、作业参数等。请确保这些参数的正确性，并按照Flink的API文档进行正确的POST请求。
- 作业依赖项缺失：如果作业代码中引用了外部的依赖项，如第三方库或其他模块，需要确保这些依赖项在Flink集群中可用。可以通过将这些依赖项打包到作业jar包中或者在集群中配置相应的依赖项路径来解决。
- Flink版本兼容性问题：如果使用的Flink版本与上传的作业jar包不兼容，可能会导致POST错误。请确保Flink版本与作业jar包版本匹配，并且查看Flink的官方文档以获取更多关于版本兼容性的信息。
总结起来，当尝试使用上传的jar启动新作业时出现Flink REST API POST错误，需要检查作业jar包的正确性、Flink REST API的配置、作业提交参数的准确性、作业依赖项的可用性以及Flink版本的兼容性。根据具体情况进行排查和解决问题。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云Flink产品页：https://cloud.tencent.com/product/flink
- 腾讯云云服务器CVM产品页：https://cloud.tencent.com/product/cvm
- 腾讯云对象存储COS产品页：https://cloud.tencent.com/product/cos
- 腾讯云数据库TencentDB产品页：https://cloud.tencent.com/product/tencentdb
- 腾讯云人工智能AI产品页：https://cloud.tencent.com/product/ai
相关·内容
在读取此之后，我正在尝试访问端点以启动一个Flink作业，如下所示-{, "true"]' http://<JobManager-hostname>:<port>/ja
浏览 28提问于2019-11-13得票数 1
回答已采纳
1回答
我试图使用Flink REST通过管道自动化Flink作业提交过程。要调用任何Flink Rest端点，我们应该了解接口IP。对于我的POC，在CLI上运行flink-session命令之后，我得到了IP，但是从代码中获得它的方法是什么呢？
r
浏览 9提问于2022-10-12得票数 0
我很难在CI/CD工作流中自动部署新的Flink作业，方法是使用Flink rest(可以找到)。文档只指出jar上传可以通过使用/jars/upload来实现，而不是如何构建有效的rest请求(哪个Headers、哪个Body类型、哪个Authorization、哪个Method等等)。因此，我查看了flink/f
浏览 9提问于2017-01-18得票数 5
回答已采纳
我已经在AWS ECS中部署了自己的flink设置。一个服务用于JobManager，一个服务用于任务管理器。我正在为作业管理器运行一个ECS任务，为任务经理运行3个ecs任务。我有一种批处理作业，我每天都使用flink rest上传新参数，当我每次提交磁盘内存增加600 S3时，我给出了一个检查点作为S3。因为我在ECS上运行，所以在每次jar上传和执行时都找不到内存增加
浏览 2提问于2021-03-29得票数 1
我试图向Kubernetes集群上运行的Flink作业管理器发送post请求。在为不需要任何命令行参数的类发送/jar/run的post请求时，它工作得很好。但是，当尝试在同一个jar中提交一个不同的类(需要命令行参数)时，会出现以下错误。然而，在传递命令行参数和直接提交作业时</e
浏览 134提问于2020-07-06得票数 0
我是新的flink用户，我有以下问题。使用flink将从关系数据库中提取的相关数据传输到HBase中。=$FLINK_HOME/conf当我从命令行手动启动这个脚本时，它工作正常--作业一个接一个地提交给纱线会话，为了这个目的，我用
Runtim
浏览 1提问于2018-01-16得票数 7
回答已采纳
在独立kubernetes模式(会话集群)中部署flink之后，我无法使用flink GUI上传任何新作业。在单击+Add New按钮并选择jar file之后，进度条结束，不会发生任何事情。作业管理器日志中没有关于此问题的信息/错误。当我尝试上传任何文件时(例如，文本文件)我收到一个错误，日志中有一条信息： "Exception occure
浏览 31提问于2021-09-01得票数 0
回答已采纳
我在K8s中使用Flink。一切正常，但是当jobmanager启动时，我必须手动提交jar。在这种情况下，如果JM关闭，K8s将启动新的pod并重新提交作业。
我说的对吗？有
浏览 46提问于2018-07-27得票数 0
回答已采纳
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
我正在尝试使用Rest请求在Flink群集上运行已部署的作业。我成功地使用了一个简单的rest客户端
POST http://localhost:8081/v1/jars/13775a71-0723-4c62-979b-7e9a9de3a0dc_some.jar/run { "programArgsList" :
浏览 1提问于2019-05-10得票数 0
我们通过cli成功地启动了工作，例如：此外，我们可以成功地通过api运行此作业，如果我们注册了fatjar，json如下所示："entryClass": "ru.test.TestApps",
&
浏览 2提问于2019-12-19得票数 0
2回答
我正在尝试按照documentation在Java 1.8.3中设置一个总体并行度设置 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment我还可以在flink UI中看到应用了环境设置(长时间运行的会话集群、通过rest API或Flink UI提交的作业)： ? 但是，当我查看各个阶段在Flink UI中运行<e
浏览 44提问于2020-07-08得票数 0
回答已采纳
我通过以下方式启动了Flink数据流作业 val env = StreamExecutionEnvironment.getExecutionEnvironmentenv.execute() 我想控制与任务管理器编号相关的env或任何解决方法来设置与任务管理器编号相关的并行度？
浏览 32提问于2021-06-17得票数 0
回答已采纳
我正在尝试恢复作业，并在作业管理器关闭而我无法成功重新启动作业时进行状态。我想知道是否有一种方法可以在没有zookeeper的情况下恢复作业管理器？当所有作业管理器都宕机时，flink是否能够恢复？当我重新启动作业管理器时，我得到了以下异常：org.apach
浏览 16提问于2018-09-07得票数 1
回答已采纳
下面是我在Flink中上传Jar的代码片段。我得到404回复这个帖子的要求。以下是请求的输出。我还尝试用/v1/jars/upload更新url，但响应相同。所有与jars相关的API都给了我相同的响应。我正在AWS中运行这段代码，它存在于EMR存在的同一个vpc中，运行我的Flink作业。像/config
浏览 5提问于2022-05-08得票数 0
正在尝试运行flink站点上的SocketWindowWordCount示例教程。我启动了flink集群，然后运行本地套接字服务器：在编译取自的示例源代码之后，我运行该作业然后，我向运行nc的终端输入一些单词。任何内容都不会写入预期的输出文件，并且日志中重复
浏览 130提问于2019-07-10得票数 5
回答已采纳
出于各种原因，我试图在构建Flink的github主分支之后运行下面的简单代码。下面是一个例外，我想知道在端口9065上运行的是什么？以及如何修正这个异常？at org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$18(RestClusterClient.java:java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFutu
浏览 0提问于2018-02-26得票数 1
回答已采纳
我使用EMR5.30.0并尝试使用以下命令提交Flink (1.10.0)作业我得到了以下错误在遍历了工人节点上的日志和作业管理器日志之后，似乎出现了端口冲突。)，建议的解决方案是在Flink配置文件中为<
浏览 4提问于2020-06-17得票数 1
我已经通过curl将一个jar (它是通过word程序生成的)通过HTTP请求上传到Apache Flink web控制台，get显示了上传的jar。当我尝试使用该jar提交作业时，它会抛出以下错误：
由: org.apache.flink.client.program.ProgramInvocationException: JAR</
浏览 2提问于2018-01-17得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
