在我的程序中，我启用了检查点，env.enableCheckpointing(5000);
但我还没有配置任何StateBackend。检查点状态存储在哪里？我能以某种方式检查这些数据吗？
浏览 9提问于2018-07-25得票数 1
回答已采纳
2回答
我是Apache的新手，我正在研究Apache的例子。我发现，在失败的情况下，Flink能够从检查点恢复流处理。StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();现在，我的问题是，在默认情况下，Flink在<em
浏览 0提问于2018-05-13得票数 2
回答已采纳
我在RocksDBStateBackend中使用flink 1.11，代码如下所示：env.setStateBackend(stateBackend);--我的理解是，当DbStoragePath被设置时，Flink将在存储到hadoop hdfs:///flink-c
浏览 0提问于2021-02-24得票数 0
回答已采纳
在我的flink代码中，我使用RocksDB作为状态后端来实现增量检查点，但是我想知道增量检查点正在发生什么我的意思是有方法检查日志或flink仪表板是执行增量检查点还是执行完整检查点
我使用的是flink版本1.10.0，根据我看到的flink文档，在Flink版本1.10.0中禁用了日志机制，我遵循这个链接来启用下面的RocksDB日志记录，以便启用<em
浏览 7提问于2021-01-08得票数 0
回答已采纳
我正在将Kafka数据流写入HDFS路径中的bucketing接收器。Kafka会给出字符串数据。如果我直接将流写入HDFS，它工作得很好。你知道为什么会发生这种事吗？我使用的是Flink 1.6.1、Hadoop 3.1.1和Oracle JDK1.8
浏览 0提问于2018-10-20得票数 0
application/config/routes.php
当我第一次提交时，我希望提交这些文件(包括它们的默认值)，因此它们作为“默认”配置存在于存储库中，如果我克隆到存储库，就会得到这些文件。当我更新它们以包含我的配置变量(对于我正在开发的版本)时，我不希望它们在存储库
浏览 1提问于2012-02-19得票数 4
回答已采纳
嗨，我试着在我的一个flink模块中做检查点，在这个模块中，如果我注释掉了CoFlatMapFunction检查点，如果它不起作用的话，就使用CoFlatMapFunction组合到流。我将检查点更新为flink网站中的这个，它说在迭代流中添加了一个额外的属性来强制检查点事件，这样做之后它也不起作用，请在下面查找检查点设置
StateBackend stateBackend
浏览 2提问于2020-09-22得票数 0
回答已采纳
在.NET中使用Settings.settings文件时，配置实际存储在哪里？我想删除保存的设置以恢复到默认状态，但找不到它的存储位置...有什么想法吗？
浏览 3提问于2009-07-02得票数 104
回答已采纳
我使用Flink 1.10.1和FsStateBackend作为检查点的状态后端。我有一些有状态的操作，在应用程序运行期间(作为.jar应用程序运行，而不是作为集群)，它们按预期工作，但如果应用程序由于某种原因停止(或崩溃)，应该与检查点一起存储在文件系统中的状态没有加载，并且函数没有任何先前的引用，那么我需要从数据库加载信息并将其保存为
浏览 41提问于2020-07-09得票数 0
我正在用Spark Structured Streaming进行'flatMapGroupsWithState‘的实验，这个想法很有趣，但现在我问自己，由于Spark的分布式性质，这个状态信息保存在哪里……
假设我有一个集群10，是所有10个节点都分担存储负载以保留此状态信息，还是存在集群中的一个节点可能过载的风险？我在某处读到State对象必须是Java序列化的
浏览 3提问于2019-06-05得票数 1
这是一个HTTP (默认情况下是/actuator/health)，您可以为获取关于应用程序的信息。缺省情况下，Spring启用此功能。Spring还有一个配置属性management.endpoint.health.show-details，用于保护响应中是否包含详细信息。该属性的默认值为never，因此不显示详细信息。因此，Spring的默认配置是提供端点，但不提供任何细节。
但是，没有详细信息的健康端点有什么
浏览 0提问于2019-09-13得票数 0
回答已采纳
1回答
我有一个生产者应用程序，它以每秒600条记录的速度写入Kinesis流。我编写了一个Apache应用程序来读取/处理和聚合这些流数据，并将聚合的输出写入AWS Redshift。每条记录的平均大小为2KB。此应用程序将运行24 * 7。
我想知道我的AWS EMR集群的配置应该是什么。我需要多少个节点？我应该使用的EC2实例类型(R3/C3)是
浏览 4提问于2017-08-11得票数 0
回答已采纳
在我的flink作业中，我将数据保存在mapstate中几分钟，以便进一步处理，在process元素中，我需要在mapstate值的帮助下执行一组操作，所以我在mapstate内容的帮助下使用多个线程进行处理线程没有修改状态，它只获取导致CocurrentModification异常的键值，这个TTL异常也出现在COnfigured TTL时间之前，日志如下。
浏览 84提问于2020-04-03得票数 0
默认情况下，docker连接到Docker注册中心，在Ubuntu中这是在哪里配置的？
如果我们需要指向我们自己的公司存储库或任何其他存储库，那么我们可以在哪里配置相同的存储库呢？
浏览 3提问于2017-12-11得票数 1
回答已采纳
1回答
我试图在Mono中设置NHibernate，在SQLite中存储对象。var config = new Configuration();导致下列不语法验证异常：
System.InvalidOperationException:正在意外地尝试验证从已完成的状态到内容的状态转换。我不知道问题
浏览 2提问于2009-06-21得票数 3
回答已采纳
但是，一旦我启用了带有本地RocksDB状态后端的检查点，集群就会以一种意想不到的方式运行，停止作业，尝试重新启动它们，只丢弃所有这些作业，并将错误日志保持为空。我知道，对于每个作业，都保留了全部JobManager内存的一小部分，同样，对于每个作业，在同一台机器上实例化了一个本地RocksDB，但我假设它们同样轻量级，不需要太多内存/CPU容量。我不确定，例如，将RocksDB检查点存储在像S3这样<em
浏览 3提问于2020-03-10得票数 0
3回答
--如果配置文件图片存在，则必须与员工关联。但是，如果有一个没有个人资料的雇员，那是完全没有问题的。
现在我想创建一个REST端点，它允许向给定的雇员id请求配置文件图片。如果提供的雇员id不存在配置文件图片，我希望返回默认图片。问题是，我不知道在哪里存储默认图片:我想将<e
浏览 2提问于2022-08-09得票数 0
1回答
嗨，我想找出SparkSQL在Spark中存储表元数据的位置？如果默认情况下它不在配置单元元存储中，那么它存储在哪里？
浏览 113提问于2019-03-10得票数 2
回答已采纳
1回答
Spring MVC创建了一些默认的开箱即用的对象，比如HandlerMapping、ViewResolver等。
在哪里配置这些默认创建的bean的配置文件？(我不是在谈论我们提供的配置文件)。我在问，Spring用来创建上述对象的默认开箱即用实现的默认配置</em
浏览 0提问于2012-07-29得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
