1回答
Google Cloud Dataproc支持的OSS
google-cloud-platform、apache-flink、google-cloud-dataproc、dataproc
Dataproc是一种完全托管且高度可扩展的服务，用于运行Apache Spark、Apache Flink、Presto和30+开源工具和框架。
浏览 34提问于2021-10-01得票数 3
回答已采纳
2回答
是否有像Nifi或流集数据收集器这样的可视化编程环境用于flink或beam？
apache-flink、apache-beam、visual-programming
我正在寻找一个可视化的编程工具，以抽象化的代码，当创建数据流流，以建立在Flink或束-Flink中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。
有人知道这样的计划吗？
浏览 5提问于2017-04-30得票数 4
回答已采纳
2回答
有没有一种使用SQL查询正在运行的Flink作业的方法
apache-flink、flink-streaming、flink-sql
我是新的Flink，并试图创建一个原型，可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询)，但与第二个部分斗争。有可以使用的SQL。我已经看到了Flink木星笔记本集成，这告诉我，这应该工作的方式从一个网页界面。但是，不知道如何做到这一点，每次都不提交一个完整的JAR。见和
对我们还能探索什么有什么建议吗？
浏览 12提问于2022-01-15得票数 0
回答已采纳
3回答
是否有一些好的开源连接器可以实现从InfluxDB到Flink的数据传输？
apache-flink、influxdb、flink-streaming
在每一开始，我们都试图了解流入DB和Flink之间的数据传输过程。我们的基本思想是: Flink读取来自influxDB的数据，Flink利用这些数据进行一些基于Flink的ML库的建模。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Flink发送到InfluxDB (例如Flink InfluxDB连接器)。因此，如果你知道一些好的例子，如我所描述的，请告诉我。
浏览 0提问于2019-12-12得票数 1
回答已采纳
1回答
如何减少或禁用Flink中的检查点日志
java、apache-flink
我使用Flink 1.11.1，并以独立模式在Kubernetes上运行，hdfs用于存储和HA。现在，我尝试启用Flink检查点功能。例子如下：2020-10-08 19:54:23,237 [INFO] org.apache.flink.runtime.checkpoint.CheckpointCoordinator@ 1602186863226 for job fbf26a33a6d5d235085d10e7a10c1cab.
2020-10-08 19:54:42,818 [INFO] org.apache.
浏览 2提问于2020-10-08得票数 0
回答已采纳
2回答
链接到NiFi连接器
scala、apache-flink、apache-nifi
在使用Scala代码将数据从输出NiFi端口传输到Flink方面，我需要一些帮助。import org.apache.flink.streaming.connectors.nifi.NiFiSourceimport org.apache.flink.streaming.api.functions.sourc
浏览 0提问于2017-07-17得票数 0
回答已采纳
2回答
为Apache提交作业时Amazon使用Hadoop可恢复的Flink获取错误
amazon-s3、apache-flink、hadoop2
Added Depedency Pom Details :
<dependency> <artifactId>flink-clients_2.11</artifactId> <
浏览 0提问于2019-04-04得票数 2
回答已采纳
1回答
基于NAT的Flink任务管理器
apache-flink、nat
我正在尝试通过NAT运行Flink集群，其中通告的端口将不同于绑定端口。 在Flink中有对此的支持吗？ 我查看了配置和源代码，但没有注意到支持NAT的任何提示。如果没有，推荐的实现方法是什么？
浏览 23提问于2020-01-26得票数 0
回答已采纳
1回答
flink中的“外部状态”是什么？
apache-flink、flink-streaming
虽然Flink网站上的所有文档都没有提到“外部状态”，但我们在一篇论文中遇到了这个概念(http://www.vldb.org/pvldb/vol10/p1718-carbone.pdf 4.1节)。
浏览 26提问于2020-09-03得票数 0
回答已采纳
1回答
嵌入式Flink实例的JobManager在哪里？
apache-flink、flink-streaming
我使用Flink (通过Kafka)在服务之间传输消息。Flink嵌入在Java应用程序中，每个应用程序都在单独的docker容器中运行。这是我第一次尝试Flink，在看完文档后，我仍然觉得我遗漏了一些基本的东西。JobManager在哪里运行？谢谢,
摩西
浏览 1提问于2017-03-29得票数 0
1回答
获取作业名称或作业id的Flink日志记录
apache-flink
我正在尝试设置logback.xml，以便它包含与日志记录相关联的JobName或JobId。最终，我想要实现的是能够将日志发送到ElasticSearch，并将JobName或Id与消息标记在一起，这样我就能够按任务进行筛选。
浏览 7提问于2017-06-15得票数 3
2回答
光束+闪烁:使用SDFBoundedSourceReader时没有并行性
apache-flink、apache-beam、tfx
背景:我正在使用TFX管道，并使用Flink作为光束的运行器(使用flink-on-K8s-operator的flink会话集群)。Flink集群有2个任务管理器，每个任务管理器有16个核心，并行度设置为32。TFX组件调用beam.io.ReadFromTFRecord来加载数据，传入一个glob文件模式。当我尝试运行该组件时，对所有160个文件的处理在Flink中的单个子任务中结束，即并行度实际上为1。如下图所示： ? ? 我尝试了所有的波束/闪烁
浏览 18提问于2021-09-20得票数 0
回答已采纳
1回答
每次运行Flink作业时都会有多个“k8s-ha-app1-jobmanager”配置映射
kubernetes、apache-flink、high-availability
我有一个Flink 会话 集群在Kubernetes之上，最近我从基于ZK的HA切换到Kubernetes HA。通读 https://cwiki.apache.org/confluence/display/FLINK/FLIP-144%3A+Native+Kubernetes+HA+for+Flink#FLIP144:NativeKubernetesHAforFlink-LeaderElection 我可以在Flink名称空间上观察到上述文档中描述的每个资源的
浏览 38提问于2021-02-12得票数 0
回答已采纳
1回答
Kubernetes和Native Kubernetes上的Flink部署有何不同
kubernetes、apache-flink、flink-streaming
我是Kubernetes的新手，并试图了解Flink在它们上的部署有何不同。如果对内部结构有任何了解，这将是非常有帮助的。
浏览 53提问于2020-08-06得票数 3
回答已采纳
2回答
在代码中访问Flink的系统度量到终端，而不是使用像JMX这样的度量报告
apache-flink、flink-streaming、flink-cep
我曾经使用JMX作为度量报告来获取Flink指标，但是有什么方法可以在终端中将其作为输出吗？
这是我的Flink程序的执行计划，我有多个问题，但我想问一个基本问题
如何度量输出吞吐量？目前，我已经在select函数中编写了一些代码，用于计数所见的复杂事件和时间Fl
浏览 2提问于2017-10-22得票数 0
1回答
Flink安装Maven构建失败flink-运行时-web
windows、maven、github、apache-flink
-仪表板@2.0.0~preci检查:flink-仪表板@2.0.07详细的生命周期flink-仪表板@Windows\System32\WindowsPowerShell\v1.0;C:\Windows\System32\OpenSSH;C:\Program文件(x86)\Intel\Intel(R)管理引擎组件\DAL；C：\Program\Intel\Intel(R)管理引擎组件\DA
浏览 19提问于2022-01-17得票数 0
1回答
Akka与Flink TaskManager的关系
akka、apache-flink
我刚在本地电脑上安装了Flink，并提交了一份Flink作业。在Flink web UI TaskManagers菜单中，我可以看到path, id是"akka://flink/user/taskmanager“
我想知道这意味着什么。
浏览 1提问于2018-06-14得票数 0
回答已采纳
1回答
使用Kafka Connect和Flink的实时流数据管道
apache-flink、apache-kafka-connect
IBM MQ -> Kafka连接-> Flink -> MongoDBIBM MQ部件是不能更改的遗留组件。可能会使用confluent或cloudera平台来容纳流程中的Kafka和Flink部分。
我可以使用一些关于上述方法的想法/建议。
浏览 2提问于2019-02-23得票数 0
2回答
工作流引擎和事件流框架是编排层的替代方案吗？
architecture、workflow、system-design、event-driven-design
要求该层具有灵活性，以便可以快速实现不同类型文档的不同流另一种思考方式是--工作流。
浏览 7提问于2019-10-23得票数 3
1回答
使用RocksDB的Flink状态
apache-flink、flink-streaming
在Flink作业中使用RocksDB存储操作符状态检查点与使用RocksDB作为缓存(而不是Redis之类的缓存)有什么区别？我需要将处理过的数据从Flink作业存储到缓存24小时，并根据这些数据在流作业中执行一些计算。数据必须在24小时后删除。RocksDB可以用于这个目的吗？
浏览 8提问于2022-01-28得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号