1回答
根据this page的说法，当使用Flink Statefun v2.1.0时，我们可以为状态设置TTL。 根据this page的说法，我们也有能力引导状态。第一个问题是，bootstrap文档根本没有提到状态过期。在具有TTL的状态上进行引导的正确方法是什么？谁能给我举个例子？第二个问题是，如果我将某个状态设置为在1天内写入后过期，然后使用6个月的数据引导该状态</e
浏览 18提问于2020-07-25得票数 0
回答已采纳
我对Apache和有状态函数非常陌生，只是尝试了一些代码。./flink run -c org.apache.flink.statefun.flink.core.StatefulFunctionsJob ./statefun-examp
浏览 10提问于2022-06-10得票数 0
我使用以下命令运行有状态的2.0基本hello作业我的POM.xml是 <version>2.0.0</version>
</dependency
浏览 4提问于2020-05-23得票数 0
我曾计划用python statefun示例(链接：https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-python-greeter-example)来交流嵌入式有状态函数 但是(总会有一个但是)我一直在努力构建python发行版。tried to described 我的pip版本:19.2.3 我的
浏览 23提问于2020-05-04得票数 0
我希望你能给我一些关于使用状态函数的建议。我们目前正在使用Flink，根据Flink，我们从许多kafka流中消费，聚合，运行一个计算，然后输出到一个新的流。我们希望为他们提供独立于流元素之外开发和更新其组件的能力。最初，我们只是将他们的代码移植到Java。在这里，有状态函数似乎提供了另一种选择，在这里，我们将保留一些现有的功能，并在Python中将模型作为一个状态函数承载。不过，我想知道，与仅仅在自己的管道上托管计算模块和使用Flink中的Async
浏览 5提问于2021-07-23得票数 1
回答已采纳
我们可以根据需要扩展无状态函数。但是，如果我们在扩展无状态函数时不对其进行扩展，则有状态函数可能会成为瓶颈。伸缩状态似乎很棘手，因为数据分布在节点上。如果有状态函数成为瓶颈，我们也可以扩展它们吗？
浏览 12提问于2020-05-13得票数 0
我试图将传入的消息发送到多个有状态函数，但我无法完全理解如何做到这一点。为了便于理解，让我们假设我的一个有状态函数获取一些整数并将它们发送到一对远程函数。这些函数将这些整数添加到其状态值中，并将其保存为新状态。
当这两个远程函数中的一个失败时，另一个应该继续以相同的方式工作。当失败的函数恢复时，它应该处理在失败期间不能处理的消息。
浏览 1提问于2020-05-09得票数 0
回答已采纳
1回答
大家好，最近开始使用Apache Flink Stateful functions。我们正在使用Flink reporter将指标放入InfluxDB https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/metric_reporters/有状态函数提供了具有几个开箱即用指标的"function“作用域https:&#x
浏览 34提问于2021-11-04得票数 1
回答已采纳
我使用的是Flink StateFun 3.1.0，并希望从嵌入式函数中调用远程Python函数。在StateFun 2.2中，我可以通过ProtoBuf (通过Protobuf生成) Java类的实例通过Any.pack(msg)创建Protobuf Any，这是可行的。by: java.lang.ClassCastException: class com.google.protobuf.Any cannot be cast to class org.apache.flink.statefun.sdk.
浏览 7提问于2021-12-14得票数 1
我已经在http://localstack:4645的Docker撰写中运行了一个模拟动态流kind: io.statefun.kinesis.v1/ingress id: com/sentiment type: specificStateFun映像，但是我在日志中得到了这个错误：
Caused by: org.apache.flink.shaded.jackso
浏览 8提问于2022-09-14得票数 0
回答已采纳
使用远程功能的Flink 涉及到Flink StateFun集群将计算任务的执行交给通过某种FaaS机制部署的远程员工，例如AWS Lambda。正如所述，AWS lambda受到扩展限制(它们可以扩展的速度和限制)。请注意，并发的Lambda配额适用于帐户，而不是每个单独的lambda函数。在大规模流传输系统中，特别是如果由单个Lambda调用执行的工作相对于在该时段中在数据流中遇到的密钥的数量而言相对较长，则可以想象Flink StateFun集群可能遇到Lambda节流事件。换句话
浏览 9提问于2021-10-18得票数 0
我们使用flink 1.10.1和scala 2.11。Class[_], x$2: T)Unit
[error] cannot be applied to (Class[com.here.lanes.laneroadreference.derivation.statefun.state.EventMeta.EventMeta], Class[org.apache.flink.statefun.flink.common.protobuf.ProtobufSerializer[com.h
浏览 48提问于2021-05-06得票数 0
我的有状态函数是将数据写入数据库，但它是不确定的，因此从检查点恢复可能会导致数据库包含不一致的数据。我的想法是在Flink的持久化状态下“缓冲”数据，只有在检查点完成后才将数据写入数据库。
浏览 61提问于2020-08-24得票数 0
回答已采纳
我正在尝试新的有状态函数方法，并且我已经尝试手动创建一个保存点(https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.1
浏览 11提问于2020-07-26得票数 0
回答已采纳
我有两个关于在Kubernetes上运行的StateFun应用程序的高可用性的问题。下面是有关我的设置的详细信息：
状态后端为rocksdb1-我尝试了动物园管理员和Kubernetes HA设置，结果是一样的(下面的日志来自动物园管理员HA )。有人能确认我认为什么是正确的和/或给我如何使我的StateFun应用程序高可用性工
浏览 54提问于2021-12-11得票数 0
回答已采纳
我们感兴趣的是从连接到常规的Flink流应用程序，最好使用Table。这样做的想法是查阅Statefun在Flink中注册的表，是否有此可能，如何做才是正确的方法？到目前为止，我的想法是在一些主函数中初始化我的表流，并注册一个有状态函数提供程序来连接到该表：public classFnEnrichmentCallback.TYPE, myTable.select("max(amount)").toString(),
浏览 2提问于2020-04-11得票数 2
在开发apache有状态函数时，使用python或java有哪些优点和缺点？
我们能在python上完全开发应用程序吗？什么是一个支持和另一个不支持的特征。
浏览 4提问于2020-05-13得票数 2
回答已采纳
背景并不是每个元素都拥有唯一的id。Flink是否提供了一个API来限制状态中元素的数量？尝试过的事情
使用MapState和StateTtlConfig生成的TTL/过期机制
浏览 4提问于2022-04-07得票数 1
回答已采纳
1回答
我当前的Flink应用程序
我想自动放大/缩小有状态函数。然后，我直接调整部署的副本：kind: Deployment name: statefun-master replicas我只需要确保Job
浏览 54提问于2022-01-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
