回答情况：
提问时间：
问题标签：
Spark streaming提供了销毁awaitTermination()的接口。有没有类似的API可以在t秒后优雅地关闭flink流？
浏览 4修改于2017-07-26得票数 0
如何使用flink-streaming生成断电警报。 e.x:我有一个网站，通过kafka发送数据到flink-job。可以使用flink吗？
浏览 17修改于2020-04-26得票数 0
回答已采纳
我正在尝试运行Apache Flink，但得到的错误作为依赖项不可用。模块flink-streaming-java是否仍然可用。<dependency> <artifactId>flink-streaming-java</artifactId关于flink-streaming-java 中的进
浏览 1修改于2015-10-22得票数 2
我正在尝试运行官方示例，该示例展示了如何在Twitter中使用Apache Flink流：
如果我没有提供properties.file的路径，将使用TwitterStreamData.java。属性文件是正常的，因为我在另一个示例(没有apache flink的tweet流)中使用了它，并且它是有效的。
浏览 0修改于2015-12-14得票数 1
当我使用Hudi0.10.1和flink1.14.0时，我得到了一个异常“not org.apache.flink.streaming.api.operators.MailboxExecutor”“
我发现与flink 1.14的复杂？
浏览 10提问于2022-03-22得票数 0
package com.knoldusimport org.apache.flink.streaming.api.scala._
def main，当我在Intellij上运行这段代码时，我得到了这个错误 Excep
浏览 102修改于2020-03-23得票数 1
当使用全局窗口时，该窗口是从作业启动并收到第一个事件的那一刻开始启动的，还是也从1970年1月1日00:00:00开始，如以下答案所示：flink Windows, when do they start
浏览 47修改于2021-10-20得票数 0
回答已采纳
env.execute();Error:(36, 22) java: cannot access org.apache.flink.streaming.api.scala.DataStreamclass file for org.apache.flink.streaming.api.scala.DataStream not foundCassandraSink.addSink;
import org.apache.fli
浏览 2修改于2018-03-24得票数 4
回答已采纳
1回答
我使用flink 1.9.0和rabbitmq连接器读取数据，我可以成功地编译我的代码，但当我运行代码时，我得到以下错误：我在pom文件中没有为依赖项定义任何作用域。.setPort(1234).setUserName("usernam
浏览 44提问于2019-11-06得票数 1
回答已采纳
package uimpimport org.apache.flink.streaming.api.TimeCharacteristicimport org.apache.flink.streaming.util.serialization.SimpleStringSchema
import org.apache.flink.streaming.connect
浏览 0修改于2020-08-15得票数 0
我正在尝试实现一个简单的闪光作业，使用org.apache.flink.streaming.connectors，将一个卡夫卡主题作为输入源和输出到一个卡夫卡接收器。我正在遵循这个指南https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka我的pom.xml文件如下 <dependency>
浏览 92提问于2021-08-28得票数 0
我正在写一个Flink流程序，其中我需要使用一些静态数据集(信息库，IB)来丰富用户事件的DataStream。由于Flink不允许在流媒体程序中使用DataSets，我如何实现以上功能？在Flink流程序中实现上述丰富需求的正确设计模式是什么？
浏览 3提问于2018-04-04得票数 5
附言:我看过这个文档：
我认为这里提到的离散化的流可以做到这一点，但它们在flink 1.2 (或任何其他版本)中都不可用。
浏览 7修改于2017-02-10得票数 0
我写了一个Flink程序，从一个简单的kafka流计算每个键控窗口的事件数。当源停止时，我希望将0作为每个窗口的计算结果，但没有发送任何结果。我认为这是因为Flink的懒惰操作行为。
有什么建议吗？
浏览 1修改于2015-12-17得票数 1
使用maven，我正在为我的流媒体应用程序构建一个大罐子。必须将jar部署到k8集群。企业没有内部docker集线器。因此，我的选择是将映像构建为jenkins的一部分，并在kub作业管理器配置中使用相同的映像。如果有任何演示项目布局和部署步骤的示例，我将不胜感激
浏览 3提问于2019-01-10得票数 0
OffsetsInitializer.committedOffsets(OffsetResetStrategy.EARLIEST))在构建incompatible types: org.apache.flink.streaming.util.serialization.JSONKeyValueDeserializationSchemacannot be converted to org.apache.flink.connector.kafka.source.reader.deserializer
浏览 5修改于2022-02-08得票数 2
1回答
我正在将flink(v1.10.0)作业提交到我的群集，但显示以下错误： System.out: (none) at org.apache.flink.client.program.OptimizerPlanEnvironment.generateException/streaming/connectors/rabbitmq/common/RMQConnectionConfig$Builder
at org.myorg.quicksta
浏览 57提问于2020-04-05得票数 0
回答已采纳
我是Flink的新手，我的理解是遵循API调用将并行读取给定对于我的用例，为了服务多个客户端请求，我正在评估使用Flink。因此，我希望Flink为不同的亚马逊网络服务S3文件路径并行执行亚马逊网络服务S3读取。
是否有可能在单个Flink作业中实现这一点。
浏览 49修改于2017-07-18得票数 2
我有一个在flink流中序列化的参数params， class P extend Serializable {...}有没有可能基于flink流作业不停顿？
浏览 24修改于2020-06-30得票数 0
回答已采纳
1回答
;import org.apache.flink.streaming.api.environment.LocalStreamEnvironment;import org.apache.flink</em
浏览 5修改于2021-09-03得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号