在阅读了本文档之后，我知道我可以发送一个POST请求，以便从一个保存点启动一个Flink作业。问题是:这个REST接口托管在JobManager中，只有当有一个作业已经在那里运行时，它才是活动的(我在本地的JVM中运行这个作业)。
浏览 7提问于2017-06-10得票数 0
1回答
我使用Flink1.8 for java来执行有状态计算。我的状态存储在RocksDB中。我可以确定每个运算符维护的状态的大小吗？
浏览 30提问于2021-10-21得票数 0
回答已采纳
1回答
目前，我有一个流作业，当它接收到特定的触发器时，它会触发批处理作业。 我想跟踪启动的批处理作业，当它完成时，想要在数据库中插入一个条目，比如elastic search之类的。 有什么想法，我们如何实现这一点？我们怎么才能听到那份工作？
浏览 142提问于2020-12-03得票数 0
我正在创建流分析应用程序使用火花，Flink和卡夫卡。每个分析/功能都将实现为Microservice，以便该分析可以在以后的不同项目中使用。我在简单的Scala应用程序中完美地运行了我的Spark/Flink作业，并分别在Spark & Flink集群上提交了这个作业。但是，当REST将startJob()请求调用到web服务时，我必须启动/运行此作业。
如何在面向web服务的应用程序中集成我的Spark & Flink数据处理功能？寻找正确的方向来实现这种
浏览 3提问于2017-04-25得票数 1
在SCALA代码中使用Kafka/FLink命令行-“命令”Starting Flink Server bin/sto
浏览 7提问于2017-10-09得票数 0
回答已采纳
:44) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
at org.apache.flink<
浏览 3提问于2021-02-08得票数 3
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
我想按需运行flink程序，提交它们去一个条件发生。如何在flink 1.3.0版本中从java代码运行flink作业？
浏览 5提问于2017-06-27得票数 0
回答已采纳
我看到了有关如何使用保存点的Flink文档。我希望有一个简单的解决方案来更新AWS EMR中的Flink作业。https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/deployment/aws.html https://ci.apache.org/projects/flink/flink
浏览 28提问于2020-06-11得票数 1
(JobID: 6095949ee689e308039dbc62da2bdf03) at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:820)
at org.apache.flink</
浏览 433提问于2019-10-13得票数 3
回答已采纳
在向Flink集群提交作业之前，我感兴趣的是在运行时获取Flink集群的TaskManagers和插槽的数量(我想根据集群参数优化一些程序参数)。
有人知道我应该调用哪些函数来获取这些参数吗？
浏览 0提问于2018-04-10得票数 0
回答已采纳
1回答
指标导出器
、、、
我知道我可以从Flink Dashboard中找到这个值，但我需要在Prometheus的一个Grafana板中包含所有的指标，希望这是可能的。我希望在Grafana中的flink dashboard中有类似的东西： ? 非常感谢!
浏览 10提问于2020-08-05得票数 0
'2018-12-17 19:11:46,148 INFO org.apache.flink.runtime.rest.RestClient:173)
at org.apache.flink.<em
浏览 0提问于2018-12-18得票数 2
Apache Flink 1.10.2的REST API中存在CVE-2020-17518漏洞。现在我想关闭REST API服务，我应该如何设置配置文件？
浏览 2提问于2021-01-14得票数 0
从Flink的官方文件中我们知道我们可以通过下面的命令“在纱线上运行一个Flink作业”，我的问题是我们是否可以通过Rest“在纱线上运行一个Flink作业”，并得到应用程序API？
./bin/flink run -m yarn-cluster -yn 2 ./examples/batch/WordCount.jar
浏览 1提问于2019-01-26得票数 0
获取以下flink作业提交错误， @centos1 flink-1.10.0]$ ./bin/flink run -m 10.0.2.4:8081 .: The main method caused an error: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerExceptionta
浏览 1218提问于2020-03-19得票数 0
回答已采纳
有没有办法限制对Apache Flink提供的REST API的访问，例如使用Basic Auth、Api-Key等？
我指的是“监控REST API”(令人困惑的不仅是监控，还包括作业控制)。
浏览 3提问于2017-10-16得票数 2
我正在尝试使用Rest请求在Flink群集上运行已部署的作业。我成功地使用了一个简单的rest客户端
POST http://localhost:8081/v1/jars/13775a71-0723-4c62-979b-7e9a9de3a0dc_some.jar/
浏览 1提问于2019-05-10得票数 0
是否可以在运行时更改flink框架的日志级别？什么时候flink集群已经在运行？我参考了下面的文件，没有提到它。https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/logging.html
浏览 267提问于2020-11-24得票数 0
1回答
我有几个要在AWS EMR上运行的长时间运行(流) flink作业。我从AWS控制台或使用aws cli阅读了执行此操作的步骤。但这是手动的。
浏览 28提问于2019-12-11得票数 1
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号