在读取此之后，我正在尝试访问端点以启动一个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
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
