我在一个长期窗口中使用flink数据流和TumblingEventTimeWindows，在1.9版本中，我可以通过状态处理器api读取保存点中的windowState数据吗？ 谢谢。
浏览 24提问于2019-08-23得票数 0
的KStream和state (只是普通的，而不是GlobalKTable)。拓扑看起来是这样的：commands.leftJoin(state, computeNewState).to(state)，即命令在当前状态下工作，并为相同主题的生成新的。从functional的角度来看，它有点像command X state -> state；最终的state是在同一个地方产生的，初始状态是从这个地方提取出来<em
浏览 1提问于2020-07-06得票数 2
回答已采纳
我试图理解Kafka处理器API中的RocksDB行为。我正在使用StateStore提供的默认RocksDB配置持久的KStreams。开发人员指南提到，您可以通过在上面的构建器上调用.withCachingEnabled()来启用处理器API中的记录缓存。
缓存“用作读取缓存，以加快从状态存储区读
浏览 0提问于2019-05-29得票数 5
我正在使用JDBC项目读取器和JDBC项目编写器，并且通过处理器通过API更改特定的状态，如果API未能更改状态，我希望在稍后的时间使用指数退避来重试。我想不出如何实现这个
浏览 4提问于2022-05-19得票数 0
回答已采纳
在创建处理器API Topology时，我注意到Topology#addStateStore(StoreBuilder, String...)接受多个处理器，这意味着一个状态存储可以由多个处理器共享。这个设计有什么要注意的地方吗？如果密钥不存在，而实际上其他处理器只是存储该键的值，那么是否有可能通过存储值来丢失数据？我想我是在问是否会出现通常的比
浏览 10提问于2020-06-10得票数 1
回答已采纳
1回答
然后从数据库中读取这些ping，并在多个处理器中单独处理，以便为最终用户提取有价值的信息。到目前为止，我们的系统在pingsTable本身中维护一个列，即processed_state，它基本上指定一个ping是否已经通过特定的处理器处理过。例如，处理状态3意味着pings由前3个处理器处理。每个处理器被配置为读取处理状态小于其
浏览 2提问于2018-07-25得票数 0
回答已采纳
我有一个用于处理ProcessWindowFunction的TumblingEventTimeWindows，其中我使用一个状态存储来在多个滚动窗口中保存一些值。我的问题是，这个状态存储不是在翻滚的窗口中保存的，也就是说，如果我首先在窗口0,999中存储一些东西，然后从window 1000,1999访问这个存储，那么这个存储是空的。我知道全局<
浏览 3提问于2020-06-18得票数 0
我知道联接可以使用dsl执行。出于各种原因，我们需要使用处理器api。
两个处理器，每个处理器都有自己的源主题。每个处理器
浏览 0提问于2018-11-26得票数 3
回答已采纳
我在我的Flink应用程序中的一个ValueState中添加了TTL到ProcessFunction中。Flink应用程序在这个ProcessFunction和其他运营商中都有多种其他类型的状态。我理解将TTL添加到ValueState使其不向后兼容。但是，我想知道我是否可以使用AllowNonRestoredState选项从快照恢复应用程序的其
浏览 7提问于2020-08-21得票数 0
回答已采纳
如何才能让保存点从正确的偏移量开始？我正在使用标准的Kinesis接收器和一个指向S3路径的连续阅读器。
我使用的是只有一次的语义(检查点)，并且我可以验证源代码的状态是否与每个保存点一起存储。
浏览 0提问于2020-01-27得票数 1
1回答
因此，正如标题所述，是否可能使处理器0的A行具有共享(S)状态，而处理器1的B行具有无效的(I)状态？想象一下以下情况：
如果P2对A行发出读取请求，那么P1的最终状态是什么？共享还是无效？
浏览 1提问于2021-05-19得票数 0
回答已采纳
我有许多IOT设备，它们通过消息向kafka主题报告事件，并且我已经定义了一个聚合器来从这些事件中更新设备状态。我想要做的是能够将输入流加入到聚合器在聚合更新状态之前输出的KTable --也就是说，我想，比方说，将一个事件与当前状态进行比较，如果它们匹配某个谓词，则执行一些处理，然后更新状态。我已经尝试过先用StreamsBuilder#addStateStor
浏览 0提问于2019-06-26得票数 0
回答已采纳
1回答
从Cassandra将有界控制流排入队列，从Kafka读取主流。我的问题是，在处理主流之前，我们可以完全读取和广播控制流吗？
我们使用的是Flink 1.9.3和Java 8
浏览 1提问于2021-03-22得票数 0
例如，在配置了fork-join分派器并且参与者的状态没有被@volatile标记的情况下，如果fork/join工作线程在不同的内核(或处理器)上运行，是否可以保证参与者的状态将通过缓存层次结构从一个内核(或处理器)传播到另一个内核(或处理器)？附注:在JSR133之后，只需要对/从任何易失性变量执行一次写/读操作，就可以将缓存刷新到主内存，并在运行
浏览 2提问于2012-04-16得票数 10
回答已采纳
我在GenerateTableFetch处理器中使用“组件状态”，以确保不会从数据库中查询相同的数据两次。由于迁移，流必须再次部署，在此过程中会丢失其状态。如何手动设置此处理器的“组件状态”？我尝试使用独立的ExecuteScript处理器(使用ECMAScript)来更新状态。一开始，我尝试用以下命令读取状态
浏览 29提问于2020-09-23得票数 1
有办法通过REST获得PutSQL处理器最后一次执行的时间戳吗？这样的时间戳存在吗?或者我可以自己构建一个时间戳？设置：，我有气流触发我的Nifi，它以几个PutSQL处理器结束-在这些完成之后，我需要在气流中执行其他的东西。问题：I尝试访问属性statsLastRefreshed，但这不是最后一次执行时间，而是最后一次任何东西(用户/
浏览 1提问于2021-04-12得票数 1
回答已采纳
我读了这个堆栈流的讨论，了解到在恢复期间全局状态存储跳过处理器。因为输入主题在处理器中没有任何键，所以我们构造键并将其放入状态存储中。我看到了许多创建自定义更改日志主题解决方案，该主题将用作全局状态存储的源主题。
但我想知道如何在使用处理器api恢复期间强制全局状态存
浏览 0提问于2020-03-10得票数 1
我不想检索审核的“状态”(例如，“打开”、“关闭”)，而是检索状态(例如，“已批准”)。不过，我看不出有什么办法可以通过API来做到这一点。不管状态如何，它总是返回一个空的JSON数组。例如，此__should__返回“已批准”的状态，但不返回任何内容：
[API不支持此操作(“评审状态”)吗？
浏览 0提问于2019-03-21得票数 5
回答已采纳
我使用的是NiFi ExecuteScript和python。在python脚本中，我添加/修改了处理器的状态stateManager.setState(newmap, Scope.LOCAL)
我是否可以查看/清除NiFi web中的处理器状态？当您右键单击<
浏览 3提问于2016-10-11得票数 1
回答已采纳
3回答
我想根据上一个流文件的内容来设置处理器的属性。
示例:我使用处理器GenerateFlowFile实例化流文件，并在创建flowFile期间使用自定义文本${now()}作为当前时间戳。我希望有一个处理器(与我无关)将流文件(时间戳)的内容读取到处理器的自定义属性property_name。之后，我希望能够通过REST查询处理器
浏览 4提问于2021-04-14得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号