3回答
我正在flink群集内运行flink流作业。我需要模拟一个作业失败的场景。我在我的源代码中引入了一个损坏的事件。当该事件发生时，我看到抛出异常的作业和任务已经从检查点重新启动。根据文档，作业应在第一次尝试后失败。我需要模拟作业失败的场景。该怎么做呢？
浏览 38提问于2020-10-13得票数 0
回答已采纳
3回答
我有一个Java应用程序午餐，一个flink作业来处理Kafka流。在flinkEnv.execute("flink job name")提交作业时，应用程序在这里挂起，因为作业将永远运行，以获取从kafka传入的流。
<e
浏览 3提问于2016-09-16得票数 0
我有一个有状态操作符的作业，并且还启用了检查点。由于某些原因，staful操作符的任务之一失败，并已重新启动并恢复检查点状态。我会问，以下哪一个是重新启动行为：
整个工作将重新启动并恢复。
浏览 3提问于2020-12-18得票数 3
回答已采纳
我希望使用同样的方法来部署我的一些Flink作业。Flink作业是关键的-有些作业是无状态的，它们处理每一个数据(准确地说是一次)，有些作业是有状态的，可以在流中查找模式或对时间作出反应。没有作业能够容忍长时间的停机或频繁的关闭(因为编程错误，Flink退出的方式)。
我发现文档大多倾向于将k8s中的Flink作业部署为Job Cluster。但是，我们应该如何采取一种实际的做法来
浏览 0提问于2020-02-13得票数 3
我有一个使用Apache Flink (flink版本: 1.8.1)的作业流，使用scala。有如下流作业要求: Kafka ->写入Hbase ->再次发送到kafka使用不同的主题 在写入Hbase的过程中，需要从另一个表中检索数据。为了确保数据不为空(NULL)，作业必须(在一定时间内)重复检查数据是否为空。 Flink可以做到这一点吗？如果是，您能提供与我的需求类似的情况的示例吗？编辑:我的意思是，对于我在内容中描述的问题，我想过
浏览 46提问于2020-12-21得票数 1
1回答
Flink群集详细信息，Flink版本：1.11我们使用PackagedProgram从流作业中提交Flink批处理作业，但是我们的要求是一次只执行一个作业，假设我们从源获得2个事件，所以理想的情况下，必须触发2个批处理作业(每个事件)，但每次只能执行一个。为了实现这一点，我们使用了client.setDetached(false) (在fl
浏览 4提问于2020-09-22得票数 0
回答已采纳
1回答
我对flink很陌生，并试图将其部署到EMR集群上。我使用了3个节点集群(1个主服务器和2个从节点)进行默认配置。我没有做任何配置更改，并坚持默认配置。我很想了解以下几点：
主从是如何相互通信的，因为我还没有在主节点中提到任何IP？我可以在主节点(Path: /usr/lib/ flink )中看到flink库，但在从节点中找不到flink库。我的代码如何在从节点上执行？如果需要，我将根据conf/flink-config.y
浏览 1提问于2018-05-10得票数 3
1回答
我正在尝试使用Flink 2.1.0从mysql日志表中读取流数据，但是，它只读取一次，然后它将停止该过程。我希望它继续读取，如果有传入的数据，并打印它。for Source: Custom Source (1$09:15:56,394 INFO org.apache.flink.core.fs.FileSystem- Terminate JobClientActor.
09:15:56,406 INFO org.apache.flink.
浏览 72提问于2017-02-22得票数 2
1回答
EKS上的Flink集群
、、、、
我计划创建一个flink流作业，将数据从一个FileSystem流流到Kafka。我尝试使用minikube在本地设置它，并启动了会话集群，并提交了工作正常的作业。我的问题是:1)在两个选项中，作业集群和会话集群，因为作业是流作业，应该保持对文件系统的监视
浏览 9提问于2020-01-08得票数 0
回答已采纳
3回答
我试图从oreilly书“用Apache进行流处理”和flink项目中运行第一个示例。每个错误都是不同的和错误是一样
浏览 7提问于2020-04-05得票数 1
回答已采纳
众所周知，Flink有两个核心mode.So (数据流/数据集)，但是当我使用flink Sql客户端提交作业时，我不需要选择流或批处理API，因为Flink SQL客户端如何决定使用批处理模式和流模式那么，我想知道Flink SQL Client如何区分批处理模式和流模式？
浏览 29提问于2019-12-23得票数 0
回答已采纳
我试图通过flink停止停止一项工作但是，CLI引发错误，不允许我停止作业。我可以取消它。这里的原因是什么？程序在以下异常情况下结束：
org.apache.flink.util.FlinkException: c7196bb1d21d679efed73770a4e4f9ed无法停止这项工作。在org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:557) at
浏览 1提问于2018-12-12得票数 0
回答已采纳
1回答
我想了解窗口如何影响Flink作业性能，我正在运行一个由以下运算符组成的flink作业：
作业并行度(4,8,16)：自动生成源--> Map1 -->翻滚窗口(10s)--> Map2--> Sink高于性能的作业上限约为每秒50k+-，无论我如何扩展集群形成4 -16个并行度。当删除作业窗口时，作业可以达到每秒200k。作业并行度(4-8)：自动生成源--> Map
浏览 1提问于2018-05-29得票数 2
1回答
我使用的是Flink 1.12。我想读取csv，并根据处理时间进行翻滚窗口分组。代码如下，但是查询sql_tubmle_window没有输出，我想知道问题出在哪里 import org.apache.flink.streaming.api.scala._import org.apache.flink.types.Row
def ma
浏览 5提问于2021-05-02得票数 0
回答已采纳
/flink/testlogs/2021-12-08--07 我希望日志文件应该每15分钟写一次到一个新的日志文件。下面是密码。FileSink<Tuple6<String, String, String, String, String, Integer>> sink = FileSink.forRowFormat(new Path("/flink
浏览 5提问于2021-12-08得票数 0
回答已采纳
我已经知道flink将开始从使用者组的. https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.htmlhttps://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafk
浏览 6提问于2019-11-04得票数 2
回答已采纳
基于Flink Scala快速入门，我已经创建了一个使用org.apache.flink.streaming.connectors.twitter.TwitterSource的示例作业。我使用本地流作业管理器/start-local-streaming.sh，并使用~/flink-0.10.0/bin/flink run target/quickstart-0.1.jar启动作业
在TwitterSou
浏览 0提问于2015-12-04得票数 2
我在运行flink作业时遇到了问题，flink作业基本上是对mysql数据库运行查询，然后尝试创建一个必须从不同作业访问的临时视图。resultStream = tableEnv.toDataStream(resultTable);
env.execute();2022-02-14 12:22:57,702 INFO
浏览 36提问于2022-02-14得票数 0
回答已采纳
在flink中有两个作业在运行，如果其中一个失败了，我需要让整个flink应用程序失败吗？我该怎么做呢？假设并行度为1的作业由于某种异常而失败，如何使并行度为4的作业失败？ ?
浏览 5提问于2020-07-25得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
