Streaming 导入数据错误 curl: (56) Recv failure: Connection reset by peer

【详述】导入其他字段比这个少的表正常。
【背景】做过哪些操作?
【业务影响】
【StarRocks版本】2.1.3

建表语句:
CREATE TABLE testload (
filed1 varchar(500) ,
filed2 varchar(500) ,
filed3 varchar(500) ,
filed4 varchar(500) ,
filed5 varchar(500) ,
filed6 varchar(500) ,
filed7 varchar(500) ,
filed8 varchar(500) ,
filed9 varchar(500) ,
filed10 varchar(500) ,
filed11 varchar(500) ,
filed12 varchar(500) ,
filed13 varchar(500) ,
filed14 varchar(500) ,
filed15 varchar(500) ,
filed16 varchar(500) ,
filed17 varchar(500) ,
filed18 varchar(500) ,
filed19 varchar(500) ,
filed20 varchar(500) ,
filed21 varchar(500) ,
filed22 varchar(500) ,
filed23 varchar(500) ,
filed24 varchar(500) ,
filed25 varchar(500) ,
filed26 varchar(500) ,
filed27 varchar(500) ,
filed28 varchar(500) ,
filed29 varchar(500) ,
filed30 varchar(500) ,
filed31 varchar(500) ,
filed32 varchar(500) ,
filed33 varchar(500) ,
filed34 varchar(500) ,
filed35 varchar(500) ,
filed36 varchar(500) ,
filed37 varchar(500) ,
filed38 varchar(500) ,
filed39 varchar(500) ,
filed40 varchar(500) ,
filed41 varchar(500) ,
filed42 varchar(500) ,
filed43 varchar(500) ,
filed44 varchar(500) ,
filed45 varchar(500) ,
filed46 varchar(500) ,
filed47 varchar(500) ,
filed48 varchar(500) ,
filed49 varchar(500) ,
filed50 varchar(500) ,
filed51 varchar(500) ,
filed52 varchar(500) ,
filed53 varchar(500) ,
filed54 varchar(500) ,
filed55 varchar(500) ,
filed56 varchar(500) ,
filed57 varchar(500) ,
filed58 varchar(500) ,
filed59 varchar(500) ,
filed60 varchar(500) ,
filed61 varchar(500) ,
filed62 varchar(500) ,
filed63 varchar(500) ,
filed64 varchar(500) ,
filed65 varchar(500) ,
filed66 varchar(500) ,
filed67 varchar(500) ,
filed68 varchar(500) ,
filed69 varchar(500) ,
filed70 varchar(500) ,
filed71 varchar(500) ,
filed72 varchar(500) ,
filed73 varchar(500) ,
filed74 varchar(500) ,
filed75 varchar(500) ,
filed76 varchar(500) ,
filed77 varchar(500) ,
filed78 varchar(500) ,
filed79 varchar(500) ,
filed80 varchar(500) ,
filed81 varchar(500) ,
filed82 varchar(500) ,
filed83 varchar(500) ,
filed84 varchar(500) ,
filed85 varchar(500) ,
filed86 varchar(500) ,
filed87 varchar(500) ,
filed88 varchar(500) ,
filed89 varchar(500) ,
filed90 varchar(500) ,
filed91 varchar(500) ,
filed92 varchar(500) ,
filed93 varchar(500) ,
filed94 varchar(500) ,
filed95 varchar(500) ,
filed96 varchar(500) ,
filed97 varchar(500) ,
filed98 varchar(500) ,
filed99 varchar(500) ,
filed100 varchar(500) ,
filed101 varchar(500) ,
filed102 varchar(500) ,
filed103 varchar(500) ,
filed104 varchar(500) ,
filed105 varchar(500) ,
filed106 varchar(500) ,
filed107 varchar(500) ,
filed108 varchar(500) ,
filed109 varchar(500) ,
filed110 varchar(500) ,
filed111 varchar(500) ,
filed112 varchar(500) ,
filed113 varchar(500) ,
filed114 varchar(500) ,
filed115 varchar(500) ,
filed116 varchar(500) ,
filed117 varchar(500) ,
filed118 varchar(500) ,
filed119 varchar(500) ,
filed120 varchar(500) ,
filed121 varchar(500) ,
filed122 varchar(500) ,
filed123 varchar(500) ,
filed124 varchar(500) ,
filed125 varchar(500) ,
filed126 varchar(500) ,
filed127 varchar(500) ,
filed128 varchar(500) ,
filed129 varchar(500) ,
filed130 varchar(500) ,
filed131 varchar(500) ,
filed132 varchar(500) ,
filed133 varchar(500) ,
filed134 varchar(500) ,
filed135 varchar(500) ,
filed136 varchar(500) ,
filed137 varchar(500) ,
filed138 varchar(500) ,
filed139 varchar(500) ,
filed140 varchar(500) ,
filed141 varchar(500) ,
filed142 varchar(500) ,
filed143 varchar(500) ,
filed144 varchar(500) ,
filed145 varchar(500) ,
filed146 varchar(500) ,
filed147 varchar(500) ,
filed148 varchar(500) ,
filed149 varchar(500) ,
filed150 varchar(500) ,
filed151 varchar(500) ,
filed152 varchar(500) ,
filed153 varchar(500) ,
filed154 varchar(500) ,
filed155 varchar(500) ,
filed156 varchar(500) ,
filed157 varchar(500) ,
filed158 varchar(500) ,
filed159 varchar(500) ,
filed160 varchar(500) ,
filed161 varchar(500) ,
filed162 varchar(500) ,
filed163 varchar(500) ,
filed164 varchar(500) ,
filed165 varchar(500) ,
filed166 varchar(500) ,
filed167 varchar(500) ,
filed168 varchar(500) ,
filed169 varchar(500) ,
filed170 varchar(500) ,
filed171 varchar(500) ,
filed172 varchar(500) ,
filed173 varchar(500) ,
filed174 varchar(500) ,
filed175 varchar(500) ,
filed176 varchar(500) ,
filed177 varchar(500) ,
filed178 varchar(500) ,
filed179 varchar(500) ,
filed180 varchar(500) ,
filed181 varchar(500) ,
filed182 varchar(500) ,
filed183 varchar(500) ,
filed184 varchar(500) ,
filed185 varchar(500) ,
filed186 varchar(500) ,
filed187 varchar(500) ,
filed188 varchar(500) ,
filed189 varchar(500) ,
filed190 varchar(500) ,
filed191 varchar(500) ,
filed192 varchar(500) ,
filed193 varchar(500) ,
filed194 varchar(500) ,
filed195 varchar(500) ,
filed196 varchar(500) ,
filed197 varchar(500) ,
filed198 varchar(500) ,
filed199 varchar(500) )
ENGINE=OLAP
DUPLICATE KEY(filed1)
DISTRIBUTED BY HASH(filed1) BUCKETS 2;

测试数据:
filed1,filed2,filed3,filed4,filed5,filed6,filed7,filed8,filed9,filed10,filed11,filed12,filed13,filed14,filed15,filed16,filed17,filed18,filed19,filed20,filed21,filed22,filed23,filed24,filed25,filed26,filed27,filed28,filed29,filed30,filed31,filed32,filed33,filed34,filed35,filed36,filed37,filed38,filed39,filed40,filed41,filed42,filed43,filed44,filed45,filed46,filed47,filed48,filed49,filed50,filed51,filed52,filed53,filed54,filed55,filed56,filed57,filed58,filed59,filed60,filed61,filed62,filed63,filed64,filed65,filed66,filed67,filed68,filed69,filed70,filed71,filed72,filed73,filed74,filed75,filed76,filed77,filed78,filed79,filed80,filed81,filed82,filed83,filed84,filed85,filed86,filed87,filed88,filed89,filed90,filed91,filed92,filed93,filed94,filed95,filed96,filed97,filed98,filed99,filed100,filed101,filed102,filed103,filed104,filed105,filed106,filed107,filed108,filed109,filed110,filed111,filed112,filed113,filed114,filed115,filed116,filed117,filed118,filed119,filed120,filed121,filed122,filed123,filed124,filed125,filed126,filed127,filed128,filed129,filed130,filed131,filed132,filed133,filed134,filed135,filed136,filed137,filed138,filed139,filed140,filed141,filed142,filed143,filed144,filed145,filed146,filed147,filed148,filed149,filed150,filed151,filed152,filed153,filed154,filed155,filed156,filed157,filed158,filed159,filed160,filed161,filed162,filed163,filed164,filed165,filed166,filed167,filed168,filed169,filed170,filed171,filed172,filed173,filed174,filed175,filed176,filed177,filed178,filed179,filed180,filed181,filed182,filed183,filed184,filed185,filed186,filed187,filed188,filed189,filed190,filed191,filed192,filed193,filed194,filed195,filed196,filed197,filed198,filed199

使用stream load导入:

curl --location-trusted -u root:X456@123 -T /opt/new_1.txt -H "label:0123" -H "cloumns:filed1,filed2,filed3,filed4,filed5,filed6,filed7,filed8,filed9,filed10,filed11,filed12,filed13,filed14,filed15,filed16,filed17,filed18,filed19,filed20,filed21,filed22,filed23,filed24,filed25,filed26,filed27,filed28,filed29,filed30,filed31,filed32,filed33,filed34,filed35,filed36,filed37,filed38,filed39,filed40,filed41,filed42,filed43,filed44,filed45,filed46,filed47,filed48,filed49,filed50,filed51,filed52,filed53,filed54,filed55,filed56,filed57,filed58,filed59,filed60,filed61,filed62,filed63,filed64,filed65,filed66,filed67,filed68,filed69,filed70,filed71,filed72,filed73,filed74,filed75,filed76,filed77,filed78,filed79,filed80,filed81,filed82,filed83,filed84,filed85,filed86,filed87,filed88,filed89,filed90,filed91,filed92,filed93,filed94,filed95,filed96,filed97,filed98,filed99,filed100,filed101,filed102,filed103,filed104,filed105,filed106,filed107,filed108,filed109,filed110,filed111,filed112,filed113,filed114,filed115,filed116,filed117,filed118,filed119,filed120,filed121,filed122,filed123,filed124,filed125,filed126,filed127,filed128,filed129,filed130,filed131,filed132,filed133,filed134,filed135,filed136,filed137,filed138,filed139,filed140,filed141,filed142,filed143,filed144,filed145,filed146,filed147,filed148,filed149,filed150,filed151,filed152,filed153,filed154,filed155,filed156,filed157,filed158,filed159,filed160,filed161,filed162,filed163,filed164,filed165,filed166,filed167,filed168,filed169,filed170,filed171,filed172,filed173,filed174,filed175,filed176,filed177,filed178,filed179,filed180,filed181,filed182,filed183,filed184,filed185,filed186,filed187,filed188,filed189,filed190,filed191,filed192,filed193,filed194,filed195,filed196,filed197,filed198,filed199" -H "column_separator:," http://xxxx:9030/api/test/testload/_stream_load

报错:
curl: (56) Recv failure: Connection reset by peer
5.1.0KhYrTPVc
gtKfvaB_sLSKmysql_native_password

FE错误:
2022-04-08 14:12:37,148 WARN (starrocks-mysql-nio-pool-1|161) [MysqlChannel.fetchOnePacket():156] receive packet sequence id[32] want to get[1]
2022-04-08 14:12:37,148 WARN (starrocks-mysql-nio-pool-1|161) [AcceptListener.lambda$handleEvent$262():91] connect processor exception because
java.io.IOException: Bad packet sequence.
at com.starrocks.mysql.MysqlChannel.fetchOnePacket(MysqlChannel.java:157) ~[starrocks-fe.jar:?]
at com.starrocks.mysql.MysqlProto.negotiate(MysqlProto.java:146) ~[starrocks-fe.jar:?]
at com.starrocks.mysql.nio.AcceptListener.lambda$handleEvent$262(AcceptListener.java:68) ~[starrocks-fe.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_171]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_171]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_171]

企微加您了,麻烦通过下吧。

端口写错了,应该是8030

你好,请问是怎么解决的,我也在stream load的过程中遇到了相同的问题

检查一下 stream load 的端口写的对不对,fe_host:fe_http_port(默认8030)

谢谢,是端口写错了,改了端口就正确了