streamload socket error
简简单单XTlife 发布于2021-06 浏览:3005 回复:1
0
收藏
最后编辑于2021-06

你好,我本地用streamload 从kafka拿数据清洗后导入doris,但是一旦json字符串过长的话 会报 java.net.SocketException: Connection reset by peer: socket write error

我用了httpclient4.5 和 okhttp3 都出现了这个问题,请问下,有人遇到过这种情况吗,能提供下解决方案的思路吗,我暂时是把 jsonArray 切成一小段一小段去处理了,但是我想找个不受长度限制的方案, 我试过gzip,但是也没啥用,报分区无数据"Status":"Fail","BeginTxnTimeMs":0,"Message":"all partitions have no load data" 。gzip用的是okhttp3  加上下面的。

同样的数据,同样的代码,我上个版本0.14.7也没报错,到这14.12就是大面积出现这个报错了,更诡异的是我用postman调,同样的数据postman不报错,但是okhttp3报错了,header参数都一样,我现在没啥头绪,希望各位大神给个思路或者方案。

收藏
点赞
0
个赞
共1条回复 最后由简简单单XTlife回复于2021-06
#2简简单单XTlife回复于2021-06

问题已经解决 http://ai.baidu.com/forum/topic/show/989093

0
快速回复
TOP
切换版块