1回答
目前，我有一个流作业，当它接收到特定的触发器时，它会触发批处理作业。 我想跟踪启动的批处理作业，当它完成时，想要在数据库中插入一个条目，比如elastic search之类的。有什么想法，我们如何实现这一点？我们怎么才能听到那份工作？
浏览 142提问于2020-12-03得票数 0
我正在尝试通过flink作业的名称来监控它们的状态。 但是我没有发现任何rest api可以从这个site返回作业名称。 我怎么才能得到它呢？
浏览 23提问于2019-03-12得票数 1
回答已采纳
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
1回答
我试图使用Flink REST通过管道自动化Flink作业提交过程。要调用任何Flink Rest端点，我们应该了解接口IP。对于我的POC，在CLI上运行flink-session命令之后，我得到了IP，但是从代码中获得它的方法是什么呢？
requests.p
浏览 9提问于2022-10-12得票数 0
1.如何获得正确的任务管理器来查询状态，而不是查询所有的任务管理器。(KvstateLocation )是否有人提供无法在文档中找到它的示例代码。如何使用作业名称获得作业十六进制字符串。
Flink 1.6.0
浏览 0提问于2019-01-17得票数 0
回答已采纳
从Flink的官方文件中我们知道我们可以通过下面的命令“在纱线上运行一个Flink作业”，我的问题是我们是否可以通过Rest“在纱线上运行一个Flink作业”，并得到应用程序API？
./bin/flink run -m yarn-cluster -yn 2 ./examples/batch/WordCount.jar
浏览 1提问于2019-01-26得票数 0
我找不到关于如何安全更新代码的说明。我看到了有关如何使用保存点的Flink文档。我希望有一个简单的解决方案来更新AWS EMR中的Flink作业。https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/deployment/aws.html https://ci.apache.org/pro
浏览 28提问于2020-06-11得票数 1
在Flink v-1.4中，有一个rest api来获取所有已完成/已完成的作业： /joboverview/已完成 正如我所看到的，在v-1.6中没有这样的api，我如何才能只获得已完成/已完成的作业
浏览 22提问于2019-01-25得票数 0
1回答
我有几个要在AWS EMR上运行的长时间运行(流) flink作业。我从AWS控制台或使用aws cli阅读了执行此操作的步骤。但这是手动的。在生产环境中(在生产环境中，我可以有多个作业，可能还需要处理故障情况)，有哪些方法可以实现自动化？
浏览 28提问于2019-12-11得票数 1
我正在创建流分析应用程序使用火花，Flink和卡夫卡。每个分析/功能都将实现为Microservice，以便该分析可以在以后的不同项目中使用。我在简单的Scala应用程序中完美地运行了我的Spark/Flink作业，并分别在Spark & Flink集群上提交了这个作业。但是，当REST将startJob()请求调用到web服务时，我必须启动/运行此作业。
如何在面向web服务的应用程序中集成我的Spark &am
浏览 3提问于2017-04-25得票数 1
我试图为Flink实现一个Rest客户端，通过Restful服务发送作业。我也想把Flink和Kubernetes结合起来。根据Flink文档，我决定使用“应用程序模式”作为部署模式。我已经实现了一个作业，并将其打包为jar。我已经在独立的Flink上测试过了。但是我的目标是通过Flink的Rest在应用程序模式下继续使用Kubernetes并部署我的应用程序。对于应用程序模式，在提交作业<
浏览 10提问于2022-04-04得票数 0
我正在尝试使用Rest请求在Flink群集上运行已部署的作业。我成功地使用了一个简单的rest客户端
POST http://localhost:8081/v1/jars/13775a71-0723-4c62-979b-7e9a9de3a0dc_some.jar/无法使用此客户端运行已部署的作业。我说的对吗？
浏览 1提问于2019-05-10得票数 0
我想了解LocalExecutionEnvironment的局限性，以及它是否可以在生产中运行？ 感谢任何帮助/洞察力。谢谢
浏览 26提问于2019-12-24得票数 1
回答已采纳
3回答
我有一个Java应用程序午餐，一个flink作业来处理Kafka流。在flinkEnv.execute("flink job name")提交作业时，应用程序在这里挂起，因为作业将永远运行，以获取从kafka传入的流。
如何从Java远程服务器取消给定
浏览 3提问于2016-09-16得票数 0
1回答
指标导出器
、、、
我知道我可以从Flink Dashboard中找到这个值，但我需要在Prometheus的一个Grafana板中包含所有的指标，希望这是可能的。我希望在Grafana中的flink dashboard中有类似的东西： ? 非常感谢!
浏览 10提问于2020-08-05得票数 0
我想按需运行flink程序，提交它们去一个条件发生。如何在flink 1.3.0版本中从java代码运行flink作业？
浏览 5提问于2017-06-27得票数 0
回答已采纳
2回答
我还可以在flink UI中看到应用了环境设置(长时间运行的会话集群、通过rest API或Flink UI提交的作业)： ? 但是，当我查看各个阶段在Flink UI中运行的并行度时，它们都是以并行度1运行的(源和宿除外，它们都是以预期的并行度设置运行的)： ?
浏览 44提问于2020-07-08得票数 0
回答已采纳
在SCALA代码中使用Kafka/FLink命令行-“命令”Starting Flink Server
Stopping Flink</
浏览 7提问于2017-10-09得票数 0
回答已采纳
我正在尝试将我们的工作从flink 1.4.2升级到1.7.1，但是在提交作业后，我一直遇到超时。flink作业在我们的hadoop集群上运行(版本2.7)和Yarn。INFO at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:258)
INFO at org.apache.flink.client.program.Cluste
浏览 1提问于2019-02-19得票数 1
回答已采纳
我通过以下方式启动了Flink数据流作业 val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setParallelism
浏览 32提问于2021-06-17得票数 0
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
