我是新的Flink，并试图创建一个原型，可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询)，但与第二个部分斗争。有可以使用的SQL。我已经看到了Flink木星笔记本集成，这告诉我，这应该工作的方式从一个网页界面。但是，不知道如何做到这一点，每次都不提交一个完整的JAR。见和
对我们还能探索什么有什么建议吗？
浏览 12提问于2022-01-15得票数 0
回答已采纳
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网站上的所有文档都没有提到“外部状态”，但我们在一篇论文中遇到了这个概念(http://www.vldb.org/pvldb/vol10/p1718-carbone.pdf 4.1节)。
浏览 26提问于2020-09-03得票数 0
回答已采纳
我正在寻找一个可视化的编程工具，以抽象化的代码，当创建数据流流，以建立在Flink或束-Flink中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。
有人知道这样的计划吗？
浏览 5提问于2017-04-30得票数 4
回答已采纳
在每一开始，我们都试图了解流入DB和Flink之间的数据传输过程。我们的基本思想是: Flink读取来自influxDB的数据，Flink利用这些数据进行一些基于Flink的ML库的建模。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Flink发送到InfluxDB (例如Flink InfluxDB连接器)。因此，如果你知道一些好的例子，如我所描述的，请告诉我。
浏览 0提问于2019-12-12得票数 1
回答已采纳
我正在尝试运行一个用Scala编写的大型开源项目。我正在使用3个docker图像运行它。 docker-compose文件是here。- "FLINK_JOBMGR_HOST=jobmanager" - "FLINK_MONITORING_HOST=jobmanagerlinks: env
浏览 12提问于2019-08-26得票数 3
回答已采纳
摘要:找不到mapr依赖项，因此在主分支上构建Flink失败。Failed to execute goal on project flink-mapr-fs: Could not resolve Failed to collect dependencies at com.mapr.hadoop:maprfs:jar:5.2.1详细信息：
org.apache.maven.
浏览 42提问于2019-07-19得票数 1
回答已采纳
我正在探索PyFlink，我想知道是否有可能将PyFlink与ML工程师通常使用的所有ML库一起使用: PyTorch、Tensorflow、Scikit Learn、Xgboost、LightGBM等等。考虑到PyFlink类似于PySpark，我想答案可能是“不”。但是我很想再次检查一下，看看我需要做些什么来使PyFlink能够使用这些ML库来定义UDF。
浏览 2提问于2021-03-15得票数 0
回答已采纳
我使用Kafka作为Flink job的数据源。当我将作业部署到flink集群作业管理器时，我收到一个错误ClassNotFoundException：Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSource</groupId>
<artifactId>flink-connector-kafka_2.12</arti
浏览 489提问于2021-08-28得票数 0
回答已采纳
1回答
我正在尝试使用带有RabbitMq流连接器的Flink。尝试了所有可能的版本组合，但仍然失败。json4sNative = "org.json4s" %% "json4s-native" % "3.3.0"
"org.apache.flink" %% "flink-scala" % flinkVersion % "provided",
"org.
浏览 0提问于2016-03-08得票数 2
1回答
我正在使用apache开发一个基于scala的项目，到目前为止，我只在IntelliJ中运行我的项目，它没有出现任何问题。这在IntelliJ中有效，但在flink运行时不起作用。currentPath = Paths.get(filePath)所有三个变体都在IntelliJ中工作，而不是flink请注意，以下将在IntelliJ和flink运行时中同时工作：
val source = Source.fro
浏览 2提问于2018-12-12得票数 4
1回答
我可以从IntelliJ运行我的Flink作业没有问题，但是当我尝试在flink standalone上运行它时……./flink-1.4.0/bin/flink run ..<exclude>org.apache.flink:flink<
浏览 3提问于2018-01-24得票数 0
我从它的git克隆导入了"flink“项目，并配置了相关设置。我可以用"mvn“在命令行中成功编译/打包它。
有几个项目报告了无法解析符号的错误。例如：“无法解决/flink-streaming-java_2.10/src/main/java/org/apache/flink/streaming/runtime/operators/windowing"Mat
浏览 5提问于2016-04-24得票数 3
示例：此消息结构在kafka主题中，但我希望在elasticsearch中对其进行索引，如下所示
{"id":"1","name"{"firstName":"abc","lastName":
浏览 0提问于2018-09-20得票数 0
急切的执行函数，在第145行，所以我尝试重新上传jar文件，这次删除了print()，我得到了一个不同的错误，它说：
2022-01-07 17:15:56,391 ERROR org.apache.flink.runtime.webmonitor.handlers.JarRunHandler
浏览 32提问于2022-01-07得票数 0
3回答
</groupId> <version>1.3.2</version><dependency> <artifactId>flink-clients_2.11&
浏览 19提问于2017-11-28得票数 0
回答已采纳
2回答
在我的Flink项目中，我找不到连接器的某些库(具体来说，我需要吃一次CSV，在批处理或流模式下读取几个块数据的TBs )。>flink-connector-filesystem_${scala.binary.version}</artifactId>我是否需要一个与Java不同的Scala导入路径？我希望Fli
浏览 26提问于2022-11-14得票数 0
1回答
我正在做一个项目，在这个项目中我制作了一个flink数据流程序，并将代码的第一次运行转移到了另一个团队，以便他们可以查看它。他们都是大级别的用户，并问我是否有任何缺点或好处切换到使用gradle，而不是在未来的flink项目使用maven。有两个git集线器repos，我发现乍一看，它们看起来像是在flink项目上实现gradle，但仅此而已。( 1.)是否有“如果flink
浏览 1提问于2017-05-09得票数 2
回答已采纳
我在仪表板和IntelliJ中都使用Flink 1.3.2。ClassNotFoundException说，当我从源代码构建Flink时，我看到了很多警告消息，这使我相信迭代条件类没有包含在jar中，因为错误也是如此。下面是错误
Caused by: java.lang.NoClassDefFoundError: org/apache/flink/cep/pattern/conditions/IterativeConditionjava.lang.Class.getMethod0(
浏览 1提问于2017-10-28得票数 0
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号