This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2011-10-28 17:16:59 +0900: failed to flush the buffer error="incompatible character encodings: ASCII-8BIT and UTF-8" | |
2011-10-28 17:16:59 +0900: /home/hoge/.rvm/gems/ruby-1.9.2-p180/gems/thrift-0.7.0/lib/thrift/transport/framed_transport.rb:84:in `write' | |
2011-10-28 17:16:59 +0900: /home/hoge/.rvm/gems/ruby-1.9.2-p180/gems/thrift-0.7.0/lib/thrift/protocol/binary_protocol.rb:112:in `write_string' | |
2011-10-28 17:16:59 +0900: /home/hoge/.rvm/gems/ruby-1.9.2-p180/gems/thrift-0.7.0/lib/thrift/client.rb:35:in `write' | |
2011-10-28 17:16:59 +0900: /home/hoge/.rvm/gems/ruby-1.9.2-p180/gems/thrift-0.7.0/lib/thrift/client.rb:35:in `send_message' | |
2011-10-28 17:16:59 +0900: /home/hoge/.rvm/gems/ruby-1.9.2-p180/gems/fluent-plugin-scribe-0.10.3/lib/fluent/plugin/thrift/scribe.rb:21:in `send_Log' | |
2011-10-28 17:16:59 +0900: /home/hoge/.rvm/gems/ruby-1.9.2-p180/gems/fluent-plugin-scribe-0.10.3/lib/fluent/plugin/thrift/scribe.rb:16:in `Log' | |
2011-10-28 17:16:59 +0900: /home/hoge/.rvm/gems/ruby-1.9.2-p180/gems/fluent-plu |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env ruby | |
source_file = ARGV.shift | |
target_host = ARGV.shift | |
target_port = ARGV.shift | |
target_path = ARGV.shift | |
username = ARGV.shift | |
lasting_seconds = ARGV.shift.to_i |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env perl | |
use 5.14.0; | |
my $odata = '============================================================================================================================================================================================================================================================================================================'; | |
my $data_length = length($odata); | |
my $seq = {first => [], second => [], third => [], forth => []}; | |
my $lines = 0; | |
my $bytes = 0; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env perl | |
use 5.14.0; | |
my $seq = {first => [], second => [], third => [], forth => []}; | |
my $lines = 0; | |
my $bytes = 0; | |
my $broken = 0; | |
while(my $line = <STDIN>){ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env ruby | |
require 'net/http' | |
(host,port,username,path) = ARGV | |
port = port.to_i | |
data = '============================================================================================================================================================================================================================================================================================================' | |
$i = 0 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<source> | |
type scribe | |
# 14631, 14632, 14633, 14634 | |
port 14631 | |
add_prefix scribe | |
</source> | |
<match scribe.*> | |
type hoop | |
hoop_server hoop-server.local:14000 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
OK, I understand what is not supported (now?). | |
In this case, hoop server should send response message means correct reason, like | |
'concurrent append not supported'. | |
But now, in fact, hoop send message as 'failed to create file'. We cannot know what is wrong | |
from this message. (request method? wrong path? or ...?) | |
This is wrong message, and i want to be fixed. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
$ ack dfs.block.size | |
hoop-server/src/main/java/com/cloudera/hoop/fs/FSCreate.java | |
72: blockSize = fs.getConf().getInt("dfs.block.size", 67108864); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2012-01-10 18:16:09 +0900: failed to flush the buffer, retrying. error="undefined method `write' for nil:NilClass" instance=76009820 | |
2012-01-10 18:16:09 +0900: /home/username/.rvm/gems/ruby-1.9.2-p180/gems/fluentd-0.10.8/lib/fluent/plugin/out_exec_filter.rb:139:in `write' | |
2012-01-10 18:16:09 +0900: /home/username/.rvm/gems/ruby-1.9.2-p180/gems/fluentd-0.10.8/lib/fluent/buffer.rb:262:in `write_chunk' | |
2012-01-10 18:16:09 +0900: /home/username/.rvm/gems/ruby-1.9.2-p180/gems/fluentd-0.10.8/lib/fluent/buffer.rb:246:in `pop' | |
2012-01-10 18:16:09 +0900: /home/username/.rvm/gems/ruby-1.9.2-p180/gems/fluentd-0.10.8/lib/fluent/output.rb:299:in `try_flush' | |
2012-01-10 18:16:09 +0900: /home/username/.rvm/gems/ruby-1.9.2-p180/gems/fluentd-0.10.8/lib/fluent/output.rb:121:in `run' |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2012-02-11 16:23:43 +0900: detected rotation of /tmp/symlink; waiting 5 seconds | |
2012-02-11 16:23:45 +0900: unexpected error error="undefined method `call' for #<Fluent::TailInput::RotateHandler:0x0000010229f6c8>" | |
2012-02-11 16:23:45 +0900: /Users/tagomoris/Documents/fluentd/lib/fluent/plugin/in_tail.rb:241:in `on_change' | |
2012-02-11 16:23:45 +0900: /Users/tagomoris/.rvm/gems/ruby-1.9.2-p290/gems/cool.io-1.1.0/lib/cool.io/loop.rb:96:in `run_once' | |
2012-02-11 16:23:45 +0900: /Users/tagomoris/.rvm/gems/ruby-1.9.2-p290/gems/cool.io-1.1.0/lib/cool.io/loop.rb:96:in `run' | |
2012-02-11 16:23:45 +0900: /Users/tagomoris/Documents/fluentd/lib/fluent/plugin/in_tail.rb:76:in `run' |