我有一个远程运行的Flink作业管理器，并且正在使用来安排作业。
Flink启用保存点，以便我可以中断正在运行的作业，并从保存的状态恢复它。保存点数据的持久化位置应该在作业管理器的外部(例如，这样我就可以重新配置和重新启动作业管理器并恢复<
浏览 23提问于2017-08-23得票数 1
回答已采纳
我找不到关于如何安全更新代码的说明。我看到了有关如何使用保存点的Flink文档。我希望有一个简单的解决方案来更新AWS EMR中的Flink作业。https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/deployment/aws.
浏览 28提问于2020-06-11得票数 1
我有多个Kafka主题(多租户)，并且我根据主题的数量多次运行相同的作业，每个作业消耗来自一个主题的消息。我已经将文件系统配置为状态后端。 假设有3个作业在运行。检查点在这里是如何工作的？这3个作业是否都将检查点信息存储在同一路径中？如果任何作业失败，该作业如何知道从何处恢复检查点信息？我们过去常常在向flink群集提交作业时提供作业</
浏览 33提问于2020-07-16得票数 0
回答已采纳
我正在为数据流工作apache (1.3.1)，我必须在Windows 2012 R2下设置它，我在Flink HA设置上有一个问题。任何帮助都是非常感谢的。谢谢。下面是设置细节，我有5台服务器，2台用于作业管理器HA，2台用于任务管理器HA，最后一台(资源服务器)用于保存所有恢复、保存点或检查点文件。我已经将资源服务器映射为'Y‘网络驱动器在所有其他服务器。在flink-#en0#.high中高可用性.：
浏览 0提问于2017-11-05得票数 1
回答已采纳
1回答
我正在研究Flink 1.9.1的停靠/K8部署的可能性。目前，我们确实认为我们将尝试采用工作集群的方法，尽管我们想知道这个社区的趋势是什么？我们不希望每个Flink集群部署一个以上的作业。
在这
浏览 1提问于2020-01-10得票数 2
回答已采纳
我将使用以下命令启动Flink应用程序集群现在我正在读关于的文章。我会设置索赔模式，以便给Flink保存点目录的所有权。我试图启动作业管理器，将-restoreMode CLAIM参数添加到standalone-job.sh命令中：
.文档显示了fl
浏览 22提问于2022-10-20得票数 0
1回答
我使用Apache Flink将来自给定的Kafka主题集的更新传播到Elasticsearch集群中。我面临的问题是，有时Elasticsearch集群会进化，而我必须通过(1)修改映射，当我不得不将Flink作业指向新的别名/索引时，(2)复制到data...and时，就会有大量的更新到旧的索引。所以我想知道什么是最好的方法来解决这个问题。我可以休息，但如果可能的话，我想避免这样做。我
浏览 5提问于2022-06-21得票数 0
是否可以在运行时更改flink框架的日志级别？什么时候flink集群已经在运行？我参考了下面的文件，没有提到它。https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/logging.html
浏览 267提问于2020-11-24得票数 0
我有一个用Flink (Scala)编写的示例流式WordCount示例。在它中，我想使用外部化的检查点在失败的情况下进行恢复。但它并没有像预期的那样工作。我的代码如下： object WordCount { // set up the execution environmentkafkaConsumerProperties.setProperty("zookeep
浏览 25提问于2019-04-15得票数 1
回答已采纳
在我的程序中，我启用了检查点，
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment()
浏览 9提问于2018-07-25得票数 1
回答已采纳
我有一个与用户infa1一起运行的informatica脚本
windows批处理服务器上的文档(MarkLogic安装在不同的Linux服务器上)
我试图了解如何设置特权才能在windows此外，在Linux服务器上运行的xdmp.save函数(安装MarkLogic<
浏览 0提问于2019-04-07得票数 0
回答已采纳
我使用flink 1.9和REST /jobs/:jobid/savepoints来触发savepoint和cancel作业(请优雅地停止作业以便稍后从savepoint运行)。我在源函数中使用了两阶段提交，所以我的源代码实现了CheckpointedFunction和CheckpointListener接口。在snapshotState()方法上，调用I快照，将内部状态和notifyCheckpointComplete(
浏览 3提问于2020-08-07得票数 1
回答已采纳
1回答
我尝试在PySpark的作业中运行从.py文件加载的.sh文件，但我总是收到一条消息，总是说找不到.sh文件test.py：os.system("sh ./check.sh")gcloud beta dataproc jobs submit pyspark --cluster mserver file:///home/myuser/test.py
te
浏览 0提问于2016-02-04得票数 0
使用Android ，用户可以将内容以PDF格式保存到设备的内部/外部目录。
我需要得到PDF文件的路径，一旦它被创建。有没有任何方法可以直接做到这一点，而不必使用文件选择器？
浏览 8提问于2017-05-15得票数 1
回答已采纳
如何才能让保存点从正确的偏移量开始？我正在使用标准的Kinesis接收器和一个指向S3路径的连续阅读器。
我使用的是只有一次的语义(检查点)，并且我可以验证源代码的状态是否与每个保存点一起存储。
浏览 0提问于2020-01-27得票数 1
我正在使用direct3D 11.1创建我的游戏，我想将播放器最后一次记录存储在一个文件中，所以下面是我的代码：(它在!Writer.Write("Easy", getString(Scene->Score), File);下面是我要在文件中写入的XMLWriterret = false; } }但是，任何时候我运行它，它都不能创建一个
浏览 0提问于2014-09-12得票数 1
回答已采纳
我发现在特定的小型集群和本地机器中运行作业存在问题。这项工作在较大的机器上顺利进行。/rocksdbnumberOfTaskManagers: 2resources: cpu: 0.5使用6
浏览 12提问于2022-02-08得票数 2
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
