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
回答已采纳
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
回答已采纳
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 - zeppelin -无响应
apache-flink、apache-zeppelin
我无法在zepplin中运行flink (1.0.3)进程。它处于挂起状态，web ui未记录该过程:在群集模式和本地模式下都是如此。Flink本身在命令行和intellij中运行良好。
浏览 4提问于2016-08-01得票数 1
1回答
Flink是否可以处理其返回的键随时间变化的键选择器函数？
apache-flink
我不确定这是否会对Flink的状态或流分区机制造成问题。例如，如果一个输入Foo最初映射到分区键0，但后来更改为分区键1，并且键0不再使用，那么Flink会在某个时候简单地“忘记”键0吗？
浏览 18提问于2019-06-03得票数 0
1回答
DataSource输出的初始化导致了一个错误: UDF类不是正确的子类
scala、apache-flink
我有这个问题
i.macHash, 0, }你能帮帮我吗？
浏览 6提问于2018-01-12得票数 0
2回答
是否有像Nifi或流集数据收集器这样的可视化编程环境用于flink或beam？
apache-flink、apache-beam、visual-programming
我正在寻找一个可视化的编程工具，以抽象化的代码，当创建数据流流，以建立在Flink或束-Flink中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。
有人知道这样的计划吗？
浏览 5提问于2017-04-30得票数 4
回答已采纳
1回答
flink坞中的日志文件
docker、logging、apache-flink
我正在使用flink-1.4.0对接器，类似于：services: image: ${FLINK_DOCKER_IMAGE_NAME:-flink6123" - "8081:8081" volumes:
- /home/yeyunlong/work/flink/
浏览 0提问于2018-01-26得票数 0
回答已采纳
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回答
如何在Kubernetes中使用flink-s3-fs-hadoop
apache-flink
我在flink的文档中看到了下面的信息--将各自的jar复制到插件目录中以使用s3。如果我使用Kubernetes部署Flink，我怎么做？“要使用flink-s3-fs-hadoop或flink-s3-fs-presto，请在启动Flink之前将相应的JAR文件从opt目录复制到Flink发行版的plugins目录，例如
Mkdir./opt/flink-s3-fs-presto-1.9.0.jar./plugins&#
浏览 3提问于2019-10-01得票数 0
1回答
Apache用于后端状态和检查点使用S3
amazon-s3、apache-flink、flink-streaming、checkpoint、checkpointing
背景
org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: Could not find a file system implementationThe scheme is not directly supported by Flink and no Hadoop file system to support this scheme c
浏览 61提问于2020-10-06得票数 1
回答已采纳
2回答
工作流引擎和事件流框架是编排层的替代方案吗？
architecture、workflow、system-design、event-driven-design
要求该层具有灵活性，以便可以快速实现不同类型文档的不同流另一种思考方式是--工作流。
浏览 7提问于2019-10-23得票数 3
1回答
Flink savepoint与本地执行环境(如独立应用程序)
apache-flink、flink-streaming、flink-sql、flink-batch
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
1回答
如何在Apache flink中启动和停止flink scala-shell
apache-flink、scala-shell
如何在apache flink中启动和停止flink scala-shell 我已经使用命令/bin/start- scala -shell.sh local启动了flink scala shell。但是不知道怎么停下来？
浏览 50提问于2019-05-22得票数 0
1回答
K8S上的Flink :如何向集群提供Flink配置？
kubernetes、apache-flink
我遵循创建集群，但不清楚如何向集群提供？例如，我想指定jobmanager.heap.size=2048m。
浏览 0提问于2019-08-13得票数 2
回答已采纳
1回答
flink独立没有为grafana提供推送网关的度量标准
apache-flink、grafana、prometheus-pushgateway
我是flink的新手，在我的macbook上安装了yarn和flink，配备了M1 pro芯片。为了监视flink 1.13的运行，我安装了grafana、prometheus、pushgateway，就像我在互联网上看到的那样，所有的web看起来都很好。然后，我将flink-conf.yaml文件更改为，并将flink-metrics-prometheus-1.13.6.jar复制到lib文件夹。并使用stop-cluster.sh和start-cluster.sh重新启动flink。
浏览 10提问于2022-03-25得票数 -1
1回答
未找到"org.apache.flink.streaming.api.operators.MailboxExecutor“类
apache-flink、flink-streaming、flink-sql、apache-hudi
当我使用Hudi0.10.1和flink1.14.0时，我得到了一个异常“not org.apache.flink.streaming.api.operators.MailboxExecutor”“
我发现"MailboxExecutor“在一闪而过1.13.1，我怎么做呢？与flink 1.14的复杂？
浏览 10提问于2022-03-22得票数 0
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号