lm.jiao 13

• asked Sep 26, 2024

flink sql写入doris,报no available backend

异常 org.apache.doris.flink.exception.DorisRuntimeException: no available backend. at org.apache.doris.flink.sink.BackendUtil.getAvailableBackend(BackendUtil.java:96) at org.apache.doris.flink.sink.writer.DorisWriter.lambda$getStreamLoader$1(...

1.2

0 votes

1 answers

166 views

polarbearmx 6

• asked Sep 26, 2024

为什么Profile中的RowsKeyRangeFiltered远大于表的实际行数。

2.1.5 表行数：1620000，没有做过更新和删除。 通过SortKey做点查，但是，Profile中出现【- RowsKeyRangeFiltered: 17.814555M (17814555)】，17814555远大于1620000。 详细的Profile如下： Summary: - Profile ID: f83b42d9f05142f4-96ed95ee4959670c - Task Type: QUERY - Start Time: 2024-09-26 15...

2.1

0 votes

2 answers

47 views

tumg 5

• asked Sep 26, 2024

2.1.4 版本，insert into tvf时候出现 warning

1、版本：doris-2.1.4-rc03-e93678fd1e 2、表：聚合表 3、指标字段：DECIMAL(20, 5) 4、tvf来源：s3 parquet文件 现象(插入报warning)： INSERT INTO xx WITH LABEL xx (xxx,xxx) SELECT * FROM s3("uri"="s3://xx/*.parquet","s3.endpoint"="s3.us-east-1.am...

2.1

0 votes

1 answers

24 views

星火-邓进 5

• asked Sep 26, 2024

doris2.1.2升级到2.1.6后，通过catlog查询oracle变慢很多

看下图，平时执行耗时6m左右的任务，26号耗时1h12m ![] 截图了任务的某个流程的sql，获取profile（profile见后面），这个sql耗时14m，平时应该也就几十秒 ( [https://ask.selectdb.com/uploads/post/5gBHt9Tt6mu.jpg] ) 以下是sql的profile，由于超长，分几段发： Summary: - Profile ID: ba6b36e6f8ec4712-86dddd01f3934aeb - Task...

2.1

0 votes

1 answers

122 views

lm.jiao 13

• asked Sep 26, 2024

flink(1.17) + docker部署的doris(1.2.4),填的8030端口却报8040 Connection refused

source端 阿里云(hologres) sink端 doris(1.2.4)单机版 FE/BE在1台机器上 CREATE TEMPORARY TABLE dwd_cmxs_analyse_ri ( id varchar(200) , date_time TIMESTAMP , app varchar(100) , cname varchar(100) , sname varchar(100) , user_name varchar(100) , error_code va...

1.2

0 votes

1 answers

39 views

liuzhe 5

• asked Sep 26, 2024

logstash doris output 按日志内容输出到不同的表

发现在 doris output 配置中使用日志内容渲染不出来，如下图配置，文件输出可以正确渲染到指定问题，但是输出到doris会提示无法写入 "%{@table}", 看现象是没有渲染。 麻烦大佬们看看是我使用不对还是目前不支持，有无其他实现的办法 报错日志: 标准输出日志： 日志内容： {"hostname":"-vm-33441","path":"/tmp/cmdb.log","re...

2.1

0 votes

1 answers

50 views

Alstore 29

• asked Sep 26, 2024

2.1.6 新建catalog 查表出现 No remote table found for table: xxxxx. Please refresh this catalog.

selectdb-doris-2.1.6 2.1.5升级2.1.6 后catalog 使用正常且配置 metadata_refresh_interval_sec 在2.1.6 新建catalog 后频繁出现 找不到表或者库 No remote table found for table: xxxxx. Please refresh this catalog. 或者修改正在使用的catalog后也会出现此现象 CATALOG 创建语句 {code...}

2.1 catalog

0 votes

2 answers

150 views

doris小白 11

• asked Sep 26, 2024

2.1.4版本插入数据报错Failed to connect to backend,Connection timed out

Caused by: java.sql.SQLException: errCode = 2, detailMessage = (10.128.24.16)[CANCELLED]Failed to connect to backend 11389: [E110]Fail to connect Socket{id=506806161407 addr=x.x.x.x:8060:45272} (0x0x7f6f52c21800): Connection timed out [Edit...

2.1

0 votes

3 answers

180 views

zzzz 11

• asked Sep 25, 2024

doris2.1.2版本，flink api和sql批量写入doris，3个批量参数不生效

需求：doris表有3个字段,id(int),age(int),name(string),采用主键模型,实现部分字段更新 下面以sql方式为例：api的也是一样情况 {code...} 3个参数设置后，依旧是任务执行，立马插入，日志没有明显的看出来有阻塞的情况。使用的是本地idea跑的，下面是日志打印： 2024-09-25 22:38:42,104 INFO org.apache.doris.flink.table.DorisDynamicTableSink - Send ...

2.1

0 votes

1 answers

147 views

zhangliang 1

• asked Sep 25, 2024

doris 2.1 执行一条删除语句后，后续所有查询报错

执行：delete from table_name where ip='ip' and info is null 其中info 字段是 variant 类型 再执行任何基于此表的查询都报错： failed to initialize storage reader. tablet=7439511, res=[E-1501][E-1501] Unexpected type when choosing predicate column ,type=35 0# dor...

2.1

0 votes

1 answers

31 views