我是新的Flink，并试图创建一个原型，可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询)，但与第二个部分斗争。有可以使用的SQL。我已经看到了Flink木星笔记本集成，这告诉我，这应该工作的方式从一个网页界面。但是，不知道如何做到这一点，每次都不提交一个完整的JAR。见和
对我们还能探索什么有什么建议吗？
浏览 12提问于2022-01-15得票数 0
回答已采纳
在每一开始，我们都试图了解流入DB和Flink之间的数据传输过程。我们的基本思想是: Flink读取来自influxDB的数据，Flink利用这些数据进行一些基于Flink的ML库的建模。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Flink发送到InfluxDB (例如Flink InfluxDB连接器)。因此，如果你知道一些好的例子，如我所描述的，请告诉我。
浏览 0提问于2019-12-12得票数 1
回答已采纳
2回答
在使用Scala代码将数据从输出NiFi端口传输到Flink方面，我需要一些帮助。import org.apache.flink.streaming.connectors.nifi.NiFiSourceimport org.apache.flink.streaming.api.functions.sourc
浏览 0提问于2017-07-17得票数 0
回答已采纳
我有一台Flink服务器运行在一台计算机上。我想创建一个java web应用程序，它可以部署SQL(源代码创建SQL.，Sink创建SQL.)。但我的问题是
如何使用Table . flink-table-common-1.15.2.jar) 对远程Flink服务器执行上述SQL，应用程序将显示缺少jars的错误，这些jars已在flink的/时，它的工作原理是StreamExecutionEnvironment remoteStreamEnvironment = RemoteStreamEnv
浏览 3提问于2022-10-14得票数 0
虽然Flink网站上的所有文档都没有提到“外部状态”，但我们在一篇论文中遇到了这个概念(http://www.vldb.org/pvldb/vol10/p1718-carbone.pdf 4.1节)。
浏览 26提问于2020-09-03得票数 0
回答已采纳
当我试图在AvroParquetWriter中设置RollingSink时，我遇到了一个问题，接收器路径和写入路径似乎有冲突
INFO JobManager - Status of job af0880ede809e0d699eb69eb385ca204 (Flink(AbstractFetcher.java:225)
at org.apache.flink.streaming.con
浏览 2提问于2016-12-14得票数 2
我正在寻找一个可视化的编程工具，以抽象化的代码，当创建数据流流，以建立在Flink或束-Flink中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。
有人知道这样的计划吗？
浏览 5提问于2017-04-30得票数 4
回答已采纳
我试图从JMX控制台看到JMX记者的flink指标。步骤：
我已经安装了Apache通过自制，别名fstart和fstop启动/停止Flink。基于这个JMX记者linkhttps://ci.apache.org/projects/flink/flink-docs-release-1.4/monitoring/metrics.html#jmx-orgapacheflinkmetricsjmxjmxreporter](])，，我在fl
浏览 3提问于2018-05-26得票数 1
回答已采纳
我正在用简单的玩具例子学习Flink。/bin/flink run /path/to/target/myflinkapp-1.0-SNAPSHOT.jar --input data.txt --output /tmp/out --window
浏览 15提问于2020-09-15得票数 0
回答已采纳
1回答
;import org.apache.flink.api.java.tuple.Tuple2;import org.apache.flink.streaming.api.datastream.KeyedStream;
import org.apache.flink.str
浏览 1提问于2016-12-29得票数 0
回答已采纳
Dataproc是一种完全托管且高度可扩展的服务，用于运行Apache Spark、Apache Flink、Presto和30+开源工具和框架。
浏览 34提问于2021-10-01得票数 3
回答已采纳
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
2回答
我正在使用Flink v.1.4.0。
我希望能够命名Flink UI中的操作符。我明白，要做到这一点，我所需要的只是在DataSet或DataStream上使用DataSet方法。我之所以问这个问题，是因为我想了解如何使Flink DAG处于Flink UI中，例如，我可以命名每个转换吗？
浏览 1提问于2018-03-02得票数 3
回答已采纳
我遵循创建集群，但不清楚如何向集群提供？例如，我想指定jobmanager.heap.size=2048m。
浏览 0提问于2019-08-13得票数 2
回答已采纳
它的工作原理与Opencascade提供的类似。你可以在上看到它。
我们不对我们平台的使用收费，如果有开源选项，我们会更喜欢它(Opencascade查看器不是开源的)。
浏览 4提问于2020-05-18得票数 1
我正在尝试运行一个用Scala编写的大型开源项目。我正在使用3个docker图像运行它。 docker-compose文件是here。version: '2' streammachine: - "EXECUTION_TYPE=flink-cluster"- "FLINK_JOBMGR_HOST=jobmanager"
- "FLINK_JOBMGR_PORT=8081&qu
浏览 12提问于2019-08-26得票数 3
回答已采纳
1回答
上下文：我们使用动态分析来处理我们的传感器数据并发现传感器数据中的异常。以下方法已经在中尝试过，但没有成功：CREATE OR REPLACE PUMP "STREAM_PUMP_ALERT_DOSCONNECTION" AS INSERT INTO "INTERMEDIATE_SQL_STREAM" SELECT STREAM "deviceID" as "device_key", c
浏览 13提问于2022-03-14得票数 1
2回答
我学习apache，但无法为它设置scala。我使用的是ubuntu16os，我已经浏览了谷歌搜索的每一页。似乎每个人都在使用java，而不是scala。我该怎么做？提前感谢
浏览 0提问于2018-12-09得票数 0
回答已采纳
我试图使用Table在Flink应用程序中利用s3a文件系统。我在EMR6.1(预装有Flink 1.11.0)。org.apache.flink.core.fs.UnsupportedFileSystemSchemeException
指示s3://或s3a:// URI都不支持任何文件系统似乎flink run命令没有遵守EMR预先配置的hadoop类路径。
浏览 2提问于2021-09-01得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号