yugunsung 117

• asked Jan 23

flink-doris-connector写入doris高峰期出现抖动怎么排查

doris版本：3.0.8 flink-doris-connector从kafka消费日志写入到doris，发现当数据量100w/s时，kafka消费速率出现了抖动，发现是checkpoint时间比较长。这个有什么方法可以排除是哪里出现了瓶颈？另外还发现be节点的负载相差较大。资源监控发现CPU、内存和IO都正常。

3.0

0 votes

2 answers

23 views

____ 9

• asked Jan 23

x2doris迁移Doris4.0开启Workload Group 绑定 Resource Group创建表不兼容

Doris4.0集群，开启了Workload Group 绑定 Resource Group后进行分组，此时默认创建表的属性："replication_num" = "3",但是开启了Resource Group后进行分组会报错：Backends details: backends with tag {"location" : "default"} is [], Create failed replication...

x2doris 4.0

0 votes

1 answers

36 views

gaoxuejian 1

• asked Jan 23

doris4.0.1按照官网使用ai 函数，每次查询be都会挂掉

4.0

0 votes

1 answers

42 views

limingrui 1

• asked Jan 23

datax同步数据到doris，任务间断性失败。

没有排查出是什么原因导致的

2.0

0 votes

1 answers

20 views

奥胖子001 1

• asked Jan 23

2.1.11 information_schema.`routine_load_jobs` fe不同节点数据不一致

doris 版本 ：doris-2.1.11-rc01-97b77e6cda fe 3节点：1 master+2 FOLLOWER information_schema.routine_load_jobs fe2个 follower节点状态异常，只有主节点是正确的。 有没有什么办法可以手动处理!急，急，急！ [fe从.png]

2.1

0 votes

2 answers

21 views

taojun 1

• asked Jan 22

doris 2.1.11版本 be 不时的飙高到100%，导致查询变慢，有时fe还连接不上

检查到fe飙高的时间段，大量打印如下两类日志： 1.（查询变慢） I20260121 10:26:29.554636 2362623 beta_rowset.cpp:223] deleting /data4/doris_be/be_storage/data/2/10037/1988860573/020000000002ddc4b84ec961d2480aa06f3f5fed3bb219a1_0.dat 2.（fe 连接不上） I20260120 20:00:32.033942...

2.1

0 votes

1 answers

36 views

shuguang 1

• asked Jan 22

doris的kettle插件写入资源库后无法读取

新建步骤如果保存为ktr文件，再次读取无问题，如果直接存入mysql资源库，再读取出来，会报错 {code...} kettle数据库存储的信息如下：

faq

0 votes

0 answers

21 views

Kevin.Shin 19

• asked Jan 21

Doris 2.1 SQL 解析错误

Doris 2.1.10 以下SQL是BI软件生成的，执行时遇到错误： [Code: 1054, SQL State: 42S22] errCode = 2, detailMessage = Unknown column 'code' in 'sg_bg_db' 其中的sg_bg_db是数据库名 注释掉SQL最后面任意一个and 条件，都能执行过去。 {code...}

2.1

0 votes

1 answers

26 views

3

• asked Jan 21

spark往doris写入数据时删除某些数据该如何配置

doris-2.1.10 scala-2.12 在之前我已经执行spark应用写入了一些数据在doris中，现在我根据操作通过withColumn给其中一些数据加上了删除标记： df.withColumn("should_delete",when(col("op") === "d", lit(1).otherwise(0))).drop("op") 当op为d时，表示这条数据之前已经写入了，现在要删除 然后按照查...

2.1

0 votes

0 answers

13 views

只爱吃糖不说话 3

• asked Jan 21

doris 2.1.11 查询结果错误

创建一个100w的表，使用 row_number + limit 查询的时候，结果集会重复 问题复现： CREATE TABLE test as WITH t as ( SELECT 0 as id UNION ALL SELECT 1 as id UNION ALL SELECT 2 as id UNION ALL SELECT 3 as id UNION ALL SELECT 4 as id UNION ALL SELECT 5 as id UNION ALL SELEC...

2.1

0 votes

1 answers

50 views