forest 35

• asked Jan 24, 2025

使用表函数query查询，要求查询字段必须与输出字段数量一致。

在使用表函数 query（）进行查询时候，如图：如果屏蔽掉 a.* ，或者仅仅查询部分字段，就会报错误： 1105 - errCode = 2, detailMessage = (10.132.2.117)[CANCELLED]input and output column num not equal of jdbc query. 这种情形下无法进行其他操作，请问需要如何操作才能根对查询数据进行部分字段查询，比如根据某个字段分组，对其他进行聚合。

2.1 query

0 votes

1 answers

54 views

KLUUN 13

• asked Jan 23, 2025

我执行select into outfile，导出到本地，加了delete_existing_files=true报错为什么，doris2.1.7

导出到本地的时候，打开delete_existing_files=true，会将目录和内容全部删除，导致导出失败，为啥？

2.1 ingestion

0 votes

1 answers

104 views

Rocket 1

• asked Jan 23, 2025

flink 1.14.5访问doris-2.1.6表数据报 schema size of fetch data is wrong.

目前使用flink 1.14.5通过flink-doris-connector-1.14_2.11访问doris-2.1.6表数据时执行flink sql：select * from productLine_doris_sink直接提示 org.apache.doris.flink.exception.DorisException: Load Doris data failed, schema size of fetch data is wrong. 相关依赖包信息如图： 相...

query 2.0 faq

0 votes

1 answers

98 views

liujiamin 3

• asked Jan 23, 2025

flink读kafka实时写入doris遇到问题

读kafka实时写入doris 实时观察doris数据，发现不能实时写入，是攒批写入，查找相关文档后，发现是因为checkpoint时间太长，Flink Doris Connector 主要是依赖 Checkpoint 进行流式写入，实测也是。 求教：除了缩短Checkpoint时间，还有其他方式吗？

2.1 ingestion

0 votes

1 answers

127 views

XuanKuF 1

• asked Jan 23, 2025

sparksql 查 hive 表写 doris 报错 [INTERNAL_ERROR]cancelled: closed

相关版本 spark 版本: 3.3 spark-doris-connector 版本: 3.3_2.12-1.3.2 问题描述 通过 sparksql create view 方式创建 sink 表，再 insert into view_table select * from hive.table 写入数据，doris 相关 label 日志仅有一条且没有 ERROR 级别日志。 另，我用 24.0.0版 本的 spark-doris-connector 写 doris 很...

2.1 ingestion

0 votes

2 answers

100 views

jin'song tang 15

• asked Jan 23, 2025

catalog支持mycat数据库吗？

mycat是一个将mysql数据库分库分表的数据库中间件，在我们的环境中创建catalog成功了，也可以switch到新的catalog，schema，show tables命令执行没有问题，但是在查询表的时候报错： select * from bbg_order_center_master limit 100 Error Code: 1105. errCode = 2, detailMessage = Unexpected exception: No remote colu...

2.1

0 votes

1 answers

40 views

____ 21

• asked Jan 23, 2025

x2doris 网络问题

我的doris 需要使用slb 才能连接10.xx.xx.xx 内网ip 是100.xx.xx.xx 现在我用配置了源数据 和目标数据 ，迁移的时候 报错 {code...}

x2doris

0 votes

1 answers

152 views

etnao 4

• asked Jan 23, 2025

doris3.0.3中 percentile函数不支持double类型的字段

CREATE TABLE sales_data ( product_id INT, sale_price DECIMAL(10, 2) ) DUPLICATE KEY(product_id) DISTRIBUTED BY HASH(product_id) BUCKETS AUTO PROPERTIES ( "replication_allocation" = "tag.location.default: 1" ); -- 插入示例数据 INSE...

3.0

0 votes

3 answers

84 views

glp1997 3

• asked Jan 23, 2025

2.1.7，创建catalog连接Elasticsearch后，查询es数据报连接超时的问题

问题描述：使用catalog查询es数据时报连接超时，报错内容如下图所示。 doris版本：2.1.7 ，es版本：8.6.1 catalog创建es的语句，用了如下参数 CREATE CATALOG catalog_es PROPERTIES ( "type" = "es", "hosts" = "http://xxxx:xxxx", "user" = "xxx", "p...

2.1 catalog query

0 votes

1 answers

106 views

liujiamin 3

• asked Jan 22, 2025

求助！如何高效更新部分列

背景：flink监听kafka，从不同的业务表中查出字段信息，然后更新大宽表中某条数据的对应字段，其他字段不变，大宽表是unique模型 参考文档：https://doris.apache.org/zh-CN/docs/data-operate/update/unique-update [https://doris.apache.org/zh-CN/docs/data-operate/update/update-of-unique-model] 问题：通过INSERT INT...

2.1 ingestion

0 votes

2 answers

157 views