久安 7

• asked Mar 19, 2024

http读取doris数据源，写入到doris_dwd和kafka，flink报错空指针异常

doris版本 2.0.4 streapark版本 2.0.0 kafka版本 kafka_2.12-2.4.1 flin报错详情 2024-03-19 09:33:02 java.lang.NullPointerException at org.apache.doris.flink.rest.SchemaUtils.lambda$convertToSchema$0(SchemaUtils.java:36) at java.util.ArrayList$ArrayListSp...

2.0

0 votes

1 answers

58 views

caopengbo 5

• asked Mar 18, 2024

【已记录】执行show query profile "/queryId"，报错如下。2.0.3版本

2.0

0 votes

2 answers

67 views

Payne 3

• asked Mar 18, 2024

【已解决】关于Bucket shuffle join文档疑问

文档原文： Broadcast Join: 如果根据数据分布，查询规划出A表有3个执行的HashJoinNode，那么需要将B表全量的发送到3个HashJoinNode，那么它的网络开销是3B，它的内存开销也是3B。 Shuffle Join: Shuffle Join会将A，B两张表的数据根据哈希计算分散到集群的节点之中，所以它的网络开销为 A + B，内存开销为B。 ..... Bucket Shuffle Join开销如下： 网络开销： B < min(3B, A...

docs

0 votes

1 answers

62 views

caoliang 76

• asked Mar 18, 2024

【已解决】flink 整库同步，新创建的表没有自动同步

使用flink同步数据到doris,mysql新创建的表没有同步

faq

0 votes

2 answers

79 views

caoliang 76

• asked Mar 18, 2024

【已解决】export 导入数据的时候，查看导出数据默认都是两百条

在使用doris export 或者select * from xx into OUTFILE 导出数据的时候，查看导出条数始终是两百条

ingestion faq

0 votes

1 answers

49 views

caoliang 76

• asked Mar 18, 2024

【已解决】flink-doris-connector 导入出现报错：errCode = 2, detailMessage = transaction [xx] not found

使用flink-doris-connector导入的时候，看taskmanager日志出现errCode = 2, detailMessage = transaction [19650] not found 的错误，是什么原因导致的呢

faq

0 votes

1 answers

151 views

liangyihan 7

• asked Mar 18, 2024

doris创建一个 WITH BROKER的 S3 远程仓库 s3_repo不成功

版本 doris：2.1.0 其他前置条件： Broker的名称为obs_broker CREATE REPOSITORY obs_repo WITH S3 ON LOCATION "s3://dorisbak" PROPERTIES ( "AWS_ENDPOINT" = "http://10.xxx.xx.x:9383", "AWS_ACCESS_KEY" = "admin", "AWS...

2.1

0 votes

2 answers

81 views

东方红 13

• asked Mar 18, 2024

【已解决】创建 routine load 报错

创建 Kafka routine load报错，这个怎么回事 ERROR 1105 (HY000): errCode = 2, detailMessage = Failed to get all partitions of kafka topic: rpt_table1 from backend[10072]. error: errCode = 2, detailMessage = failed to get kafka partition info: [(xxx.xxx.x...

2.0

0 votes

2 answers

119 views

caoliang 76

• asked Mar 18, 2024

【解决方案】flink-doris-connector 读取doris 并发不生效问题

flink 读取doris的时候，设置了flink并发，读取速度没有变化，是什么原因导致的呢

faq

0 votes

1 answers

70 views

caoliang 76

• asked Mar 18, 2024

【解决方案】routine load 执行一段时间后出现 Broker: Offset out of range

routine load 执行一段时间后，出现： ReasonOfStateChanged: ErrorReason{code=errCode = 104, msg='be 10004 abort task with reason: fetch failed due to requested offset not available on the broker: Broker: Offset out of range

faq

0 votes

1 answers

273 views