mozilla-services / heka

DEPRECATED: Data collection and processing made easy.
http://hekad.readthedocs.org/
Other
3.39k stars 530 forks source link

StreamOutput stopped: can't get record: can't unmarshal record: proto: illegal wireType 6 ? #1989

Open wangfeiping opened 7 years ago

wangfeiping commented 7 years ago

I run hekad on a lot of server, but just one server show error log and shut down. All the server is same, same system, same path, same config. I don't know why, every time I restart hekad then the server will show me the log!

2016/11/14 10:12:33 Plugin 'o' error: StreamOutput stopped: can't get record: can't unmarshal record: proto: illegal wireType 6 2016/11/14 10:12:33 Plugin 'o' error: can't get record: can't unmarshal record: proto: illegal wireType 6 2016/11/14 10:12:33 Plugin 'o': stopped 2016/11/14 10:12:33 Plugin 'o': has stopped, shutting down.

` [hekad] maxprocs = 1 base_dir = "/apps/heka-0_10_0-linux-amd64/bin" share_dir = "/apps/heka-0_10_0-linux-amd64/bin"

[ks] type = "RegexSplitter" delimiter = '' delimiter_eol = true

[pd] type = "PayloadRegexDecoder" match_regex = '(?P[\s\S]*)'

[pd.message_fields] Logger = "xml_log" Payload = "{{pay_mpos_front_cnepay}}%msg%"

[file_input] type = "LogstreamerInput" log_directory = "/apps/front_cnepay/log" file_match = 'front_cnepay.log' splitter = "ks" decoder = "pd"

[PayloadEncoder] append_newlines = false

[o] type = "TcpOutput" address = "logs.qianbao.com:516" message_matcher = "Logger=='xml_log'" encoder = "PayloadEncoder" `