是否存在用于导出描述flink群集服务状态的json文件的URL？
即系统正常运行时间、作业状态、节点数等。
浏览 10提问于2017-02-14得票数 0
回答已采纳
Flink Web UI有一个出色的背压部分。但我看不到任何指标，由普罗米修斯记者给出，可以用来检测背压的相同方式为Grafana仪表盘。 ?有没有办法在Flink Web UI之外获得相同的指标？使用此处描述的指标https://ci.apache.org/projects/flink/flink</
浏览 68提问于2019-03-13得票数 2
回答已采纳
1回答
目前，我有一个流作业，当它接收到特定的触发器时，它会触发批处理作业。 我想跟踪启动的批处理作业，当它完成时，想要在数据库中插入一个条目，比如elastic search之类的。有什么想法，我们如何实现这一点？我们怎么才能听到那份工作？
浏览 142提问于2020-12-03得票数 0
1回答
除了这个question之外，我还创建了这个示例来集成DataStreamAPI和TableAPI，这一次我没有出错，而且我有两个作业而不是一个，一个作业是为运行正常的DataStreamAPI创建的，另一个作业是为运行正常的TableAPI创建的，但唯一的问题是永远不会从DataStreamAPI收到任何值，示例： /*FILTERING NULL IDs*/ env.e
浏览 39提问于2020-09-08得票数 0
回答已采纳
我正在通过prometheus Flink metrics Reporter向Prometheus发送自定义应用程序指标。指标创建正确，因为我能够在flink仪表板中准确地看到它们。当我转向prometheus端点(curl http://localhost:9090/api/v1/metrics)时，我只能看到集群指标，而不能看到我正在创建的自定义指标。我怀疑这个问题与我如何配置Pr
浏览 45提问于2021-08-06得票数 2
2回答
我已经为在Intellij IDEA中运行的应用程序设置了Flink UI。我想获得一些流指标，如-调度延迟和处理时间。但是，我在UI中找不到anywhere。应该有一些具体的设置，或者我应该显式地提交app jar？ 目前，该作业的Flink UI如下所示： ?
浏览 25提问于2020-01-21得票数 0
回答已采纳
我在Yarn上运行Flink，我想收集一些指标来看看情况如何。我找到了一些关于如何配置Flink > Promehteues > Grafana组合的指南，但我注意到，目前没有任何定制，只是： metrics.reporter.prom.class: org.apache.flink.metrics.prometheus.PrometheusReporter
metrics.report
浏览 3提问于2021-05-13得票数 0
1回答
我有一个flink工作，在创建检查点时卡住了。它几乎没有状态(除了一些kafka偏移量)。从我的指标中可以看到，所有这些都发生了，我得到了一些5xx (返回迭代源代码)，一些4xx (忽略)和很多2xx (转发到HDFS)。:154)while (availableMemoryS
浏览 0提问于2020-05-19得票数 1
我在flink上做了一些poc，但我找不到关于如何在kafka流中实现类似于KGroupTable的用例的文档，如下所示我想从收到的交易中汇总账户余额的用例如果我得到现有事
浏览 5提问于2020-05-23得票数 0
我的Flink作业从一个kafka主题中读取数据，并将数据存储在RocksDB状态后端中，以便使用可查询状态。我能够在本地机器上运行作业并查询状态。:107)
at org.apache.flink.streaming.api.operators
浏览 6提问于2017-06-03得票数 0
回答已采纳
2回答
使用Flink同步的进程2流
、、、、
流A只在每分钟的59秒获得一条记录。 流B获取一分钟内的任何一秒的记录。 我希望处理两个流是同步的。这可以在Flink中实现吗？
浏览 49提问于2021-01-21得票数 0
在使用可查询客户端对状态进行查询时，我遇到了一个问题。JobID.fromHexString(jobId), queryableStateName, clusterId, BasicTypeInfo.STRING_TYPE_INFO, descriptor);java.util.concurrent.ExecutionException: org.apache.flink.util.FlinkRuntimeException: java.io.I
浏览 0提问于2018-04-11得票数 0
1回答
我正在运行以RocksDB作为我的状态后端的Apache的欺诈检测器示例。我想知道Apache需要多长时间来检查状态。 * limitations under the License.
package
浏览 1提问于2020-07-11得票数 1
回答已采纳
我有一个像这样的流：<_time(timestamp), uri(string), userId(int)>。:837) at org.apache.flink.table.api.StreamTableEnvironment.translate(St
浏览 1提问于2018-03-02得票数 1
我使用的是Flink v1.4.0，我已经设置了两个不同的作业。第一个是一个管道，它使用来自Kafka主题的数据并将其存储到可查询状态( Queryable State，QS)中。数据按日期进行键控。第二个任务向QS作业提交一个查询，并处理返回的数据。
这两份工作都与Flink v.1.3.2合作得很好。但是随着新的更新，一切都坏了。集群上启用可查询状态，方法是将flink
浏览 5提问于2018-01-15得票数 4
回答已采纳
我有两个流，一个是Int流，另一个是json .In，json，有一个键，就是一些int .So，我需要通过键比较来过滤json流和其他整数流，所以在Flink中可以吗？
浏览 1提问于2017-04-20得票数 2
回答已采纳
1回答
我使用的是Flink 1.12，我对何时可以执行表和数据集/数据集转换感到非常困惑。()import org.apache.flink.api.scala._import org.apache.flink.tabl
浏览 2提问于2021-05-02得票数 0
回答已采纳
我在1.1快照版本上使用Apache的Table来评估流上的SQL查询。at org.apache.flink.api.table.TableEnvironment$$anonfun$4.apply(TableEnvironment.scala:299)
浏览 1提问于2016-06-15得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号