pawnZzz 7

• asked Aug 27, 2024

Flink CDC导入数据BE节点CPU、内存占用很高

版本： Doris V3.0.0 Flink 1.17.2 Flink-doris-connector: 1.6.2 资源：Doris BE节点16C32G 每秒写入：5k左右 流程：Mysql -> Flink CDC -> Kafka -> Flink -> Doris，使用Flink-doris-connector datastream api同步kafka的多topic数据debezium-json到doris 问题：BE节点CPU占用90%以...

3.0

0 votes

1 answers

77 views

frey 13

• asked Aug 27, 2024

UNIQUE KEY模型数据丢失

版本；2.0.3 数据通过flink-cdc从MYSQL同步的关系表。 表结构如下： CREATE TABLE ac_cu_permission_account ( PERMISSION_ID bigint(20) NULL, ACCOUNT_ID bigint(20) NULL ) ENGINE=OLAP UNIQUE KEY(PERMISSION_ID, ACCOUNT_ID) COMMENT 'OLAP' DISTRIBUTED BY HASH(PERM...

2.0

1 votes

2 answers

90 views

Yangboxiao 47

• asked Aug 27, 2024

【问题】当使用 streamload 导入数据时报错 Encountered unqualified data,不展示 ERROR URL

版本：2.1.4 描述：当使用 stream load 导入时报错，Encountered unqualified data 不出现错误日志地址。 {code...} 目前问题已解决：触发原因，分区类型不匹配，目标类型 yyyymmdd（int），实际写入 YYYY-MM—DD(String)

2.1

0 votes

1 answers

598 views

哈哈先生 5

• asked Aug 27, 2024

DORIS 2.0.1版本在写入数据的时候，查询会很慢？有什么优化方案

DORIS 2.0.1版本在写入数据的时候，查询会很慢？有什么优化方案？ 目前我做了如下处理 1、分表操作，之前结果写入的是一张表t1 现在拆分成多个表(t1,t2,...tn),运用端做路由到不同的表 2、聚合模型表 之前是INSERT INTO 计划修改成INSERT OVERWRITE PARTITION

2.0

0 votes

1 answers

81 views

shojinto 3

• asked Aug 27, 2024

select 中支持子查询的功能什么时候可以提供支持

MySQL和Oracle中都提供了selec a.col1,(select t.col1 from t where t.col2=a.col2) from a 或者 select a.col1,sum(if(a.xxid in select id from c),1,0) as 'newCol' from a 我看github上也有类似issue但是不知道此功能的支持什么能够支持上来。 MySQL中可以简化操作： 到了doris中只能用case...when语...

2.1

0 votes

1 answers

161 views

tlzmkm 17

• asked Aug 27, 2024

Doris 1.2.7 写入的时候出现 txn_manager.cpp:154] too many transactions: 112, limit: 100

还有其他的机器时不时的出现 W0827 09:39:33.323386 4973 runtime_filter_mgr.cpp:271] runtimefilter rpc err:[E1008]Reached timeout=500ms @192.168.0.91:8060 W0827 09:39:33.323410 4973 runtime_filter_mgr.cpp:271] runtimefilter rpc err:[E1008]Reached timeout=5...

1.2

0 votes

1 answers

58 views

____ 9

• asked Aug 26, 2024

请问doris-manager从Manager v23.11.4升级到Manager v23.11.9时，发生异常 该如何解决

2.1

0 votes

1 answers

23 views

搬砖工人 17

• asked Aug 26, 2024

PG 迁移 Doris 语法问题

在PG 中有这么一个语法 sum (xx) filter(where xxxx) 如下： {code...} 像这种语法，如果不使用 case when替换， Doris怎么能实现这种查询可以正常的替换 sum(xxx) filter (where)。

2.1

0 votes

1 answers

33 views

哈哈先生 5

• asked Aug 26, 2024

DORIS 2.0版本 INSERT OVERWRITE table test PARTITION(p1,p2) SELECT * FROM test2问题

2.0版本中 INSERT OVERWRITE table test PARTITION(p1,p2) SELECT * FROM test2 其中P1和P2字段 怎么根据当前日期复制 目前我想使用 DATE_FORMATE(,'p%Y%m%d') 发现报错，有什么好的替代方案 主要版本是2.0

2.0

0 votes

1 answers

46 views

哈利波特强 3

• asked Aug 26, 2024

【已解决】Reason: Unable to display, only support csv data in utf8 codec, please check the data encoding.

无法显示怎么办

2.1

0 votes

1 answers

50 views