1

• asked Jan 24

doris 2.1.7版本，Routine Load 消费kafka 3.2.0获取offset错误

相关版本 doris版本: 2.1.7 kafka 版本: 3.2.0（kafka_2.13-3.2.0） 问题描述 问题一： 提交routine load 任务时，出现 [INTERNAL_ERROR]failed to get latest offset for partition: 0, err: Local: Unknown partition异常. be.WARNING错误日志： fe.warn.log错误日志： 创建语句如下： CREATE ROUTINE LOA...

2.1 ingestion

0 votes

1 answers

91 views

forest 35

• asked Jan 24

使用表函数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

22 views

KLUUN 13

• asked Jan 23

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

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

2.1 ingestion

0 votes

1 answers

38 views

Rocket 1

• asked Jan 23

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

51 views

liujiamin 3

• asked Jan 23

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

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

2.1 ingestion

0 votes

1 answers

79 views

XuanKuF 1

• asked Jan 23

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

45 views

jin'song tang 15

• asked Jan 23

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

23 views

____ 21

• asked Jan 23

x2doris 网络问题

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

x2doris

0 votes

1 answers

68 views

etnao 4

• asked Jan 23

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

58 views

glp1997 3

• asked Jan 23

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

58 views