StarRocks be 掉线一个节点影响写入

💬 StarRocks 用户问答
#1

【详述】3副本表，be掉线一个节点5分钟后，flink写入开始报错，与3副本表掉线一个节点不影响写入描述不符。请教一下这个是什么原因？
Suppressed: java.lang.RuntimeException: com.starrocks.data.load.stream.exception.StreamLoadFailException: Transaction prepare failed, db: tast, table: test_insert, label: flink-f486d80a-4663-4831-9a28-41fe4271e175,
responseBody: {
“Status”: “INTERNAL_ERROR”,
“Message”: “[E112]Not connected to ip:8060 yet, server_id=456 [R1][E112]Not connected to ip:8060 yet, server_id=456 [R2][E112]Not connected to ip:8060 yet, server_id=456 [R3][E112]Not connected to ip:8060 yet, server_id=456”
}

【是否存算分离】否
【StarRocks版本】3.1.0
【集群规模】3fe+5be

#2

flink sink 部分的代码逻辑请贴下，jdbc-url和load_url,这个不是写入数据报错，是导入任务报错，还没到数据写入的步骤

#3

使用的flink sql方式写入，flink connector版本是flink-connector-starrocks-1.2.8_flink-1.17.jar，sink代码：
CREATE TABLE sink_demo(
id STRING COMMENT ‘id’,
) COMMENT ‘’ with (
‘connector’ = ‘starrocks’,
‘database-name’ = ‘test’,
‘sink.buffer-flush.interval-ms’ = ‘60000’,
‘sink.properties.format’ = ‘json’,
‘sink.properties.strict_mode’ = ‘true’,
‘sink.properties.strip_outer_array’ = ‘true’,
‘sink.properties.ignore_json_size’ = ‘true’,
‘table-name’ = ‘table_name’,
‘jdbc-url’: ‘jdbc:mysql://feip1:9030,feip2:9030,feip3:9030’,
‘load-url’: ‘feip1:8030;feip2:8030;feip3:8030’
);

insert into
sink_demo
select
id
from
source_demo;

#4

3节点，掉线一个不影响读，影响写把，升级的时候也是一样

#5

@dongquan 大佬帮忙看看呢

#6

存算分离，cn掉线一个节点也会导致routine load job消费 [E112]Not connected to ip:8060 yet 异常，job状态runnining，但不消费kafka问题

京ICP备2022026421号-1