腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何在删除flink jobmanager之前删除
rocksdb
(flink state)文件?
、
我想在删除flink作业群集之前/之后删除所有
rocksdb
文件。我们在K8s上
部署
了flink作业。我们将每个作业集群的状态存储在
rocksdb
上。并且当作业集群停止时,存储状态的
rocksdb
不会被删除。有什么想法吗?
浏览 39
提问于2020-02-21
得票数 0
回答已采纳
1
回答
如果我给Flink的
RocksDB
状态后端足够的内存,这与基于堆的状态后端有什么不同?
、
使用EmbeddedRocksDBStateBackend与Flink一起使用的一个明显优点是,当内存不足时,它可能会溢出到磁盘。但是,如果我准备给它足够的内存,使它不再需要使用磁盘,这与使用HashMapStateBackend有什么区别?
浏览 9
提问于2022-02-07
得票数 1
2
回答
Python-
Rocksdb
的安装
、
、
、
我正在尝试安装Python-
RocksDB
包。我尝试使用sudo pip3 install python-
rocksdb
sudo pip install python-
rocksdb
但是,我得到的消息需求已经满足: python-
rocksdb
浏览 82
提问于2019-10-06
得票数 2
1
回答
Kafka流:动态配置
RocksDb
、
我想调优卡夫卡流的性能,为此我必须使用
RocksDb
配置值。我看到我可以使用StreamsConfig.
ROCKSDB
_CONFIG_SETTER_CLASS_CONFIG来设置
RocksDB
的配置。就像显示的。但是我想要一种从配置中动态配置它的方法(为了改变阈值,而不必编译和
部署
我的所有代码)。 是否有选项以某种方式给出具体的实现实例而不是类名?(这将允许设置阈值,例如,使用属性文件)
浏览 2
提问于2019-04-04
得票数 2
回答已采纳
1
回答
arangodb能处理200亿条记录吗?
、
我只想知道,Arangodb能在一个集合中处理200亿条记录吗?
浏览 3
提问于2018-11-19
得票数 1
1
回答
为什么Apache流使用
RocksDB
,如果有可能改变它呢?
、
、
、
、
有一个有趣的事实是,卡夫卡内部使用
RocksDB
。见。
RocksDB
不是用JVM兼容的语言编写的,因此需要仔细处理
部署
,因为它需要额外的共享库(依赖于操作系统)。这里有一些简单的问题: 我曾试图搜索答案,但我只看到了一个隐含的原因,即
RocksDB
在每秒数以百万计的运算范围内非常快。
浏览 2
提问于2016-10-18
得票数 31
回答已采纳
1
回答
RocksDB
生成的文件夹是什么?
、
在我的kubernetes容器中,我为kafka流应用程序配置了
rocksdb
。 ...name: state-volume - name: state-volume medium: Memory 在
部署
之后如果我转到这些文件夹中的一个,例如cd /tmp/state/my-service/0_105/
rocksdb
/state,我会看到实际的.sst文件。在每个_0_*文件夹中,都有多个sst文
浏览 6
提问于2019-12-12
得票数 1
回答已采纳
1
回答
限制堆外内存的Kafka流
、
、
我们的应用程序被
部署
,kubernetes吊舱继续重新启动。 我正在做一些调查,发现我们可以通过实现RocksDBConfigSetter来限制堆外内存,如下面的示例所示。static org.
rocksdb
.WriteBufferManager writeBufferManager = new org.
rocksdb
.WriteBufferManager(TOTAL_MEMTABLE_MEMORY因此,根据我的理解,kafka streams应用程序将创建以下
rocksdb
实例,并需要在堆内存中跟踪max。如果我错了,请
浏览 3
提问于2021-01-20
得票数 1
1
回答
RocksDB
Java支持ARM吗
、
、
、
我正在做我的大学项目,我使用最新版本的
RocksDB
和Maven来存储我的键值数据: <groupId>org.
rocksdb
</groupId> at org.
rocksdb
.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:56) at org.
rocksdb
.
Ro
浏览 2
提问于2018-04-05
得票数 0
1
回答
将unique_ptr与需要指针指针的接口一起使用,指向抽象类
我使用的是
RocksDB
,它需要一个指向指针的指针才能打开:
rocksdb
::DB* db{nullptr};const
rocksdb
::Status status =
rocksdb
::DB::Open(options::DB> _db; //
浏览 32
提问于2021-09-27
得票数 0
回答已采纳
1
回答
卡夫卡流BoundedMemoryRocksDBConfig
我试图了解Kafka流的内部是如何与缓存和
RocksDB
(状态存储)一起工作的。应用程序
部署
在OpenShift上,内存分配为4GB。我注意到应用程序的内存不断增加,直到最终出现OOMKILLED。在进行了一些研究之后,我读到自定义
RocksDB
配置是我应该实现的东西,因为对于我的应用程序来说,默认大小太大了。cache = new org.
rocksdb
.LRUCache(1 * 1024 * 1024L, -1, false, 0); private static org.
rocksdb
.Wri
浏览 0
提问于2020-11-20
得票数 1
回答已采纳
1
回答
Kafka sream中ProcessorContext.getStateStore(字符串名)和ReadOnlyKeyValueStore.get(字符串键)的行为是什么
我有一个1.0.0的kafka流应用程序,有两个类,在更新。在我的应用程序中,我读取事件,执行一些条件检查,然后转发到另一个主题中的相同kafka。在我的评估过程中,我在全局表存储的帮助下从Kafka中获得了一些表达式。观察到大部分时间是在从store获取值时花费的(示例代码如下所示)。请帮帮忙。p
浏览 11
提问于2018-01-17
得票数 1
1
回答
向
Rocksdb
的CMakeLists添加gRPC依赖
、
、
我正尝试在
rocksdb
的源代码中直接使用gRPC secondary我正在将它直接添加到
rocksdb
的源代码中。 为了解决gRPC依赖关系,我使用grpc提供的CMakeLists示例将依赖关系添加到
rocksdb
的CMakeLists.txt文件中。我在Ubuntu18.04中安装了gRPC和protobuf,这是我添加到
rocksdb
的CMakeLists中的内容。与grpc、prot
浏览 227
提问于2021-02-19
得票数 0
2
回答
RocksDb
7.9.0库不能打开
RocksDb
6.2.2文件?
这是源代码,没有什么特别之处:
rocksdb
::Options options; options.compression =
rocksdb
:(
rocksdb
::InternalStats*,int,bool,bool,0x000000007e86fb
rocksdb
::VersionEditHandler::LoadTables(
rocksdb
rocksdb
::VersionEditHandler::Chec
浏览 19
提问于2022-11-20
得票数 0
回答已采纳
1
回答
用于增量
rocksdb
检查点的Flink键控状态清理
、
我们有一个flink作业,将持续在
rocksdb
后端的大键控状态。我们正在使用增量检查点策略。随着时间的推移,状态的大小成为一个问题。我们已经检查了状态ttl解决
方案
,但它不支持增量
rocksdb
状态。 如果我真的需要增量检查点,那么解决此问题的最佳方法是什么?
浏览 2
提问于2018-12-13
得票数 0
2
回答
卡夫卡流: UnsatisfiedLinkError on Lib Rocks DB
、
、
、
1824)at java.lang.System.load(System.java:1086)at org.
rocksdb
.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:56) at org.
rocksdb
.
R
浏览 2
提问于2018-04-23
得票数 1
回答已采纳
1
回答
我们可以将sst文件从一个
RocksDB
摄取到另一个
RocksDB
吗?
我在
RocksDB
接口中找到了一个ingestExternalFile()。但是当我尝试将sst文件从一个
RocksDB
摄取到另一个
RocksDB
时,它给了我一个令人震惊的异常: at org.
rocksdb
.
RocksDB
.ingestExternalFile(Native Meth
浏览 32
提问于2018-02-24
得票数 1
1
回答
如何在Spring Cloud Stream中将
RocksDB
改为内存中的stateStore
、
为了比较使用
RocksDB
或内存中的Spring Cloud Stream应用程序(使用Kafka)的性能,我想将
RocksDB
更改为内存中。不幸的是,我找不到任何解决
方案
。我已经为DSL API和处理器API ()找到了一个解决
方案
,但我不确定它是否适用于kafka-streams绑定器。有人能在这个问题上帮我吗? 向马丁致以最美好的问候
浏览 20
提问于2019-07-10
得票数 0
1
回答
如何在GN中导入第三方库?
我的一个项目是由gn+ninja构建的。我想使用平面缓冲区,但它是用cmake编写的。
浏览 10
提问于2020-03-24
得票数 1
2
回答
Kafka -本地状态存储是否消耗应用程序内存(JVM)
、
、
、
我有一个消费者API线程运行在我的应用程序中(运行在不同的节点上),我的目标是消费来自Kafka的传入记录,它将具有唯一的id作为键。寻找一个选项来存储由Kafka消费者API处理的记录,以便我的订单可以使用它来显示。
浏览 3
提问于2020-07-20
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RocksDB 简介
【行业资讯】RocksDB 8.0 发布
Aruba OnConnect 方案部署
摩纳哥选择IN Groupe部署数字身份方案
Flask 高并发部署方案详细教程!
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券