OpenViking 代码问答对照实验:本地直读、语义检索、VikingBot 三组实测
把一个 1686 文件的代码库索引进 OpenViking,用 4 道跨文件难题跑三组对照。VikingBot 快 2.7 倍,但质量垫底——我把原因拆到了检索层和框架层。
共 43 篇。可以按时间逐篇阅读,也可以按分类浏览。
把一个 1686 文件的代码库索引进 OpenViking,用 4 道跨文件难题跑三组对照。VikingBot 快 2.7 倍,但质量垫底——我把原因拆到了检索层和框架层。
mainClass是 ChildFirstClassLoader加载的,因此java.sql.DriverManager.getConnection也是ChildFirstClassLoader加载的。
目前项目中写动态SQL,用的都是下面的语法:
微服务一般都采用集群方式部署,而且在高并发下经常需要对服务进行扩容、缩容、上线、下线的操作。比如我们需要更新配置,又或者需要同时失效所有服务器上的某个缓存,需要向所有相关的服务器发送命令…
mock了类EnvUtil之后,setEnvironment方法的参数始终为null。明明传的是一个对象。
首先,应用ServiceA通过DNS查询获取到ServiceB的可用IP列表 2. DNS-F会拦截到ServiceA的查询请求,判断自己是否该查询的答案,如果有(服务已在VIPServer中注册)则直接返回IP列表;…
使用allowedLateness(5d)可以让窗户等待5天再关闭。
我在排查 问题过程中,前前后后花了超过16小时。
e是事件时间,相同的key、相同的事件时间,写入程序一定是先写入RowKind为DELETE的数据,后写入RowKind为INSERT的数据。
schema中,只有f0一个field,类型是TrackLog,也就是说,在把POJO类的fields映射到表时,出现了问题。
通过doris stream load http接口(请求的是FE地址,中间加了一层nginx反向代理),导入数据时,设置了Expect头,但是接口还是返回: “There is no 100-continue header”
在flink中,我们使用druid datasource创建数据源:
peer1节点(python程序往这个节点注册数据)日志:
线上突然出现,某一个消费者组下的部分分区无法消费。 kafka broker日志如下:
如传感器5s上报一次数据,某些场景下,为了性能考虑,需要20s或者5min返回一个point
在 ReactiveStateMachineExecutor 类中,triggerSink 是一个 Sinks.Many 类型的对象,用于管理状态机触发器的事件流。…
业务上经常会出现这样的问题:客户反馈某个业务今天查不到数据。怎么通过监控提前发现呢?
数据湖的出现,主要是为了去满足企业对原始数据的存储、管理和再加工的需求。首先要有一个低成本的存储,用于存储结构化、半结构化,甚至非结构化的数据;另外,有一套包括数据处理、数据管理以及数据治理在内的一体化解决方案。
前面写过一篇业务中使用 telegraf 的文章。
本文将讲述influxdb内存中都存了哪些数据?
写入influxdb时,报错类型冲突:表中字段longitude的类型是string,要写入的值类型是float,不允许这样。
一个 java web api,耗时 2s,但是db 300ms 就返回了,时间到底耗费在哪里呢。
把时序数据(如车辆指标)写入influxdb之后,我们想知道指标值是否异常(如累计里程 大于 1 亿)、新增数据量是否合理(如半个小时表中没有新增数据,大概率服务故障了)
遇到这个报错,是很烦的。折腾半天有时候都无法解决。
influxdb官方有一个库(实验版本),说的是可以支持空间索引(如查询某一个框内的轨迹点)。但是我经常测试,查询慢的不可思议。
spring cloud架构下,微服务间很多是通过 feign进行调用的。
强烈推荐这个视频,kafka 的联合创始人录制的视频。
物联网指标数据(车辆的轨迹、里程、速度等)存储在influxDB中。需要对指标查询服务的性能做压力测试。
上面是一个 netty client,在ClientHandler中写入数据:
client 和 server 建立链接之后,并发送报文:
在Spring中消费Kafka数据时,最便捷的方法就是给方法加@KafkaListener注解。在数据消费逻辑中,需要先把一些配置信息预加载到内存中。…
Spring Cloud架构下,我们在开发时,一般会搭建一个测试的Eureka Server,多个工程师的应用,都往这个Server进行注册。
什么意思呢? 参考chatGPT的回答:
在 Maven 中,依赖的解析顺序和优先级如下:
需要通过telegraf把kafka中的数据,同步到influxdb,parameters中的所有key,作为时序数据库的指标存储。
url格式写错了(两个jdbc),然后呢,在spring项目中查询mysql时,一直卡死,没有返回。
本文针对eureka的源码分析,基于的版本号:
spring框架下,大多数bean都是单例模式。这些单例模式的bean,会在多线程环境下执行(每个http request,可能对应一个线程)。如果bean是有状态的(对象的属性会被修改),如何解决线程安全问题?
结合@LoadBalanced和RestTemplate,实现服务发现。
pg分区功能、最好每个设备数据存在一个分区 - pg array类型、或者中间表,来解决行数太多的问题。 - 表太大时,btree会有性能瓶颈。块级索引就适合这个场景 - 每天一个分区,每个分区有自己的索引文件。
直接使用yum安装的时候,都会提示缺少某些包无法安装。我这里把缺少的包的安装方式列一下。
spring boot项目中,使用hibernate validator作为java bean validation标准的一个实现。
也就是说,有过期删除和压实两种策略。可以为每一个topic单独设置清理策略,默认是过期删除。
没有匹配的文章。
Spring 全家桶、Netty、Kafka 与服务注册——框架内部的机制、源码与踩坑记录。
关系库、时序库、数据湖仓与空间索引——从选型到落地的完整链路。
Flink 作业的并行度、乱序、类加载与调优,实时链路上的具体问题。
从 Wireshark 抓包到 Grafana 看板,定位线上问题的完整工具链与方法。
构建、依赖、IDE 与测试——把日常开发中的摩擦降到最低。
多仓库代码问答 Agent 的设计、评测与落地,以及上下文基础设施的实践。