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库的建模。(如图中的红圈)。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Fli
浏览 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.functi
浏览 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回答
Apache Flink -跟踪最大值
hadoop、apache-flink
假设我有一个由元组(t, q)组成的数据流，其中t是感兴趣的变量。
有没有一种分布式的方法来跟踪具有最大t的元组？是否仅在t高于全局最大值时发出？
浏览 3提问于2016-07-29得票数 0
2回答
weblogic是开源的吗？
java、jakarta-ee、weblogic、weblogic12c
我知道weblogic是专有的，但它是开源的吗？
或者，即使Weblogic下载是二进制的(.class或.jar文件)，我们是否有办法获得oracle如何实现Java规范的源代码？
浏览 9提问于2013-10-14得票数 6
1回答
无法用动物园管理员启动Flink HA集群
apache-zookeeper、apache-flink、flink-streaming
我正在尝试安装Flink HA集群(模式)，但是任务管理器找不到作业管理器。在这里，我给你建筑；- Machine 2 : Task ManagerMachine1Machine2high-availability.zookeeper.quorum: Machine1:2181
high-availability.zookeeper.path.root: /<e
浏览 3提问于2018-08-17得票数 0
2回答
JavaFX是开源的吗？
javafx-2、javafx
当安装JDK时，我在C:\Program Files\Java\jdk1.7.xxx文件夹中找到了src.zip，但我找不到javafx源代码，我搜索了一下，但(在上)什么也没有找到，那么，javafx是开源的吗
浏览 1提问于2013-02-05得票数 9
回答已采纳
10回答
C是开源的吗？
c、compiler-construction、open-source
这可能是一个愚蠢的问题，但我一直在想这个问题有一段时间了。C语言(或任何其他低级语言)是否有源代码，或者编译器是“完成所有工作”的部分，包括解析？如果是这样的话，不同的编译器不能有不同的C方言吗？stdlib的因素是什么呢？我真的很想知道这是如何工作的。
浏览 1提问于2011-02-24得票数 80
回答已采纳
1回答
黑客是开源的吗？
haskell、open-source、licensing、package、hackage
我在Hackage上看到的大多数软件包都是用开源许可证发布的libaries，我想我对一个带有缺少许可字段的黑客上传有微弱的记忆，这引发了hackage.haskell.org关于不使用开源许可证的抨击是否有一条规则，规定在黑客上托管的每个包都必须在开放源码许可证下可用？，如果您声称有这样的规则，是如何关联的？。
浏览 8提问于2012-04-29得票数 2
回答已采纳
2回答
是否有像Nifi或流集数据收集器这样的可视化编程环境用于flink或beam？
apache-flink、apache-beam、visual-programming
我正在寻找一个可视化的编程工具，以抽象化的代码，当创建数据流流，以建立在Flink或束-Flink中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。
有人知道这样的计划吗？
浏览 5提问于2017-04-30得票数 4
回答已采纳
2回答
工作流引擎和事件流框架是编排层的替代方案吗？
architecture、workflow、system-design、event-driven-design
要求该层具有灵活性，以便可以快速实现不同类型文档的不同流另一种思考方式是--工作流。将其设计为在Apache Airflow或Uber Cadence等工作流引擎上运行的工作流。
什么是更好的方法。
浏览 7提问于2019-10-23得票数 3
1回答
K8S上的Flink :如何向集群提供Flink配置？
kubernetes、apache-flink
我遵循创建集群，但不清楚如何向集群提供？例如，我想指定jobmanager.heap.size=2048m。
浏览 0提问于2019-08-13得票数 2
回答已采纳
1回答
电子病历上的检查点s3p链路
amazon-s3、apache-flink、amazon-emr
在EMR的flink中，我遇到了s3p检查点的问题。由: org.apache.flink.core.fs.UnsupportedFileSystemSchemeException:导致的无法为方案“s3pFlink通过以下插件直接支持该方案: flink-s3-fs-presto。请确保每个插件都驻留在
浏览 1提问于2020-11-03得票数 0
回答已采纳
1回答
ClassNotFoundException在Analytics应用程序上运行jar
java、spring、apache-flink、amazon-kinesis、amazon-kinesis-analytics
我在SpringBoot中创建了一个，它将使用来自AmazonKinesis输入流的消息，并将使用Apache库对其进行一些操作。下面是一些代码文件。：
按照主类中的times.Checked post.Downgraded SpringBoot版本(从"2.7.0“到"2.4.0".Added ComponentScan注释)中的一个建议，清洁构建了pom中的两个 Java和Spring版本。尝试将注释从@Configuration更改为@Component.Last，但同
浏览 10提问于2022-05-27得票数 0
1回答
flink流是不变的吗？
apache-flink、flink-streaming
我需要使用flink拆分数据流。第一个文件名为"myDs“-包含重复数据部分代码为： .filter// createSync for goodDataStream
我的问题是：
这是否意味着myDs sync还包含新的DedupeFilterFunction
浏览 16提问于2017-03-16得票数 0
回答已采纳
3回答
无法访问windows上的Flink仪表板本地主机:8081
windows、localhost、apache-flink
我遵循安装Flink。我可以在没有任何问题的情况下启动集群Starting cluster.但我没有从我也不能通过本地主机访问仪表板:8081。
有一个较旧的存在这些问题，但是这个解决方案对我不起作用，因为所描述的conf文件显然已经不存在了。我的JAVA_HOME设置为C:\Progra~1\Java\jdk1.8.0_311，以避免程序文件中的空间问题。
浏览 60提问于2022-01-17得票数 0
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号