Skip to content

Instantly share code, notes, and snippets.

@KeenS
Created November 17, 2013 09:35
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save KeenS/7511316 to your computer and use it in GitHub Desktop.
Save KeenS/7511316 to your computer and use it in GitHub Desktop.
fluentd forward bug
#!/usr/bin/env ruby
# _*_ coding:UTF-8 _*_
require 'msgpack'
require 'socket'
TCPSocket.open "127.0.0.1", "24224" do |sock|
sock.write ["debug.access", [1308466941, {"a"=>1}], [1308466942, {"b"=>2}]].to_msgpack
end
2013-11-17 18:31:17 +0900 [info]: fluent/supervisor.rb:169:supervise: starting fluentd-0.10.40
2013-11-17 18:31:17 +0900 [info]: fluent/supervisor.rb:271:read_config: reading config file path="./fluent/fluent.conf"
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered buffer plugin 'file'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered buffer plugin 'memory'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'debug_agent'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'exec'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'forward'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'gc_stat'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'http'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'monitor_agent'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'object_space'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'status'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'tcp'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'unix'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'syslog'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered input plugin 'tail'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'copy'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'exec'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'exec_filter'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'file'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'forward'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'null'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'roundrobin'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'stdout'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'tcp'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'unix'
2013-11-17 18:31:17 +0900 [trace]: fluent/plugin.rb:87:register_impl: registered output plugin 'test'
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:85:block in configure: gem 'fluentd' version '0.10.40'
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:85:block in configure: gem 'fluentd' version '0.10.39'
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:89:configure: using configuration file: <ROOT>
<source>
type forward
</source>
<source>
type http
port 8888
</source>
<source>
type monitor_agent
port 24220
</source>
<source>
type debug_agent
port 24230
</source>
<match debug.**>
type stdout
</match>
<match system.**>
type forward
host 192.168.0.11
<secondary>
host 192.168.0.12
</secondary>
</match>
</ROOT>
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:99:block in configure: adding source type="forward"
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:99:block in configure: adding source type="http"
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:99:block in configure: adding source type="monitor_agent"
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:99:block in configure: adding source type="debug_agent"
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:115:block in configure: adding match pattern="debug.**" type="stdout"
2013-11-17 18:31:17 +0900 [info]: fluent/engine.rb:115:block in configure: adding match pattern="system.**" type="forward"
2013-11-17 18:31:17 +0900 [warn]: plugin/out_forward.rb:57:configure: 'host' option in forward output is obsoleted. Use '<server> host xxx </server>' instead.
2013-11-17 18:31:17 +0900 [info]: plugin/out_forward.rb:87:block in configure: adding forwarding server '192.168.0.12:24224' host="192.168.0.12" port=24224 weight=60
2013-11-17 18:31:17 +0900 [warn]: plugin/out_forward.rb:57:configure: 'host' option in forward output is obsoleted. Use '<server> host xxx </server>' instead.
2013-11-17 18:31:17 +0900 [info]: plugin/out_forward.rb:87:block in configure: adding forwarding server '192.168.0.11:24224' host="192.168.0.11" port=24224 weight=60
2013-11-17 18:31:17 +0900 [debug]: plugin/out_forward.rb:170:rebuild_weight_array: rebuilding weight array lost_weight=0
2013-11-17 18:31:17 +0900 [debug]: plugin/out_forward.rb:170:rebuild_weight_array: rebuilding weight array lost_weight=0
2013-11-17 18:31:17 +0900 [info]: plugin/in_forward.rb:64:listen: listening fluent socket on 0.0.0.0:24224
2013-11-17 18:31:17 +0900 [debug]: plugin/in_http.rb:73:start: listening http on 0.0.0.0:8888
2013-11-17 18:31:17 +0900 [debug]: plugin/in_monitor_agent.rb:157:start: listening monitoring http server on http://0.0.0.0:24220/api/plugins
2013-11-17 18:31:17 +0900 [info]: plugin/in_debug_agent.rb:44:start: listening dRuby uri="druby://0.0.0.0:24230" object="Engine"
2013-11-17 18:31:20 +0900 [trace]: plugin/in_forward.rb:152:initialize: accepted fluent socket object_id=6823540
1970-01-01 09:00:01 +0900 debug.access: 0 *********************<= here! ***************************
2013-11-17 18:31:20 +0900 [trace]: plugin/in_forward.rb:193:on_close: closed fluent socket object_id=6823540
2013-11-17 18:31:23 +0900 [debug]: fluent/supervisor.rb:222:block in install_supervisor_signal_handlers: fluentd supervisor process get SIGINT
2013-11-17 18:31:23 +0900 [debug]: fluent/supervisor.rb:343:block in install_main_process_signal_handlers: fluentd main process get SIGINT
2013-11-17 18:31:23 +0900 [debug]: fluent/supervisor.rb:343:block in install_main_process_signal_handlers: fluentd main process get SIGINT
2013-11-17 18:31:23 +0900 [debug]: fluent/supervisor.rb:346:block in install_main_process_signal_handlers: getting start to shutdown main process
2013-11-17 18:31:23 +0900 [info]: fluent/engine.rb:221:run: shutting down fluentd
2013-11-17 18:31:23 +0900 [info]: fluent/supervisor.rb:186:supervise: process finished code=0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment