Skip to content

Commit d2fcbb2

Browse files
authored
Merge pull request #807 from wonderflow/fixa1
remove one line
2 parents 6c77934 + 69e4b16 commit d2fcbb2

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

reader/socket/socket.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -226,10 +226,9 @@ func (ssr *streamSocketReader) jsonRead(c net.Conn) {
226226
if err != nil {
227227
log.Errorf("runner[%v] Reader %q read decoder buffered error: %v", ssr.meta.RunnerName, ssr.Name(), err)
228228
} else {
229-
log.Errorf("runner[%v] Reader %q read streaming message: %v", ssr.meta.RunnerName, ssr.Name(), TruncateStrSize(string(readBytes), 2048))
229+
log.Infof("runner[%v] Reader %q read streaming message:{ %v }, will combine it to next json decoder", ssr.meta.RunnerName, ssr.Name(), TruncateStrSize(string(readBytes), 2048))
230230
}
231231
decoder = json.NewDecoder(bufioReader)
232-
log.Errorf("runner[%v] Reader %q decode message error %v", ssr.meta.RunnerName, ssr.Name(), err)
233232
time.Sleep(time.Second)
234233
continue
235234
}

0 commit comments

Comments
 (0)