1回答
让我以一种通用的方式开始，看看我是否错过了一些概念:我有一个流flink作业，我从该作业创建了一个保存点。)
CassandraSink.addSink(stream) 只要我在没有保存点的情况下运行作业，这就可以很好地工作如果我从一个保存点开始作业，我会得到一个异常，如下所示 Caused by: java.lang.Un
浏览 51提问于2021-08-03得票数 0
回答已采纳
我有一个使用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.
浏览 4提问于2020-09-22得票数 0
回答已采纳
我在线程"main“中得到了一个异常:类org.apache.flink.state.api.runtime.SavepointLoader试图访问受保护的方法org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage.resolveCheckpointPointer(Ljava/lang/String;)Lorg/apache/flink/runtime/state
浏览 0提问于2020-01-20得票数 1
回答已采纳
我希望处理来自kafka的消息，然后提交该消息，一旦flink消费和处理所有消息，结束作业，使用任务管理器和心跳将进程升级
StreamExecutionEnvironment environment
浏览 4提问于2022-06-09得票数 -1
2回答
我们正在部署一个新的Flink流处理作业，它的状态(存储)需要使用历史数据进行初始化，并且在开始处理任何新的应用程序事件之前，这些数据应该在状态存储中可用。我们不希望大幅修改Flink作业来加载历史数据。我们考虑编写另一个单独的Flink作业来处理历史数据，更新它的状态存储并创建一个保存点，并使用这个保存点来初始化主Flink作业</em
浏览 47提问于2021-04-23得票数 0
仅仅将stateUri放在保存点路径中就足够了吗？
如果两个不同的jars具有相同的后端stateUri，会发生什么情况？
浏览 0提问于2019-01-09得票数 1
回答已采纳
1回答
我试图在我的产品flink作业中更新keyby函数，方法是向getKey函数添加一个新的keyby值，例如keyby函数是 value.getTimestampvalue.getTimestamp(), value.isRedirect()我正试图将新任务部署到uat服务器(以确保它在启动之前工作)，方法是优雅地停止作业并使用保存点进行恢复但是
浏览 0提问于2021-06-16得票数 0
我正在Yarn集群中运行这些Flink作业。如何使用此保存点重新启动Flink作业。我使用的是Flink 1.4.2。
浏览 1提问于2018-06-01得票数 0
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
我们已经用1.4版本部署了一个新的Flink实例。在尝试从旧的1.2.1部署恢复保存点时，尝试还原的所有作业都会出现相同的错误：错
浏览 6提问于2018-01-04得票数 2
回答已采纳
1回答
我试图使用Flink REST通过管道自动化Flink作业提交过程。要调用任何Flink Rest端点，我们应该了解接口IP。对于我的POC，在CLI上运行flink-session命令之后，我得到了IP，但是从代码中获得它的方法是什么呢？
requests.post(') //取消保存</em
浏览 9提问于2022-10-12得票数 0
1回答
我已经在批处理中使用了apache一段时间，但现在我们希望将这个批处理作业转换为流作业。我遇到的问题是如何运行端到端的测试。如何在批处理作业中工作
我们希望对流作业</em
浏览 1提问于2018-07-09得票数 4
回答已采纳
是否可以为flink中的不同作业配置不同的保存点路径？有没有办法在Flink的Java程序中配置该路径？
浏览 2提问于2018-04-12得票数 0
我希望使用保存点机制将现有作业从Flink的一个版本移动到另一个版本，方法是：直到Flink 1.14我没有问题，但在Flink1.15.1中，它失败了。即使不更改版本并停留在1.15.1中，它也会失败。] -> [my_sink]
在以前版
浏览 7提问于2022-08-05得票数 1
回答已采纳
我使用FlinkKafkaConsumer来使用kafka并启用检查点。现在，我对偏移管理和检查点机制有点困惑。我已经知道flink将开始从使用者组的. https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#kafka-consumers-start-position-configuration读取分区
浏览 6提问于2019-11-04得票数 2
回答已采纳
我使用Yarn来运行Flink作业。对于每个Flink作业，我都要创建一个检查点。
我提交一个在我的Yarn集群中运行的Flink作业。我有一个轮询作业，它检查一个作业是否在Yarn上失败并重新启动它。当作业再次提交时，Yarn为该Flink作业创建一个新的application_id。如何配置重新提交的Flink作业以
浏览 0提问于2018-05-22得票数 0
回答已采纳
1回答
我使用的是在从docker-flink安装的ECS中运行的Flink。我已经通过flink-conf.yaml中的state.checkpoints.dir到S3启用了外部检查点到AWS S3。现在，根据Flink文档here，如果我们想在出现故障的情况下从检查点恢复，我们必须使用bin/flink run -s :checkpointMetaDataPath [:runArgs]，但我使用FLIN
浏览 35提问于2020-04-03得票数 0
回答已采纳
我正在测试Flink 1.3.0中的弹性特性。我有一个具有检查点启用和固定延迟重启策略的作业.当我杀死一个TaskManager JVM时，一段时间后，作业将在剩余的节点上正确地重新启动。但是，当我添加一个新节点时，作业不会自动重新启动以利用它。我试着使用bin/flink stop <jobId>，但它总是给我java.lang.IllegalStateException: Job with ID <jobId> is not sto
浏览 2提问于2017-06-19得票数 1
回答已采纳
我的项目目前构建在Azure上(数据存储在Azure SQL server中)，我目前正在尝试通过利用PyFilnk将流/批处理功能引入到我的项目中。但是，我没有找到任何关于如何将PyFlink连接到Azure SQL server的文档，有没有一种方法可以在PyFlink中使用Azure SQL server作为数据源？
浏览 13提问于2021-07-22得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
