wangwu 1

• asked May 30

flink读取doris中通过catalog配置的表报错

doris版本：2.1.15 flink版本：1.20.1 flink.connector.version版本：3.3.0-1.20 flink-doris-connector-1.20版本：25.1.0 启动flink读取doris中通过catalog配置的表时，报错argument 'Doris BE' is illegal, value is ''. 在建表语句中手动指定benodes也不行 CREATE TABLE DorisSourc...

2.1

0 votes

1 answers

22 views

XQG 15

• asked May 29

Doris Paimon Catalog 遇到的问题, 想确认一下是否正确

Paimon 元数据和数据都存储到MinIO Doris 版本 Doris 版本: 2.1.8 问题 想确认一下: Doris 创建 Paimon Catalog, 是只支持读取, 不支持通过 Doris 的 insert into 写入 Paimon Catalog 的表吗? 想确认最终的结果, 是否就是不支持写入Paimon 自己测试的时候, Doris 确实可以查询Paimon Catalog数据, 往Paimon中写数据, 日志中提示: 不支持 通过Doris Pai...

2.1

0 votes

1 answers

32 views

lihao 1

• asked May 29

doris3.0.3创建udf，jar包找不到

本地打包写好的jar，应该放到什么地方呢？ be:apache-doris-3.0.3/be/lib/java_extensions/java-udf/java-udf-demo-jar-with-dependencies.jar 是放到这里么，还是应该放到哪里，用mysql客户端，是放到mysql客户端的机器中么？

3.0

0 votes

1 answers

44 views

GN 1

• asked May 29

Java 使用jdbc 驱动doris 数据库，进行批量压测插入操作，会显示有规律的突刺，怎么办，有3个FE 10个Be,各种参数调试已经调过了，还有没有其它方法处理

2.1

0 votes

4 answers

58 views

baihongyu 1

• asked May 29

【BUG】flink-doris-connector动态新增表后发生flink容错恢复导致新增表无法被监听

现象 我们在使用该连接器的cdcTools工具进行mysql-Doris的cdc同步时，动态的新增了一张表，前期一切正常，数据也在正常同步，之后Doris侧该表数据不再增加，日志中有大量该表不被监听的警告信息：WARN org.apache.doris.flink.sink.writer.serializer.jsondebezium.JsonDebeziumDataChange [] - filter table xx.xxx, because it is not list...

ingestion

0 votes

1 answers

54 views

odos 3

• asked May 29

be扩容后查询缓慢问题

2.1.7 be扩容了2两台，下线了1台，现在是1fe 4be ，扩容后查询延迟变高10秒左右，其中大量delete truncate 语句删除执行时间都很久，请问可以问哪方面排查。我尝试部分表删除重建后可以缩短delete truncate语句执行时间 io很高

2.1

0 votes

1 answers

46 views

Da Wan 25

• asked May 28

求一个查询一个数组字段包另一个数组中任意值的语法

一个数组字段包含另外一个数组中的任意一个值，就像下面这种查询，有更简洁的语法吗 {code...}

3.0

0 votes

1 answers

30 views

wangwu 1

• asked May 28

doris通过catalog集成Hive后，flink再集成doris，如何查询这个Hive表

doris通过catalog集成Hive后，可以直接在doris中查询Hive的表，如 select * from catalog.database.table; flink集成doris后，可以查询doris中建的表 {code...} 但是查不了Hive的表，table.identifier写catalog.database.table就会报错 Caused by: org.apache.doris.flink.exception.IllegalArgumentExcep...

catalog

0 votes

1 answers

103 views

Neal_Zzzz 17

• asked May 28

【Bug】窗口函数+groupby 在join时报错

实现功能：窗口函数取第一行+去重 select height, FIRST_VALUE(address) OVER (PARTITION BY height ORDER BY index) as address from dwd_output group by height,address; 这个语句执行没问题 当加了join操作后，语句变为： select bl.,mi.address from dwd_height as bl inner join (select hei...

2.1 query demand

0 votes

1 answers

27 views

weiyf 7

• asked May 28

Doris异步物化视图问题

当有一个表A是物理表，表B是物理表，那我异步物化视图是不是不能直接将A和B关联得到物化视图C，一定得先创建A的物化视图Av1和B的物化视图Bv1后，再关联两个物化视图得到C？ 异步物化视图没法用索引，那后期怎么提升查询速度？？只能通过分区、分桶了吗？？还有异步物化视图有没有命中提升查询速度的说法？？ 异步物化视图A带分区字段date和异步物化视图B带分区字段date，但是两个物化视图union创建新的物化视图会报错，无法支持这种语法，这个有啥解决方案？？ 查询异步物化视图会一...

2.1

0 votes

1 answers

66 views