summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2025-07-03 16:13:26 +0300
committerPaul Buetow <paul@buetow.org>2025-07-03 16:13:26 +0300
commitf1ae8e6eb80c8f2f4b4b18b5b93893ad3249c6a1 (patch)
treea9348d535148dae1a93f1b08e17d9870a30e7c75
parenta4eb3cc769c13312fdd4b7aaa20659e408f734b7 (diff)
fix: implement thread-safe turbo mode for MapReduce operations
- Add SafeAggregateSet wrapper with mutex protection for concurrent access - Implement TurboAggregate for direct line processing without channels - Fix race conditions in turbo mode MapReduce aggregation - Add proper synchronization for batch processing completion - Update shutdown sequence to ensure all data is serialized - Add integration test configuration for high-concurrency scenarios The turbo mode now correctly handles MapReduce queries with significant performance improvements while maintaining data integrity and preventing race conditions during concurrent aggregation. 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude <noreply@anthropic.com>
Diffstat
-rw-r--r--CLAUDE.md34
-rw-r--r--go.mod6
-rw-r--r--go.sum14
-rw-r--r--integrationtests/dmap_test.go5
-rw-r--r--integrationtests/mapr_testdata.log1202
-rw-r--r--integrationtests/test_server_100files.json8
-rw-r--r--integrationtests/testhelpers.go10
-rw-r--r--internal/mapr/safe_aggregateset.go71
-rw-r--r--internal/mapr/safe_aggregateset_test.go147
-rw-r--r--internal/mapr/server/aggregate.go70
-rw-r--r--internal/mapr/server/turbo_aggregate.go415
-rw-r--r--internal/server/handlers/basehandler.go15
-rw-r--r--internal/server/handlers/mapcommand.go32
-rw-r--r--internal/server/handlers/readcommand.go36
-rw-r--r--internal/server/handlers/serverhandler.go3
15 files changed, 1419 insertions, 649 deletions
diff --git a/CLAUDE.md b/CLAUDE.md
index b8218a6..52f7b14 100644
--- a/CLAUDE.md
+++ b/CLAUDE.md
@@ -114,14 +114,32 @@ make profile-help
## Known Limitations
-### Turbo Mode with High-Concurrency MapReduce Operations
-When DTAIL_TURBOBOOST_ENABLE is set and processing many files concurrently (e.g., 100+ files) with MapReduce operations in server mode, data accuracy issues may occur due to the interaction between turbo mode's optimized processing and the aggregate's channel management system. This issue does not affect serverless mode.
-
-**Workarounds:**
-1. Disable turbo mode for high-concurrency MapReduce operations: `unset DTAIL_TURBOBOOST_ENABLE`
-2. Increase MaxConcurrentCats in the server configuration to match the number of files
-3. Process files in smaller batches
-4. Use serverless mode for MapReduce operations when possible
+### Turbo Mode and MapReduce Operations
+Turbo mode (DTAIL_TURBOBOOST_ENABLE) provides performance optimizations for both direct output operations (cat, grep, tail) and MapReduce operations when running in server mode.
+
+**Technical Details:**
+- For cat/grep/tail: Turbo mode bypasses channels for direct writing
+- For MapReduce in server mode: Turbo mode uses direct line processing without channels
+- For MapReduce in serverless/client mode: Turbo mode is not applicable (client-side aggregation doesn't use server optimizations)
+
+**Server-Side Turbo MapReduce:**
+When turbo mode is enabled and using dserver:
+- Lines are processed directly without channel overhead
+- Batch processing reduces lock contention
+- Memory pooling reduces garbage collection pressure
+- Same output format and accuracy as regular MapReduce
+
+**High-Concurrency MapReduce Improvements:**
+- Channel recycling ensures proper draining before reuse (regular mode)
+- Buffer sizes increased from 1,000 to 10,000 for better concurrency
+- Direct processing in turbo mode eliminates channel bottlenecks
+- Improved synchronization in both regular and turbo aggregate implementations
+
+**Best Practices for High-Concurrency MapReduce:**
+1. Enable turbo mode for server deployments: `export DTAIL_TURBOBOOST_ENABLE=yes`
+2. Increase MaxConcurrentCats in the server configuration to match workload
+3. Use server mode for large-scale MapReduce operations
+4. Monitor logs for performance metrics
## Benchmarking & Profiling
diff --git a/go.mod b/go.mod
index 8af4315..ee6402d 100644
--- a/go.mod
+++ b/go.mod
@@ -8,4 +8,8 @@ require (
golang.org/x/term v0.32.0
)
-require golang.org/x/sys v0.33.0 // indirect
+require (
+ golang.org/x/lint v0.0.0-20241112194109-818c5a804067 // indirect
+ golang.org/x/sys v0.33.0 // indirect
+ golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7 // indirect
+)
diff --git a/go.sum b/go.sum
index ccb17f9..a61b4fa 100644
--- a/go.sum
+++ b/go.sum
@@ -1,8 +1,22 @@
github.com/DataDog/zstd v1.5.7 h1:ybO8RBeh29qrxIhCA9E8gKY6xfONU9T6G6aP9DTKfLE=
github.com/DataDog/zstd v1.5.7/go.mod h1:g4AWEaM3yOg3HYfnJ3YIawPnVdXJh9QME85blwSAmyw=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
golang.org/x/crypto v0.39.0 h1:SHs+kF4LP+f+p14esP5jAoDpHU8Gu/v9lFRK6IT5imM=
golang.org/x/crypto v0.39.0/go.mod h1:L+Xg3Wf6HoL4Bn4238Z6ft6KfEpN0tJGo53AAPC632U=
+golang.org/x/lint v0.0.0-20241112194109-818c5a804067 h1:adDmSQyFTCiv19j015EGKJBoaa7ElV0Q1Wovb/4G7NA=
+golang.org/x/lint v0.0.0-20241112194109-818c5a804067/go.mod h1:3xt1FjdF8hUf6vQPIChWIBhFzV8gjjsPE/fR3IyQdNY=
+golang.org/x/mod v0.1.1-0.20191105210325-c90efee705ee/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg=
+golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
golang.org/x/term v0.32.0 h1:DR4lr0TjUs3epypdhTOkMmuF5CDFJ/8pOnbzMZPQ7bg=
golang.org/x/term v0.32.0/go.mod h1:uZG1FhGx848Sqfsq4/DlJr3xGGsYMu/L5GW4abiaEPQ=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7 h1:EBZoQjiKKPaLbPrbpssUfuHtwM6KV/vb4U85g/cigFY=
+golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28=
+golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
diff --git a/integrationtests/dmap_test.go b/integrationtests/dmap_test.go
index fc51b3c..243ceeb 100644
--- a/integrationtests/dmap_test.go
+++ b/integrationtests/dmap_test.go
@@ -251,7 +251,8 @@ func testDMap3Serverless(t *testing.T, logger *TestLogger) {
}
// Simply run dmap with multiple input files directly
- ctxTimeout, cancel := createTestContextWithTimeout(t)
+ // Use longer timeout for processing 100 files
+ ctxTimeout, cancel := createTestContextWithLongTimeout(t)
ctx := WithTestLogger(ctxTimeout, logger)
defer cancel()
@@ -288,7 +289,7 @@ func testDMap3WithServer(t *testing.T, logger *TestLogger) {
Port: server.port,
BindAddress: server.bindAddress,
LogLevel: "error",
- ExtraArgs: []string{"--cfg", "test_server_complete.json"},
+ ExtraArgs: []string{"--cfg", "test_server_100files.json"},
Env: map[string]string{"DTAIL_TURBOBOOST_ENABLE": "yes"},
}
if err := server.StartWithConfig(cfg); err != nil {
diff --git a/integrationtests/mapr_testdata.log b/integrationtests/mapr_testdata.log
index bec8774..6be9f22 100644
--- a/integrationtests/mapr_testdata.log
+++ b/integrationtests/mapr_testdata.log
@@ -1,597 +1,613 @@
+INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|17|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|17|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
INFO|1002-071143|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|17|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
INFO|1002-071143|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
INFO|1002-071143|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|17|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071143|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
INFO|1002-071143|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|lifetimeConnections=1|currentConnections=0
-INFO|1002-071143|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|lifetimeConnections=1|currentConnections=0
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=1
-INFO|1002-071143|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|lifetimeConnections=1|currentConnections=1
-INFO|1002-071143|1|stats.go:56|8|17|7|0.21|471h0m21s|MAPREDUCE:STATS|lifetimeConnections=1|currentConnections=0
-INFO|1002-071146|1|stats.go:56|8|11|7|0.19|471h0m23s|MAPREDUCE:STATS|lifetimeConnections=1|currentConnections=0
-INFO|1002-071146|1|stats.go:56|8|11|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
-INFO|1002-071146|1|stats.go:56|8|11|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
-INFO|1002-071147|1|stats.go:56|8|12|7|0.19|471h0m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|12|7|0.19|471h0m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|12|7|0.19|471h0m25s|MAPREDUCE:STATS|lifetimeConnections=2|currentConnections=0
-INFO|1002-071147|1|stats.go:56|8|13|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|13|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|14|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|14|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|14|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|14|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|14|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|14|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|14|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|14|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|15|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|15|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|15|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|16|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|16|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|16|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|16|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|16|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|16|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071147|1|stats.go:56|8|16|7|0.19|471h0m24s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=2
-INFO|1002-071148|1|stats.go:56|8|11|7|0.19|471h0m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071148|1|stats.go:56|8|11|7|0.19|471h0m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071149|1|stats.go:56|8|11|7|0.19|471h0m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071149|1|stats.go:56|8|11|7|0.19|471h0m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071156|1|stats.go:56|8|11|7|0.24|471h0m33s|MAPREDUCE:STATS|lifetimeConnections=2|currentConnections=0
-INFO|1002-071156|1|stats.go:56|8|11|7|0.24|471h0m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071156|1|stats.go:56|8|11|7|0.24|471h0m34s|MAPREDUCE:STATS|lifetimeConnections=2|currentConnections=0
-INFO|1002-071157|1|stats.go:56|8|11|7|0.24|471h0m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071157|1|stats.go:56|8|11|7|0.24|471h0m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071157|1|stats.go:56|8|11|7|0.24|471h0m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071158|1|stats.go:56|8|11|7|0.24|471h0m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071158|1|stats.go:56|8|11|7|0.24|471h0m36s|MAPREDUCE:STATS|lifetimeConnections=2|currentConnections=0
-INFO|1002-071159|1|stats.go:56|8|11|7|0.24|471h0m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071159|1|stats.go:56|8|11|7|0.24|471h0m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071206|1|stats.go:56|8|11|7|0.20|471h0m43s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071206|1|stats.go:56|8|11|7|0.20|471h0m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071206|1|stats.go:56|8|11|7|0.20|471h0m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071207|1|stats.go:56|8|11|7|0.20|471h0m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071207|1|stats.go:56|8|11|7|0.20|471h0m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071208|1|stats.go:56|8|11|7|0.20|471h0m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071208|1|stats.go:56|8|11|7|0.20|471h0m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071208|1|stats.go:56|8|11|7|0.20|471h0m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071209|1|stats.go:56|8|11|7|0.20|471h0m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071209|1|stats.go:56|8|11|7|0.20|471h0m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=2
-INFO|1002-071213|1|stats.go:56|8|12|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|12|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|12|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|12|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|12|7|0.26|471h0m50s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071213|1|stats.go:56|8|13|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|13|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|13|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|15|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|16|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071213|1|stats.go:56|8|17|7|0.26|471h0m50s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071216|1|stats.go:56|8|11|7|0.24|471h0m53s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071216|1|stats.go:56|8|11|7|0.24|471h0m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071216|1|stats.go:56|8|11|7|0.24|471h0m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071217|1|stats.go:56|8|11|7|0.24|471h0m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071217|1|stats.go:56|8|11|7|0.24|471h0m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071218|1|stats.go:56|8|11|7|0.24|471h0m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071218|1|stats.go:56|8|11|7|0.24|471h0m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071218|1|stats.go:56|8|11|7|0.24|471h0m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071219|1|stats.go:56|8|11|7|0.24|471h0m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071219|1|stats.go:56|8|11|7|0.24|471h0m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071226|1|stats.go:56|8|11|7|0.28|471h1m3s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071226|1|stats.go:56|8|11|7|0.28|471h1m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071226|1|stats.go:56|8|11|7|0.28|471h1m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071227|1|stats.go:56|8|11|7|0.28|471h1m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071227|1|stats.go:56|8|11|7|0.28|471h1m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071228|1|stats.go:56|8|11|7|0.28|471h1m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071228|1|stats.go:56|8|11|7|0.28|471h1m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071228|1|stats.go:56|8|11|7|0.28|471h1m6s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071229|1|stats.go:56|8|11|7|0.28|471h1m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071229|1|stats.go:56|8|11|7|0.28|471h1m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071236|1|stats.go:56|8|11|7|0.32|471h1m13s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071236|1|stats.go:56|8|11|7|0.32|471h1m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071236|1|stats.go:56|8|11|7|0.32|471h1m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071237|1|stats.go:56|8|11|7|0.32|471h1m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071237|1|stats.go:56|8|11|7|0.32|471h1m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071238|1|stats.go:56|8|11|7|0.32|471h1m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071238|1|stats.go:56|8|11|7|0.32|471h1m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071238|1|stats.go:56|8|11|7|0.32|471h1m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071239|1|stats.go:56|8|11|7|0.32|471h1m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071239|1|stats.go:56|8|11|7|0.32|471h1m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071246|1|stats.go:56|8|11|7|0.27|471h1m23s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071246|1|stats.go:56|8|11|7|0.27|471h1m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071246|1|stats.go:56|8|11|7|0.27|471h1m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071247|1|stats.go:56|8|11|7|0.27|471h1m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071247|1|stats.go:56|8|11|7|0.27|471h1m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071248|1|stats.go:56|8|11|7|0.27|471h1m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071248|1|stats.go:56|8|11|7|0.27|471h1m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071248|1|stats.go:56|8|11|7|0.27|471h1m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071249|1|stats.go:56|8|11|7|0.27|471h1m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071249|1|stats.go:56|8|11|7|0.27|471h1m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071256|1|stats.go:56|8|11|7|0.23|471h1m33s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071256|1|stats.go:56|8|11|7|0.23|471h1m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071256|1|stats.go:56|8|11|7|0.23|471h1m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071257|1|stats.go:56|8|11|7|0.23|471h1m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071257|1|stats.go:56|8|11|7|0.23|471h1m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071258|1|stats.go:56|8|11|7|0.23|471h1m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071258|1|stats.go:56|8|11|7|0.23|471h1m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071258|1|stats.go:56|8|11|7|0.23|471h1m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071259|1|stats.go:56|8|11|7|0.23|471h1m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071259|1|stats.go:56|8|11|7|0.23|471h1m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071306|1|stats.go:56|8|11|7|0.35|471h1m43s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071306|1|stats.go:56|8|11|7|0.35|471h1m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071306|1|stats.go:56|8|11|7|0.35|471h1m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071307|1|stats.go:56|8|11|7|0.35|471h1m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071307|1|stats.go:56|8|11|7|0.35|471h1m45s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071308|1|stats.go:56|8|11|7|0.35|471h1m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071308|1|stats.go:56|8|11|7|0.35|471h1m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071308|1|stats.go:56|8|11|7|0.35|471h1m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071309|1|stats.go:56|8|11|7|0.35|471h1m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071309|1|stats.go:56|8|11|7|0.35|471h1m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071316|1|stats.go:56|8|11|7|0.38|471h1m53s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071316|1|stats.go:56|8|11|7|0.38|471h1m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071316|1|stats.go:56|8|11|7|0.38|471h1m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071317|1|stats.go:56|8|11|7|0.38|471h1m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071317|1|stats.go:56|8|11|7|0.38|471h1m55s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071318|1|stats.go:56|8|11|7|0.38|471h1m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071318|1|stats.go:56|8|11|7|0.38|471h1m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071318|1|stats.go:56|8|11|7|0.38|471h1m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071319|1|stats.go:56|8|11|7|0.38|471h1m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071319|1|stats.go:56|8|11|7|0.38|471h1m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071326|1|stats.go:56|8|11|7|0.32|471h2m3s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071326|1|stats.go:56|8|11|7|0.32|471h2m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071326|1|stats.go:56|8|11|7|0.32|471h2m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071327|1|stats.go:56|8|11|7|0.32|471h2m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071327|1|stats.go:56|8|11|7|0.32|471h2m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071328|1|stats.go:56|8|11|7|0.32|471h2m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071328|1|stats.go:56|8|11|7|0.32|471h2m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071328|1|stats.go:56|8|11|7|0.32|471h2m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071329|1|stats.go:56|8|11|7|0.32|471h2m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071329|1|stats.go:56|8|11|7|0.32|471h2m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071336|1|stats.go:56|8|11|7|0.35|471h2m13s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071336|1|stats.go:56|8|11|7|0.35|471h2m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071336|1|stats.go:56|8|11|7|0.35|471h2m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071337|1|stats.go:56|8|11|7|0.35|471h2m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071337|1|stats.go:56|8|11|7|0.35|471h2m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071338|1|stats.go:56|8|11|7|0.35|471h2m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071338|1|stats.go:56|8|11|7|0.35|471h2m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071338|1|stats.go:56|8|11|7|0.35|471h2m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071339|1|stats.go:56|8|11|7|0.35|471h2m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071339|1|stats.go:56|8|11|7|0.35|471h2m17s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071346|1|stats.go:56|8|11|7|0.30|471h2m23s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071346|1|stats.go:56|8|11|7|0.30|471h2m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071346|1|stats.go:56|8|11|7|0.30|471h2m24s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071347|1|stats.go:56|8|11|7|0.30|471h2m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071347|1|stats.go:56|8|11|7|0.30|471h2m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071348|1|stats.go:56|8|11|7|0.30|471h2m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071348|1|stats.go:56|8|11|7|0.30|471h2m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071348|1|stats.go:56|8|11|7|0.30|471h2m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071349|1|stats.go:56|8|11|7|0.30|471h2m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071349|1|stats.go:56|8|11|7|0.30|471h2m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071356|1|stats.go:56|8|11|7|0.57|471h2m33s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071356|1|stats.go:56|8|11|7|0.57|471h2m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071356|1|stats.go:56|8|11|7|0.57|471h2m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071357|1|stats.go:56|8|11|7|0.57|471h2m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071357|1|stats.go:56|8|11|7|0.57|471h2m35s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071358|1|stats.go:56|8|11|7|0.57|471h2m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071358|1|stats.go:56|8|11|7|0.57|471h2m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071358|1|stats.go:56|8|11|7|0.57|471h2m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071359|1|stats.go:56|8|11|7|0.57|471h2m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071359|1|stats.go:56|8|11|7|0.57|471h2m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071406|1|stats.go:56|8|11|7|0.48|471h2m43s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071406|1|stats.go:56|8|11|7|0.48|471h2m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071406|1|stats.go:56|8|11|7|0.48|471h2m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071407|1|stats.go:56|8|11|7|0.48|471h2m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071407|1|stats.go:56|8|11|7|0.48|471h2m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071408|1|stats.go:56|8|11|7|0.48|471h2m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071408|1|stats.go:56|8|11|7|0.48|471h2m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071408|1|stats.go:56|8|11|7|0.48|471h2m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071409|1|stats.go:56|8|11|7|0.48|471h2m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071409|1|stats.go:56|8|11|7|0.48|471h2m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071416|1|stats.go:56|8|11|7|0.49|471h2m53s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071416|1|stats.go:56|8|11|7|0.49|471h2m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071416|1|stats.go:56|8|11|7|0.49|471h2m54s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071417|1|stats.go:56|8|11|7|0.49|471h2m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071417|1|stats.go:56|8|11|7|0.49|471h2m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071418|1|stats.go:56|8|11|7|0.49|471h2m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071418|1|stats.go:56|8|11|7|0.49|471h2m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071418|1|stats.go:56|8|11|7|0.49|471h2m56s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071419|1|stats.go:56|8|11|7|0.49|471h2m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071419|1|stats.go:56|8|11|7|0.49|471h2m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071426|1|stats.go:56|8|11|7|0.41|471h3m3s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071426|1|stats.go:56|8|11|7|0.41|471h3m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071426|1|stats.go:56|8|11|7|0.41|471h3m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071427|1|stats.go:56|8|11|7|0.41|471h3m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071427|1|stats.go:56|8|11|7|0.41|471h3m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071428|1|stats.go:56|8|11|7|0.41|471h3m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071428|1|stats.go:56|8|11|7|0.41|471h3m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071428|1|stats.go:56|8|11|7|0.41|471h3m6s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071429|1|stats.go:56|8|11|7|0.41|471h3m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071429|1|stats.go:56|8|11|7|0.41|471h3m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071436|1|stats.go:56|8|11|7|0.35|471h3m13s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071436|1|stats.go:56|8|11|7|0.35|471h3m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071436|1|stats.go:56|8|11|7|0.35|471h3m14s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071437|1|stats.go:56|8|11|7|0.35|471h3m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071437|1|stats.go:56|8|11|7|0.35|471h3m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071438|1|stats.go:56|8|11|7|0.35|471h3m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071438|1|stats.go:56|8|11|7|0.35|471h3m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071438|1|stats.go:56|8|11|7|0.35|471h3m16s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071439|1|stats.go:56|8|11|7|0.35|471h3m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071439|1|stats.go:56|8|11|7|0.35|471h3m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071446|1|stats.go:56|8|11|7|0.29|471h3m23s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071446|1|stats.go:56|8|11|7|0.29|471h3m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071446|1|stats.go:56|8|11|7|0.29|471h3m24s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071447|1|stats.go:56|8|11|7|0.29|471h3m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071447|1|stats.go:56|8|11|7|0.29|471h3m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071448|1|stats.go:56|8|11|7|0.29|471h3m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071448|1|stats.go:56|8|11|7|0.29|471h3m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071448|1|stats.go:56|8|11|7|0.29|471h3m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071449|1|stats.go:56|8|11|7|0.29|471h3m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071449|1|stats.go:56|8|11|7|0.29|471h3m27s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071456|1|stats.go:56|8|11|7|0.25|471h3m33s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071456|1|stats.go:56|8|11|7|0.25|471h3m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071456|1|stats.go:56|8|11|7|0.25|471h3m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071457|1|stats.go:56|8|11|7|0.25|471h3m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071457|1|stats.go:56|8|11|7|0.25|471h3m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071458|1|stats.go:56|8|11|7|0.25|471h3m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071458|1|stats.go:56|8|11|7|0.25|471h3m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071458|1|stats.go:56|8|11|7|0.25|471h3m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071459|1|stats.go:56|8|11|7|0.25|471h3m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071459|1|stats.go:56|8|11|7|0.25|471h3m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071506|1|stats.go:56|8|11|7|0.28|471h3m43s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071506|1|stats.go:56|8|11|7|0.28|471h3m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071506|1|stats.go:56|8|11|7|0.28|471h3m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071507|1|stats.go:56|8|11|7|0.28|471h3m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071507|1|stats.go:56|8|11|7|0.28|471h3m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071508|1|stats.go:56|8|11|7|0.28|471h3m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071508|1|stats.go:56|8|11|7|0.28|471h3m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071508|1|stats.go:56|8|11|7|0.28|471h3m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071509|1|stats.go:56|8|11|7|0.28|471h3m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071509|1|stats.go:56|8|11|7|0.28|471h3m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071516|1|stats.go:56|8|11|7|0.24|471h3m53s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071516|1|stats.go:56|8|11|7|0.24|471h3m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071516|1|stats.go:56|8|11|7|0.24|471h3m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071517|1|stats.go:56|8|11|7|0.24|471h3m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071517|1|stats.go:56|8|11|7|0.24|471h3m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071518|1|stats.go:56|8|11|7|0.24|471h3m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071518|1|stats.go:56|8|11|7|0.24|471h3m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071519|1|stats.go:56|8|11|7|0.24|471h3m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071519|1|stats.go:56|8|11|7|0.24|471h3m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071519|1|stats.go:56|8|11|7|0.24|471h3m57s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071526|1|stats.go:56|8|11|7|0.20|471h4m3s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071526|1|stats.go:56|8|11|7|0.20|471h4m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071526|1|stats.go:56|8|11|7|0.20|471h4m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071527|1|stats.go:56|8|11|7|0.20|471h4m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071527|1|stats.go:56|8|11|7|0.20|471h4m5s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071528|1|stats.go:56|8|11|7|0.20|471h4m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071528|1|stats.go:56|8|11|7|0.20|471h4m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071529|1|stats.go:56|8|11|7|0.20|471h4m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071529|1|stats.go:56|8|11|7|0.20|471h4m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071529|1|stats.go:56|8|11|7|0.20|471h4m7s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071536|1|stats.go:56|8|11|7|0.17|471h4m13s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071536|1|stats.go:56|8|11|7|0.17|471h4m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071536|1|stats.go:56|8|11|7|0.17|471h4m14s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071537|1|stats.go:56|8|11|7|0.17|471h4m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071537|1|stats.go:56|8|11|7|0.17|471h4m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071538|1|stats.go:56|8|11|7|0.17|471h4m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071538|1|stats.go:56|8|11|7|0.17|471h4m16s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071539|1|stats.go:56|8|11|7|0.17|471h4m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071539|1|stats.go:56|8|11|7|0.17|471h4m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071539|1|stats.go:56|8|11|7|0.17|471h4m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071546|1|stats.go:56|8|11|7|0.14|471h4m23s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071546|1|stats.go:56|8|11|7|0.14|471h4m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071546|1|stats.go:56|8|11|7|0.14|471h4m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071547|1|stats.go:56|8|11|7|0.14|471h4m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071547|1|stats.go:56|8|11|7|0.14|471h4m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071548|1|stats.go:56|8|11|7|0.14|471h4m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071548|1|stats.go:56|8|11|7|0.14|471h4m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071549|1|stats.go:56|8|11|7|0.14|471h4m26s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071549|1|stats.go:56|8|11|7|0.14|471h4m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071549|1|stats.go:56|8|11|7|0.14|471h4m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071556|1|stats.go:56|8|11|7|0.12|471h4m33s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071556|1|stats.go:56|8|11|7|0.12|471h4m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071556|1|stats.go:56|8|11|7|0.12|471h4m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071557|1|stats.go:56|8|11|7|0.12|471h4m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071557|1|stats.go:56|8|11|7|0.12|471h4m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071558|1|stats.go:56|8|11|7|0.12|471h4m35s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071558|1|stats.go:56|8|11|7|0.12|471h4m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071559|1|stats.go:56|8|11|7|0.12|471h4m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071559|1|stats.go:56|8|11|7|0.12|471h4m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071559|1|stats.go:56|8|11|7|0.12|471h4m37s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071606|1|stats.go:56|8|11|7|0.18|471h4m43s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071606|1|stats.go:56|8|11|7|0.18|471h4m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071606|1|stats.go:56|8|11|7|0.18|471h4m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071607|1|stats.go:56|8|11|7|0.18|471h4m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071607|1|stats.go:56|8|11|7|0.18|471h4m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071608|1|stats.go:56|8|11|7|0.18|471h4m45s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071608|1|stats.go:56|8|11|7|0.18|471h4m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071609|1|stats.go:56|8|11|7|0.18|471h4m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071609|1|stats.go:56|8|11|7|0.18|471h4m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071609|1|stats.go:56|8|11|7|0.18|471h4m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071616|1|stats.go:56|8|11|7|0.22|471h4m53s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071616|1|stats.go:56|8|11|7|0.22|471h4m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071617|1|stats.go:56|8|11|7|0.22|471h4m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071617|1|stats.go:56|8|11|7|0.22|471h4m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071617|1|stats.go:56|8|11|7|0.22|471h4m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071618|1|stats.go:56|8|11|7|0.22|471h4m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071618|1|stats.go:56|8|11|7|0.22|471h4m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071619|1|stats.go:56|8|11|7|0.22|471h4m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071619|1|stats.go:56|8|11|7|0.22|471h4m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071619|1|stats.go:56|8|11|7|0.22|471h4m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071626|1|stats.go:56|8|11|7|0.27|471h5m3s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071626|1|stats.go:56|8|11|7|0.27|471h5m4s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071627|1|stats.go:56|8|11|7|0.27|471h5m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071627|1|stats.go:56|8|11|7|0.27|471h5m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071627|1|stats.go:56|8|11|7|0.27|471h5m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071628|1|stats.go:56|8|11|7|0.27|471h5m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071628|1|stats.go:56|8|11|7|0.27|471h5m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071629|1|stats.go:56|8|11|7|0.27|471h5m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071629|1|stats.go:56|8|11|7|0.27|471h5m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071629|1|stats.go:56|8|11|7|0.27|471h5m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071636|1|stats.go:56|8|11|7|0.46|471h5m13s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071636|1|stats.go:56|8|11|7|0.46|471h5m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071637|1|stats.go:56|8|11|7|0.46|471h5m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071637|1|stats.go:56|8|11|7|0.46|471h5m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071637|1|stats.go:56|8|11|7|0.46|471h5m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071638|1|stats.go:56|8|11|7|0.46|471h5m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071638|1|stats.go:56|8|11|7|0.46|471h5m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071639|1|stats.go:56|8|11|7|0.46|471h5m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071639|1|stats.go:56|8|11|7|0.46|471h5m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071639|1|stats.go:56|8|11|7|0.46|471h5m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071646|1|stats.go:56|8|11|7|0.39|471h5m23s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071646|1|stats.go:56|8|11|7|0.39|471h5m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071647|1|stats.go:56|8|11|7|0.39|471h5m24s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071647|1|stats.go:56|8|11|7|0.39|471h5m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071647|1|stats.go:56|8|11|7|0.39|471h5m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071648|1|stats.go:56|8|11|7|0.39|471h5m25s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071648|1|stats.go:56|8|11|7|0.39|471h5m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071649|1|stats.go:56|8|11|7|0.39|471h5m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071649|1|stats.go:56|8|11|7|0.39|471h5m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071649|1|stats.go:56|8|11|7|0.39|471h5m27s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071656|1|stats.go:56|8|11|7|0.33|471h5m33s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071656|1|stats.go:56|8|11|7|0.33|471h5m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071657|1|stats.go:56|8|11|7|0.33|471h5m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071657|1|stats.go:56|8|11|7|0.33|471h5m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071657|1|stats.go:56|8|11|7|0.33|471h5m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071658|1|stats.go:56|8|11|7|0.33|471h5m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071658|1|stats.go:56|8|11|7|0.33|471h5m36s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071659|1|stats.go:56|8|11|7|0.33|471h5m36s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071659|1|stats.go:56|8|11|7|0.33|471h5m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071659|1|stats.go:56|8|11|7|0.33|471h5m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071706|1|stats.go:56|8|11|7|0.28|471h5m43s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071706|1|stats.go:56|8|11|7|0.28|471h5m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071707|1|stats.go:56|8|11|7|0.28|471h5m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071707|1|stats.go:56|8|11|7|0.28|471h5m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071707|1|stats.go:56|8|11|7|0.28|471h5m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071708|1|stats.go:56|8|11|7|0.28|471h5m45s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071708|1|stats.go:56|8|11|7|0.28|471h5m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071709|1|stats.go:56|8|11|7|0.28|471h5m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071709|1|stats.go:56|8|11|7|0.28|471h5m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071709|1|stats.go:56|8|11|7|0.28|471h5m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071716|1|stats.go:56|8|11|7|0.32|471h5m53s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071716|1|stats.go:56|8|11|7|0.32|471h5m54s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071717|1|stats.go:56|8|11|7|0.32|471h5m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071717|1|stats.go:56|8|11|7|0.32|471h5m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071717|1|stats.go:56|8|11|7|0.32|471h5m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071718|1|stats.go:56|8|11|7|0.32|471h5m55s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071718|1|stats.go:56|8|11|7|0.32|471h5m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071719|1|stats.go:56|8|11|7|0.32|471h5m56s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071719|1|stats.go:56|8|11|7|0.32|471h5m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071719|1|stats.go:56|8|11|7|0.32|471h5m57s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071726|1|stats.go:56|8|11|7|0.27|471h6m3s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071726|1|stats.go:56|8|11|7|0.27|471h6m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071727|1|stats.go:56|8|11|7|0.27|471h6m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071727|1|stats.go:56|8|11|7|0.27|471h6m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071727|1|stats.go:56|8|11|7|0.27|471h6m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071728|1|stats.go:56|8|11|7|0.27|471h6m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071728|1|stats.go:56|8|11|7|0.27|471h6m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071729|1|stats.go:56|8|11|7|0.27|471h6m6s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071729|1|stats.go:56|8|11|7|0.27|471h6m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071729|1|stats.go:56|8|11|7|0.27|471h6m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071736|1|stats.go:56|8|11|7|0.23|471h6m13s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071736|1|stats.go:56|8|11|7|0.23|471h6m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071737|1|stats.go:56|8|11|7|0.23|471h6m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071737|1|stats.go:56|8|11|7|0.23|471h6m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071737|1|stats.go:56|8|11|7|0.23|471h6m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071738|1|stats.go:56|8|11|7|0.23|471h6m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071738|1|stats.go:56|8|11|7|0.23|471h6m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071739|1|stats.go:56|8|11|7|0.23|471h6m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071739|1|stats.go:56|8|11|7|0.23|471h6m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071739|1|stats.go:56|8|11|7|0.23|471h6m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071746|1|stats.go:56|8|11|7|0.27|471h6m23s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071746|1|stats.go:56|8|11|7|0.27|471h6m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071747|1|stats.go:56|8|11|7|0.27|471h6m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071747|1|stats.go:56|8|11|7|0.27|471h6m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071747|1|stats.go:56|8|11|7|0.27|471h6m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071748|1|stats.go:56|8|11|7|0.27|471h6m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071748|1|stats.go:56|8|11|7|0.27|471h6m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071749|1|stats.go:56|8|11|7|0.27|471h6m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071749|1|stats.go:56|8|11|7|0.27|471h6m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071749|1|stats.go:56|8|11|7|0.27|471h6m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071756|1|stats.go:56|8|11|7|0.23|471h6m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071756|1|stats.go:56|8|11|7|0.23|471h6m34s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071757|1|stats.go:56|8|11|7|0.23|471h6m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071757|1|stats.go:56|8|11|7|0.23|471h6m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071757|1|stats.go:56|8|11|7|0.23|471h6m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071758|1|stats.go:56|8|11|7|0.23|471h6m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071758|1|stats.go:56|8|11|7|0.23|471h6m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071759|1|stats.go:56|8|11|7|0.23|471h6m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071759|1|stats.go:56|8|11|7|0.23|471h6m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071759|1|stats.go:56|8|11|7|0.23|471h6m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071806|1|stats.go:56|8|11|7|0.51|471h6m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071806|1|stats.go:56|8|11|7|0.51|471h6m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071807|1|stats.go:56|8|11|7|0.51|471h6m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071807|1|stats.go:56|8|11|7|0.51|471h6m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071807|1|stats.go:56|8|11|7|0.51|471h6m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071808|1|stats.go:56|8|11|7|0.51|471h6m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071808|1|stats.go:56|8|11|7|0.51|471h6m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071809|1|stats.go:56|8|11|7|0.51|471h6m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071809|1|stats.go:56|8|11|7|0.51|471h6m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071809|1|stats.go:56|8|11|7|0.51|471h6m47s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071816|1|stats.go:56|8|11|7|0.51|471h6m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071816|1|stats.go:56|8|11|7|0.51|471h6m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071817|1|stats.go:56|8|11|7|0.51|471h6m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071817|1|stats.go:56|8|11|7|0.51|471h6m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071817|1|stats.go:56|8|11|7|0.51|471h6m55s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071818|1|stats.go:56|8|11|7|0.51|471h6m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071818|1|stats.go:56|8|11|7|0.51|471h6m56s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071819|1|stats.go:56|8|11|7|0.51|471h6m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071819|1|stats.go:56|8|11|7|0.51|471h6m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071819|1|stats.go:56|8|11|7|0.51|471h6m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071826|1|stats.go:56|8|11|7|0.58|471h7m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071826|1|stats.go:56|8|11|7|0.58|471h7m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071827|1|stats.go:56|8|11|7|0.58|471h7m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071827|1|stats.go:56|8|11|7|0.58|471h7m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071827|1|stats.go:56|8|11|7|0.58|471h7m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071828|1|stats.go:56|8|11|7|0.58|471h7m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071828|1|stats.go:56|8|11|7|0.58|471h7m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071829|1|stats.go:56|8|11|7|0.58|471h7m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071829|1|stats.go:56|8|11|7|0.58|471h7m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071829|1|stats.go:56|8|11|7|0.58|471h7m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071836|1|stats.go:56|8|11|7|0.56|471h7m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071836|1|stats.go:56|8|11|7|0.56|471h7m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071837|1|stats.go:56|8|11|7|0.56|471h7m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071837|1|stats.go:56|8|11|7|0.56|471h7m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071837|1|stats.go:56|8|11|7|0.56|471h7m15s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071838|1|stats.go:56|8|11|7|0.56|471h7m15s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071838|1|stats.go:56|8|11|7|0.56|471h7m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071839|1|stats.go:56|8|11|7|0.56|471h7m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071839|1|stats.go:56|8|11|7|0.56|471h7m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071839|1|stats.go:56|8|11|7|0.56|471h7m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071846|1|stats.go:56|8|11|7|0.48|471h7m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071846|1|stats.go:56|8|11|7|0.48|471h7m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071847|1|stats.go:56|8|11|7|0.48|471h7m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071847|1|stats.go:56|8|11|7|0.48|471h7m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071847|1|stats.go:56|8|11|7|0.48|471h7m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071848|1|stats.go:56|8|11|7|0.48|471h7m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071848|1|stats.go:56|8|11|7|0.48|471h7m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071849|1|stats.go:56|8|11|7|0.48|471h7m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071849|1|stats.go:56|8|11|7|0.48|471h7m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071849|1|stats.go:56|8|11|7|0.48|471h7m27s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071856|1|stats.go:56|8|11|7|0.70|471h7m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071856|1|stats.go:56|8|11|7|0.70|471h7m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071857|1|stats.go:56|8|11|7|0.70|471h7m34s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071857|1|stats.go:56|8|11|7|0.70|471h7m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071857|1|stats.go:56|8|11|7|0.70|471h7m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071858|1|stats.go:56|8|11|7|0.70|471h7m35s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071858|1|stats.go:56|8|11|7|0.70|471h7m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071859|1|stats.go:56|8|11|7|0.70|471h7m36s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071859|1|stats.go:56|8|11|7|0.70|471h7m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071859|1|stats.go:56|8|11|7|0.70|471h7m37s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071906|1|stats.go:56|8|11|7|0.60|471h7m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071906|1|stats.go:56|8|11|7|0.60|471h7m44s|MAPREDUCE:STATS|lifetimeConnections=3|currentConnections=0
-INFO|1002-071907|1|stats.go:56|8|11|7|0.60|471h7m44s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071907|1|stats.go:56|8|11|7|0.60|471h7m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071907|1|stats.go:56|8|11|7|0.60|471h7m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071908|1|stats.go:56|8|11|7|0.60|471h7m45s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071908|1|stats.go:56|8|11|7|0.60|471h7m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071909|1|stats.go:56|8|11|7|0.60|471h7m46s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071909|1|stats.go:56|8|11|7|0.60|471h7m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071909|1|stats.go:56|8|11|7|0.60|471h7m47s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=3
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=4
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=4
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=4
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=4
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=4
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=4
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=4
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|lifetimeConnections=4|currentConnections=1
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|lifetimeConnections=4|currentConnections=1
-INFO|1002-071912|1|stats.go:56|8|15|7|0.55|471h7m50s|MAPREDUCE:STATS|lifetimeConnections=4|currentConnections=1
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|lifetimeConnections=4|currentConnections=0
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|lifetimeConnections=4|currentConnections=0
-INFO|1002-071913|1|stats.go:56|8|13|7|0.55|471h7m51s|MAPREDUCE:STATS|lifetimeConnections=4|currentConnections=0
-INFO|1002-071916|1|stats.go:56|8|11|7|0.50|471h7m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071916|1|stats.go:56|8|11|7|0.50|471h7m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071917|1|stats.go:56|8|11|7|0.50|471h7m54s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071917|1|stats.go:56|8|11|7|0.50|471h7m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071917|1|stats.go:56|8|11|7|0.50|471h7m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071918|1|stats.go:56|8|11|7|0.50|471h7m55s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071918|1|stats.go:56|8|11|7|0.50|471h7m56s|MAPREDUCE:STATS|lifetimeConnections=4|currentConnections=0
-INFO|1002-071919|1|stats.go:56|8|11|7|0.50|471h7m56s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071919|1|stats.go:56|8|11|7|0.50|471h7m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071919|1|stats.go:56|8|11|7|0.50|471h7m57s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=4
-INFO|1002-071920|1|stats.go:56|8|15|7|0.50|471h7m58s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=5
-INFO|1002-071920|1|stats.go:56|8|15|7|0.50|471h7m58s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=5
-INFO|1002-071920|1|stats.go:56|8|15|7|0.50|471h7m58s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=5
-INFO|1002-071920|1|stats.go:56|8|15|7|0.50|471h7m58s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=5
-INFO|1002-071920|1|stats.go:56|8|15|7|0.50|471h7m58s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=5
-INFO|1002-071920|1|stats.go:56|8|15|7|0.50|471h7m58s|MAPREDUCE:STATS|lifetimeConnections=5|currentConnections=1
-INFO|1002-071920|1|stats.go:56|8|15|7|0.50|471h7m58s|MAPREDUCE:STATS|lifetimeConnections=5|currentConnections=1
-INFO|1002-071921|1|stats.go:56|8|12|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071921|1|stats.go:56|8|12|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071921|1|stats.go:56|8|12|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071921|1|stats.go:56|8|13|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071921|1|stats.go:56|8|13|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071921|1|stats.go:56|8|13|7|1.02|471h7m59s|MAPREDUCE:STATS|lifetimeConnections=5|currentConnections=0
-INFO|1002-071921|1|stats.go:56|8|15|7|1.02|471h7m58s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=5
-INFO|1002-071921|1|stats.go:56|8|15|7|1.02|471h7m58s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=5
-INFO|1002-071921|1|stats.go:56|8|15|7|1.02|471h7m58s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=5
-INFO|1002-071922|1|stats.go:56|8|12|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071922|1|stats.go:56|8|12|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071922|1|stats.go:56|8|13|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071922|1|stats.go:56|8|13|7|1.02|471h7m59s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071926|1|stats.go:56|8|11|7|0.94|471h8m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071926|1|stats.go:56|8|11|7|0.94|471h8m4s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071927|1|stats.go:56|8|11|7|0.94|471h8m4s|MAPREDUCE:STATS|lifetimeConnections=5|currentConnections=0
-INFO|1002-071927|1|stats.go:56|8|11|7|0.94|471h8m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071927|1|stats.go:56|8|11|7|0.94|471h8m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071928|1|stats.go:56|8|11|7|0.94|471h8m5s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071928|1|stats.go:56|8|11|7|0.94|471h8m6s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071929|1|stats.go:56|8|11|7|0.94|471h8m6s|MAPREDUCE:STATS|lifetimeConnections=5|currentConnections=0
-INFO|1002-071929|1|stats.go:56|8|11|7|0.94|471h8m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071929|1|stats.go:56|8|11|7|0.94|471h8m7s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071936|1|stats.go:56|8|11|7|0.80|471h8m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071936|1|stats.go:56|8|11|7|0.80|471h8m14s|MAPREDUCE:STATS|lifetimeConnections=5|currentConnections=0
-INFO|1002-071937|1|stats.go:56|8|11|7|0.80|471h8m14s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071937|1|stats.go:56|8|11|7|0.80|471h8m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071937|1|stats.go:56|8|11|7|0.80|471h8m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071938|1|stats.go:56|8|11|7|0.80|471h8m15s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071938|1|stats.go:56|8|11|7|0.80|471h8m16s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071939|1|stats.go:56|8|11|7|0.80|471h8m16s|MAPREDUCE:STATS|lifetimeConnections=5|currentConnections=0
-INFO|1002-071939|1|stats.go:56|8|11|7|0.80|471h8m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071939|1|stats.go:56|8|11|7|0.80|471h8m17s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071946|1|stats.go:56|8|11|7|0.67|471h8m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071946|1|stats.go:56|8|11|7|0.67|471h8m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071947|1|stats.go:56|8|11|7|0.67|471h8m24s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071947|1|stats.go:56|8|11|7|0.67|471h8m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071947|1|stats.go:56|8|11|7|0.67|471h8m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071948|1|stats.go:56|8|11|7|0.67|471h8m25s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071948|1|stats.go:56|8|11|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=5
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071948|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
-INFO|1002-071949|1|stats.go:56|8|15|7|0.67|471h8m26s|MAPREDUCE:STATS|currentConnections=1|lifetimeConnections=6
+INFO|1002-071143|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071147|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071148|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071148|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071149|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071149|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071149|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071156|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071156|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071157|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071157|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071158|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071158|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071158|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071159|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071159|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071206|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071206|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071206|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071207|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071207|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071208|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071208|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071209|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071209|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071209|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|17|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|16|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|17|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071213|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071216|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071216|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071217|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071217|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071217|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071218|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071218|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071218|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071219|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071219|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071219|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071226|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071226|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071227|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071227|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071228|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071228|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071228|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071229|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071229|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071229|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071236|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071236|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071236|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071237|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071237|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071238|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071238|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071238|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071239|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071239|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071239|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071246|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071246|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071247|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071247|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071247|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071248|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071248|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071248|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071249|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071249|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071256|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071256|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071256|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071257|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071257|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071257|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071258|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071258|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071259|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071259|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071306|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071306|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071306|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071307|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071307|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071307|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071308|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071308|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071308|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071309|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071309|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071309|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071316|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071316|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071316|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071317|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071317|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071318|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071318|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071318|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071319|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071319|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071319|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071326|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071326|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071326|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071327|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071327|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071328|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071328|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071328|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071329|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071329|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071329|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071336|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071336|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071336|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071337|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071337|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071338|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071338|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071339|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071339|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071346|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071346|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071346|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071347|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071347|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071348|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071348|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071348|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071349|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071349|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071349|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071356|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071356|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071356|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071357|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071357|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071358|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071358|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071359|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071359|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071359|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071406|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071406|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071406|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071407|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071407|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071408|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071408|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071409|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071409|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071416|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071416|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071416|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071417|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071417|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071417|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071418|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071418|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071418|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071419|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071419|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071419|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071426|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071426|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071426|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071427|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071427|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071428|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071428|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071429|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071429|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071429|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071436|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071436|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071436|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071437|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071437|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071438|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071438|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071438|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071439|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071439|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071439|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071446|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071446|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071446|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071447|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071447|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071447|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071448|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071448|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071448|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071449|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071449|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071449|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071456|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071456|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071457|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071457|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071457|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071458|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071458|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071458|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071459|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071459|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071506|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071506|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071506|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071507|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071507|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071507|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071508|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071508|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071509|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071509|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071509|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071516|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071516|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071517|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071517|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071518|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071518|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071518|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071519|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071519|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071526|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071526|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071526|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071527|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071527|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071527|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071528|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071528|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071528|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071529|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071529|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071529|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071536|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071536|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071537|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071537|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071538|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071538|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071538|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071539|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071539|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071546|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071546|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071547|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071547|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071548|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071548|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071549|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071549|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071549|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071556|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071556|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071556|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071557|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071557|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071557|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071558|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071558|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071558|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071559|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071559|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071606|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071606|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071607|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071607|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071608|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071608|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071608|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071609|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071609|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071609|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071616|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071616|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071617|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071617|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071618|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071618|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071618|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071619|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071619|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071619|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071626|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071626|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071626|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071627|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071627|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071628|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071628|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071629|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071629|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071629|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071636|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071636|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071636|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071637|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071637|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071637|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071638|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071638|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071639|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071639|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071639|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071646|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071646|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071646|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071647|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071647|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071647|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071648|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071648|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071649|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071649|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071656|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071656|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071656|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071657|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071657|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071657|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071658|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071658|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071658|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071659|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071659|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071659|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071706|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071706|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071707|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071707|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071707|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071708|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071708|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071709|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071709|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071716|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071716|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071717|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071717|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071717|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071718|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071718|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071718|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071719|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071719|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071719|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071726|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071726|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071727|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071727|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071727|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071728|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071728|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071729|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071729|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071729|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071736|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071736|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071736|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071737|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071737|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071737|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071738|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071738|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071739|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071739|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071746|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071746|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071746|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071747|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071747|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071748|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071748|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071749|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071749|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071756|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071756|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071757|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071757|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071757|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071758|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071758|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071758|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071759|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071759|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071759|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071806|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071806|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071807|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071807|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071808|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071808|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071808|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071809|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071809|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071816|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071816|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071816|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071817|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071817|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071817|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071818|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071818|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071819|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071819|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071826|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071826|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071826|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071827|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071827|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071828|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071828|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071828|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071829|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071829|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071829|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071836|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071836|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071836|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071837|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071837|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071838|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071838|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071838|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071839|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071839|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071839|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071846|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071846|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071846|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071847|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071847|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071848|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071848|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071848|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071849|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071849|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071856|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071856|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071856|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071857|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071857|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071858|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071858|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071858|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071859|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071859|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071859|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071906|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071906|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071907|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071907|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071908|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071908|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071909|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071909|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071909|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071912|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071913|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071916|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071916|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071916|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071917|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071917|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071917|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071918|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071918|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071919|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071919|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071919|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071920|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071920|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071920|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071920|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071920|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071920|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071920|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071921|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071922|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071922|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071922|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071922|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071926|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071926|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071927|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071927|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071927|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071928|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071928|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071928|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071929|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071929|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071929|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071936|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071936|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071937|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071937|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071937|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071938|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071938|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071938|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071939|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071939|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071939|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071946|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071946|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071946|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071947|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071947|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071947|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|12|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|14|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|11|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071948|1|stats.go:56|8|13|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
+INFO|1002-071949|1|stats.go:56|8|15|7|0.21|471h0m21s|MAPREDUCE:STATS|currentConnections=0|lifetimeConnections=1
diff --git a/integrationtests/test_server_100files.json b/integrationtests/test_server_100files.json
new file mode 100644
index 0000000..d3affc5
--- /dev/null
+++ b/integrationtests/test_server_100files.json
@@ -0,0 +1,8 @@
+{
+ "Common": {},
+ "Server": {
+ "MaxConcurrentCats": 100,
+ "MaxConcurrentTails": 10
+ },
+ "Client": {}
+} \ No newline at end of file
diff --git a/integrationtests/testhelpers.go b/integrationtests/testhelpers.go
index a6a5f50..5368dfe 100644
--- a/integrationtests/testhelpers.go
+++ b/integrationtests/testhelpers.go
@@ -182,6 +182,16 @@ func createTestContextWithTimeout(t *testing.T) (context.Context, context.Cancel
return ctx, cancel
}
+// createTestContextWithLongTimeout creates a context with a 5-minute timeout for long-running tests
+func createTestContextWithLongTimeout(t *testing.T) (context.Context, context.CancelFunc) {
+ t.Helper()
+ ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)
+ t.Cleanup(func() {
+ cancel()
+ })
+ return ctx, cancel
+}
+
// cleanupFiles registers files to be removed during test cleanup
func cleanupFiles(t *testing.T, files ...string) {
t.Helper()
diff --git a/internal/mapr/safe_aggregateset.go b/internal/mapr/safe_aggregateset.go
new file mode 100644
index 0000000..b42814d
--- /dev/null
+++ b/internal/mapr/safe_aggregateset.go
@@ -0,0 +1,71 @@
+package mapr
+
+import (
+ "context"
+ "sync"
+)
+
+// SafeAggregateSet is a thread-safe wrapper around AggregateSet for use in turbo mode.
+// It uses a read-write mutex to allow concurrent reads but exclusive writes.
+type SafeAggregateSet struct {
+ mu sync.RWMutex
+ set *AggregateSet
+}
+
+// NewSafeAggregateSet creates a new thread-safe aggregate set.
+func NewSafeAggregateSet() *SafeAggregateSet {
+ return &SafeAggregateSet{
+ set: NewAggregateSet(),
+ }
+}
+
+// Aggregate data to the aggregate set with thread safety.
+func (s *SafeAggregateSet) Aggregate(key string, agg AggregateOperation, value string, clientAggregation bool) error {
+ s.mu.Lock()
+ defer s.mu.Unlock()
+ return s.set.Aggregate(key, agg, value, clientAggregation)
+}
+
+// IncrementSamples increments the sample count safely.
+func (s *SafeAggregateSet) IncrementSamples() {
+ s.mu.Lock()
+ defer s.mu.Unlock()
+ s.set.Samples++
+}
+
+// Clone creates a deep copy of the aggregate set.
+// This is useful for serialization to avoid holding locks for too long.
+func (s *SafeAggregateSet) Clone() *AggregateSet {
+ s.mu.RLock()
+ defer s.mu.RUnlock()
+
+ clone := &AggregateSet{
+ Samples: s.set.Samples,
+ FValues: make(map[string]float64, len(s.set.FValues)),
+ SValues: make(map[string]string, len(s.set.SValues)),
+ }
+
+ // Deep copy the maps
+ for k, v := range s.set.FValues {
+ clone.FValues[k] = v
+ }
+ for k, v := range s.set.SValues {
+ clone.SValues[k] = v
+ }
+
+ return clone
+}
+
+// Serialize the aggregate set safely.
+func (s *SafeAggregateSet) Serialize(ctx context.Context, groupKey string, ch chan<- string) {
+ // Clone the set to avoid holding the lock during serialization
+ clone := s.Clone()
+ clone.Serialize(ctx, groupKey, ch)
+}
+
+// GetSamples returns the current sample count safely.
+func (s *SafeAggregateSet) GetSamples() int {
+ s.mu.RLock()
+ defer s.mu.RUnlock()
+ return s.set.Samples
+} \ No newline at end of file
diff --git a/internal/mapr/safe_aggregateset_test.go b/internal/mapr/safe_aggregateset_test.go
new file mode 100644
index 0000000..327987a
--- /dev/null
+++ b/internal/mapr/safe_aggregateset_test.go
@@ -0,0 +1,147 @@
+package mapr
+
+import (
+ "sync"
+ "testing"
+)
+
+// TestSafeAggregateSetConcurrency tests that SafeAggregateSet handles concurrent operations correctly.
+func TestSafeAggregateSetConcurrency(t *testing.T) {
+ safeSet := NewSafeAggregateSet()
+
+ // Number of concurrent goroutines
+ numGoroutines := 100
+ // Number of operations per goroutine
+ opsPerGoroutine := 1000
+
+ var wg sync.WaitGroup
+ wg.Add(numGoroutines)
+
+ // Launch concurrent goroutines
+ for i := 0; i < numGoroutines; i++ {
+ go func(id int) {
+ defer wg.Done()
+
+ for j := 0; j < opsPerGoroutine; j++ {
+ // Test Count operation
+ err := safeSet.Aggregate("count", Count, "1", false)
+ if err != nil {
+ t.Errorf("Error in Count aggregation: %v", err)
+ }
+
+ // Test Sum operation
+ err = safeSet.Aggregate("sum", Sum, "10.5", false)
+ if err != nil {
+ t.Errorf("Error in Sum aggregation: %v", err)
+ }
+
+ // Test Last operation
+ err = safeSet.Aggregate("last", Last, "value", false)
+ if err != nil {
+ t.Errorf("Error in Last aggregation: %v", err)
+ }
+
+ // Test Min operation
+ err = safeSet.Aggregate("min", Min, "5.0", false)
+ if err != nil {
+ t.Errorf("Error in Min aggregation: %v", err)
+ }
+
+ // Test Max operation
+ err = safeSet.Aggregate("max", Max, "15.0", false)
+ if err != nil {
+ t.Errorf("Error in Max aggregation: %v", err)
+ }
+
+ // Increment samples
+ safeSet.IncrementSamples()
+ }
+ }(i)
+ }
+
+ // Wait for all goroutines to complete
+ wg.Wait()
+
+ // Verify results
+ clone := safeSet.Clone()
+
+ // Check Count
+ expectedCount := float64(numGoroutines * opsPerGoroutine)
+ if clone.FValues["count"] != expectedCount {
+ t.Errorf("Expected count %f, got %f", expectedCount, clone.FValues["count"])
+ }
+
+ // Check Sum
+ expectedSum := float64(numGoroutines * opsPerGoroutine) * 10.5
+ if clone.FValues["sum"] != expectedSum {
+ t.Errorf("Expected sum %f, got %f", expectedSum, clone.FValues["sum"])
+ }
+
+ // Check Min
+ if clone.FValues["min"] != 5.0 {
+ t.Errorf("Expected min 5.0, got %f", clone.FValues["min"])
+ }
+
+ // Check Max
+ if clone.FValues["max"] != 15.0 {
+ t.Errorf("Expected max 15.0, got %f", clone.FValues["max"])
+ }
+
+ // Check Samples
+ expectedSamples := numGoroutines * opsPerGoroutine
+ if clone.Samples != expectedSamples {
+ t.Errorf("Expected samples %d, got %d", expectedSamples, clone.Samples)
+ }
+
+ // Check Last (should be "value")
+ if clone.SValues["last"] != "value" {
+ t.Errorf("Expected last 'value', got '%s'", clone.SValues["last"])
+ }
+}
+
+// TestSafeAggregateSetClone tests that cloning creates an independent copy.
+func TestSafeAggregateSetClone(t *testing.T) {
+ original := NewSafeAggregateSet()
+
+ // Add some data
+ original.Aggregate("count", Count, "1", false)
+ original.Aggregate("sum", Sum, "100", false)
+ original.Aggregate("last", Last, "original", false)
+ original.IncrementSamples()
+
+ // Clone the set
+ clone := original.Clone()
+
+ // Modify the original
+ original.Aggregate("count", Count, "1", false)
+ original.Aggregate("sum", Sum, "50", false)
+ original.Aggregate("last", Last, "modified", false)
+ original.IncrementSamples()
+
+ // Verify clone is unchanged
+ if clone.FValues["count"] != 1 {
+ t.Errorf("Clone count should be 1, got %f", clone.FValues["count"])
+ }
+
+ if clone.FValues["sum"] != 100 {
+ t.Errorf("Clone sum should be 100, got %f", clone.FValues["sum"])
+ }
+
+ if clone.SValues["last"] != "original" {
+ t.Errorf("Clone last should be 'original', got '%s'", clone.SValues["last"])
+ }
+
+ if clone.Samples != 1 {
+ t.Errorf("Clone samples should be 1, got %d", clone.Samples)
+ }
+
+ // Verify original has changed
+ originalClone := original.Clone()
+ if originalClone.FValues["count"] != 2 {
+ t.Errorf("Original count should be 2, got %f", originalClone.FValues["count"])
+ }
+
+ if originalClone.FValues["sum"] != 150 {
+ t.Errorf("Original sum should be 150, got %f", originalClone.FValues["sum"])
+ }
+} \ No newline at end of file
diff --git a/internal/mapr/server/aggregate.go b/internal/mapr/server/aggregate.go
index f055b9d..353cda5 100644
--- a/internal/mapr/server/aggregate.go
+++ b/internal/mapr/server/aggregate.go
@@ -68,7 +68,7 @@ func NewAggregate(queryStr string) (*Aggregate, error) {
return &Aggregate{
done: internal.NewDone(),
- NextLinesCh: make(chan chan *line.Line, 1000),
+ NextLinesCh: make(chan chan *line.Line, 10000), // Increased buffer for high concurrency
serialize: make(chan struct{}),
hostname: s[0],
query: query,
@@ -116,15 +116,15 @@ func (a *Aggregate) aggregateTimer(ctx context.Context) {
}
}
-func (a *Aggregate) nextLine() (line *line.Line, ok bool, noMoreChannels bool) {
- dlog.Server.Trace("nextLine.enter", line, ok, noMoreChannels)
+func (a *Aggregate) nextLine() (l *line.Line, ok bool, noMoreChannels bool) {
+ dlog.Server.Trace("nextLine.enter", l, ok, noMoreChannels)
// Protect channel operations with mutex to prevent race conditions
a.mu.Lock()
defer a.mu.Unlock()
select {
- case line, ok = <-a.linesCh:
+ case l, ok = <-a.linesCh:
if !ok {
// Channel is closed, go to next channel.
select {
@@ -140,40 +140,46 @@ func (a *Aggregate) nextLine() (line *line.Line, ok bool, noMoreChannels bool) {
oldLinesCh := a.linesCh
a.linesCh = newLinesCh
- // In turbo mode, synchronously put the channel back to avoid race conditions
- if config.Server.TurboModeEnable {
- select {
- case a.NextLinesCh <- oldLinesCh:
- // Successfully put back
- default:
- // Channel is full, start a goroutine with timeout
- go func() {
- timer := time.NewTimer(5 * time.Second)
- defer timer.Stop()
- select {
- case a.NextLinesCh <- oldLinesCh:
- case <-timer.C:
- dlog.Server.Warn("Timeout: failed to put channel back, NextLinesCh full")
- }
- }()
- }
- } else {
- // Non-turbo mode: use goroutine as before
- go func() {
- timer := time.NewTimer(5 * time.Second)
- defer timer.Stop()
+ // Ensure the old channel is fully drained before recycling to prevent data mixing
+ go func(oldCh chan *line.Line) {
+ // First, drain any remaining lines from the old channel
+ drained := 0
+ drainLoop:
+ for {
select {
- case a.NextLinesCh <- oldLinesCh:
- case <-timer.C:
- dlog.Server.Warn("Timeout: failed to put channel back, NextLinesCh might be full")
+ case l, ok := <-oldCh:
+ if !ok {
+ // Channel is closed, safe to recycle
+ break drainLoop
+ }
+ if l != nil {
+ l.Recycle()
+ drained++
+ }
+ default:
+ // No more lines to drain immediately
+ break drainLoop
}
- }()
- }
+ }
+
+ if drained > 0 {
+ dlog.Server.Debug("Drained", drained, "lines from recycled channel")
+ }
+
+ // Now safely recycle the drained channel
+ timer := time.NewTimer(5 * time.Second)
+ defer timer.Stop()
+ select {
+ case a.NextLinesCh <- oldCh:
+ case <-timer.C:
+ dlog.Server.Warn("Timeout: failed to put channel back, NextLinesCh might be full")
+ }
+ }(oldLinesCh)
default:
// No new lines channel found.
}
}
- dlog.Server.Trace("nextLine.exit", line, ok, noMoreChannels)
+ dlog.Server.Trace("nextLine.exit", l, ok, noMoreChannels)
return
}
diff --git a/internal/mapr/server/turbo_aggregate.go b/internal/mapr/server/turbo_aggregate.go
new file mode 100644
index 0000000..9a748f5
--- /dev/null
+++ b/internal/mapr/server/turbo_aggregate.go
@@ -0,0 +1,415 @@
+package server
+
+import (
+ "bytes"
+ "context"
+ "strings"
+ "sync"
+ "sync/atomic"
+ "time"
+
+ "github.com/mimecast/dtail/internal"
+ "github.com/mimecast/dtail/internal/config"
+ "github.com/mimecast/dtail/internal/io/dlog"
+ "github.com/mimecast/dtail/internal/io/pool"
+ "github.com/mimecast/dtail/internal/mapr"
+ "github.com/mimecast/dtail/internal/mapr/logformat"
+ "github.com/mimecast/dtail/internal/protocol"
+)
+
+// TurboAggregate is a high-performance aggregator for MapReduce operations in turbo mode.
+// It processes lines directly without channels for maximum throughput.
+type TurboAggregate struct {
+ done *internal.Done
+ // Hostname of the current server (used to populate $hostname field).
+ hostname string
+ // The mapr query
+ query *mapr.Query
+ // The mapr log format parser
+ parser logformat.Parser
+ // Group sets protected by mutex during serialization
+ groupSets sync.Map // map[string]*mapr.SafeAggregateSet
+ bufferMu sync.Mutex // Protects serialization
+ // Batch processing
+ batchMu sync.Mutex
+ batch []rawLine
+ batchSize int
+ // Periodic serialization
+ serializeTicker *time.Ticker
+ serialize chan struct{}
+ maprMessages chan<- string
+ // Stats
+ linesProcessed atomic.Uint64
+ errors atomic.Uint64
+ // Field map pool to reduce allocations
+ fieldPool sync.Pool
+ // Synchronization for clean shutdown
+ processingWg sync.WaitGroup
+}
+
+type rawLine struct {
+ content []byte
+ sourceID string
+}
+
+// NewTurboAggregate returns a new turbo mode aggregator.
+func NewTurboAggregate(queryStr string) (*TurboAggregate, error) {
+ query, err := mapr.NewQuery(queryStr)
+ if err != nil {
+ return nil, err
+ }
+
+ fqdn, err := config.Hostname()
+ if err != nil {
+ dlog.Server.Error(err)
+ }
+ s := strings.Split(fqdn, ".")
+
+ var parserName string
+ switch query.LogFormat {
+ case "":
+ parserName = config.Server.MapreduceLogFormat
+ if query.Table == "" {
+ parserName = "generic"
+ }
+ default:
+ parserName = query.LogFormat
+ }
+
+ dlog.Server.Info("Creating turbo log format parser", parserName)
+ logParser, err := logformat.NewParser(parserName, query)
+ if err != nil {
+ dlog.Server.Error("Could not create log format parser. Falling back to 'generic'", err)
+ if logParser, err = logformat.NewParser("generic", query); err != nil {
+ dlog.Server.FatalPanic("Could not create log format parser", err)
+ }
+ }
+
+ return &TurboAggregate{
+ done: internal.NewDone(),
+ serialize: make(chan struct{}),
+ hostname: s[0],
+ query: query,
+ parser: logParser,
+ groupSets: sync.Map{},
+ batchSize: 100, // Process 100 lines at a time
+ batch: make([]rawLine, 0, 100),
+ fieldPool: sync.Pool{
+ New: func() interface{} {
+ return make(map[string]string, 20)
+ },
+ },
+ }, nil
+}
+
+// Shutdown the aggregation engine.
+func (a *TurboAggregate) Shutdown() {
+ dlog.Server.Info("Shutting down turbo aggregate", "linesProcessed", a.linesProcessed.Load())
+
+ // Signal shutdown
+ a.done.Shutdown()
+
+ // Stop the ticker
+ if a.serializeTicker != nil {
+ a.serializeTicker.Stop()
+ }
+
+ // Process any remaining batch
+ a.processBatch()
+
+ // Wait for all processing to complete
+ dlog.Server.Info("Waiting for all processing to complete")
+ a.processingWg.Wait()
+
+ // Trigger final serialization after all processing is done
+ ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+ defer cancel()
+ a.doSerialize(ctx)
+
+ // Give time for messages to be sent
+ time.Sleep(100 * time.Millisecond)
+}
+
+// Start the turbo aggregation.
+func (a *TurboAggregate) Start(ctx context.Context, maprMessages chan<- string) {
+ a.maprMessages = maprMessages
+
+ dlog.Server.Info("Starting turbo aggregate", "interval", a.query.Interval)
+
+ // Start periodic serialization
+ a.serializeTicker = time.NewTicker(a.query.Interval)
+ go a.serializationLoop(ctx)
+
+ // Start batch processor
+ go a.batchProcessorLoop(ctx)
+
+ // Also trigger an immediate serialization to ensure we capture data even if interval hasn't passed
+ go func() {
+ time.Sleep(50 * time.Millisecond) // Give time for some data to accumulate
+ a.Serialize(ctx)
+ }()
+}
+
+// ProcessLineDirect processes a line directly without channels.
+// This is called from the TurboAggregateProcessor.
+func (a *TurboAggregate) ProcessLineDirect(lineContent []byte, sourceID string) error {
+ // Make a copy of the line content as the buffer will be recycled
+ content := make([]byte, len(lineContent))
+ copy(content, lineContent)
+
+ // Add to batch
+ a.batchMu.Lock()
+ a.batch = append(a.batch, rawLine{content: content, sourceID: sourceID})
+ shouldProcess := len(a.batch) >= a.batchSize
+ batchLen := len(a.batch)
+ a.batchMu.Unlock()
+
+ if batchLen == 1 {
+ dlog.Server.Debug("TurboAggregate: First line received", "sourceID", sourceID)
+ }
+
+ // Process batch if full
+ if shouldProcess {
+ a.processBatch()
+ }
+
+ return nil
+}
+
+// batchProcessorLoop continuously processes batches.
+func (a *TurboAggregate) batchProcessorLoop(ctx context.Context) {
+ ticker := time.NewTicker(100 * time.Millisecond)
+ defer ticker.Stop()
+
+ for {
+ select {
+ case <-ctx.Done():
+ // Process any remaining batch before exiting
+ a.processBatch()
+ return
+ case <-a.done.Done():
+ // Process any remaining batch before exiting
+ a.processBatch()
+ return
+ case <-ticker.C:
+ // Periodically process any accumulated batch
+ a.processBatch()
+ }
+ }
+}
+
+// processBatch processes a batch of lines.
+func (a *TurboAggregate) processBatch() {
+ a.batchMu.Lock()
+ if len(a.batch) == 0 {
+ a.batchMu.Unlock()
+ return
+ }
+ batch := a.batch
+ a.batch = make([]rawLine, 0, a.batchSize)
+ a.batchMu.Unlock()
+
+ // Track this batch processing
+ a.processingWg.Add(1)
+ defer a.processingWg.Done()
+
+ // Process each line in the batch
+ for _, line := range batch {
+ if err := a.processLine(line.content, line.sourceID); err != nil {
+ a.errors.Add(1)
+ dlog.Server.Error("Error processing line:", err)
+ }
+ a.linesProcessed.Add(1)
+ }
+}
+
+// processLine processes a single line and aggregates it.
+func (a *TurboAggregate) processLine(lineContent []byte, sourceID string) error {
+ // Trim whitespace
+ maprLine := strings.TrimSpace(string(lineContent))
+
+ // Get a field map from the pool
+ fields := a.fieldPool.Get().(map[string]string)
+ defer func() {
+ // Clear the map before returning to pool
+ for k := range fields {
+ delete(fields, k)
+ }
+ a.fieldPool.Put(fields)
+ }()
+
+ // Parse the line
+ parsedFields, err := a.parser.MakeFields(maprLine)
+ if err != nil {
+ if err != logformat.ErrIgnoreFields {
+ return err
+ }
+ return nil
+ }
+
+ // Copy parsed fields to our pooled map
+ for k, v := range parsedFields {
+ fields[k] = v
+ }
+
+ // Apply where clause
+ if !a.query.WhereClause(fields) {
+ return nil
+ }
+
+ // Apply set clause if needed
+ if len(a.query.Set) > 0 {
+ if err := a.query.SetClause(fields); err != nil {
+ return err
+ }
+ }
+
+ // Aggregate the fields
+ a.aggregate(fields)
+ return nil
+}
+
+// aggregate adds fields to the appropriate group.
+func (a *TurboAggregate) aggregate(fields map[string]string) {
+ // Build group key
+ var sb strings.Builder
+ for i, field := range a.query.GroupBy {
+ if i > 0 {
+ sb.WriteString(protocol.AggregateGroupKeyCombinator)
+ }
+ if val, ok := fields[field]; ok {
+ sb.WriteString(val)
+ }
+ }
+ groupKey := sb.String()
+
+ // Get or create the aggregate set
+ setInterface, loaded := a.groupSets.LoadOrStore(groupKey, mapr.NewSafeAggregateSet())
+ set := setInterface.(*mapr.SafeAggregateSet)
+
+ if !loaded {
+ dlog.Server.Debug("TurboAggregate: New group created", "groupKey", groupKey)
+ }
+
+ // Aggregate the values
+ var addedSample bool
+ for _, sc := range a.query.Select {
+ if val, ok := fields[sc.Field]; ok {
+ if err := set.Aggregate(sc.FieldStorage, sc.Operation, val, false); err != nil {
+ dlog.Server.Error(err)
+ continue
+ }
+ addedSample = true
+ }
+ }
+
+ if addedSample {
+ set.IncrementSamples()
+ }
+}
+
+// serializationLoop handles periodic serialization.
+func (a *TurboAggregate) serializationLoop(ctx context.Context) {
+ for {
+ select {
+ case <-ctx.Done():
+ return
+ case <-a.done.Done():
+ return
+ case <-a.serializeTicker.C:
+ a.Serialize(ctx)
+ case <-a.serialize:
+ a.doSerialize(ctx)
+ }
+ }
+}
+
+// Serialize triggers serialization of all aggregated data.
+func (a *TurboAggregate) Serialize(ctx context.Context) {
+ select {
+ case a.serialize <- struct{}{}:
+ case <-time.After(time.Minute):
+ dlog.Server.Warn("Starting to serialize mapreduce data takes over a minute")
+ case <-ctx.Done():
+ }
+}
+
+// doSerialize performs the actual serialization.
+func (a *TurboAggregate) doSerialize(ctx context.Context) {
+ // Process any remaining batch
+ a.processBatch()
+
+ // Wait a moment for any in-progress batch processing
+ time.Sleep(10 * time.Millisecond)
+
+ dlog.Server.Info("Serializing turbo mapreduce result", "linesProcessed", a.linesProcessed.Load())
+
+ // Lock to prevent concurrent modifications during serialization
+ a.bufferMu.Lock()
+ defer a.bufferMu.Unlock()
+
+ // Create a new group set for serialization
+ group := mapr.NewGroupSet()
+
+ // Copy all aggregate sets from the groupSets
+ groupCount := 0
+ a.groupSets.Range(func(key, value interface{}) bool {
+ groupKey := key.(string)
+ safeSet := value.(*mapr.SafeAggregateSet)
+
+ // Clone the safe set to get a regular AggregateSet
+ clonedSet := safeSet.Clone()
+
+ // Add to the group set
+ groupSet := group.GetSet(groupKey)
+ *groupSet = *clonedSet
+ groupCount++
+
+ return true
+ })
+
+ dlog.Server.Info("Serializing groups", "groupCount", groupCount)
+
+ // Serialize the group
+ group.Serialize(ctx, a.maprMessages)
+
+ // Clear the groupSets after serialization
+ a.groupSets = sync.Map{}
+}
+
+// TurboAggregateProcessor implements the line processor interface for turbo mode aggregation.
+type TurboAggregateProcessor struct {
+ aggregate *TurboAggregate
+ globID string
+}
+
+// NewTurboAggregateProcessor creates a new turbo aggregate processor.
+func NewTurboAggregateProcessor(aggregate *TurboAggregate, globID string) *TurboAggregateProcessor {
+ return &TurboAggregateProcessor{
+ aggregate: aggregate,
+ globID: globID,
+ }
+}
+
+// ProcessLine processes a line directly to the turbo aggregate.
+func (p *TurboAggregateProcessor) ProcessLine(lineContent *bytes.Buffer, lineNum uint64, sourceID string) error {
+ // Process the line directly
+ err := p.aggregate.ProcessLineDirect(lineContent.Bytes(), sourceID)
+
+ // Recycle the buffer
+ pool.RecycleBytesBuffer(lineContent)
+
+ return err
+}
+
+// Flush ensures all buffered data is processed.
+func (p *TurboAggregateProcessor) Flush() error {
+ // Process any remaining batch
+ p.aggregate.processBatch()
+ return nil
+}
+
+// Close flushes any remaining data.
+func (p *TurboAggregateProcessor) Close() error {
+ return p.Flush()
+} \ No newline at end of file
diff --git a/internal/server/handlers/basehandler.go b/internal/server/handlers/basehandler.go
index bfc7ec2..427ab6c 100644
--- a/internal/server/handlers/basehandler.go
+++ b/internal/server/handlers/basehandler.go
@@ -31,6 +31,7 @@ type baseHandler struct {
handleCommandCb handleCommandCb
lines chan *line.Line
aggregate *server.Aggregate
+ turboAggregate *server.TurboAggregate // Turbo mode aggregate
maprMessages chan string
serverMessages chan string
hostname string
@@ -56,6 +57,16 @@ type baseHandler struct {
// Shutdown the handler.
func (h *baseHandler) Shutdown() {
+ // Shutdown turbo aggregate if present
+ if h.turboAggregate != nil {
+ dlog.Server.Info(h.user, "Shutting down turbo aggregate")
+ h.turboAggregate.Shutdown()
+ }
+ // Shutdown regular aggregate if present
+ if h.aggregate != nil {
+ dlog.Server.Info(h.user, "Shutting down regular aggregate")
+ h.aggregate.Shutdown()
+ }
h.done.Shutdown()
}
@@ -372,6 +383,10 @@ func (h *baseHandler) flush() {
if h.turboMode {
maxIterations = 300 // Give more time for turbo mode to drain
}
+ // Also increase iterations if we have MapReduce messages
+ if h.turboAggregate != nil || h.aggregate != nil {
+ maxIterations = 300 // Give more time for MapReduce results
+ }
for i := 0; i < maxIterations; i++ {
if numUnsentMessages() == 0 {
diff --git a/internal/server/handlers/mapcommand.go b/internal/server/handlers/mapcommand.go
index 65e0ed8..5dc7b8f 100644
--- a/internal/server/handlers/mapcommand.go
+++ b/internal/server/handlers/mapcommand.go
@@ -4,29 +4,49 @@ import (
"context"
"strings"
+ "github.com/mimecast/dtail/internal/config"
+ "github.com/mimecast/dtail/internal/io/dlog"
"github.com/mimecast/dtail/internal/mapr/server"
)
// Map command implements the mapreduce command server side.
type mapCommand struct {
- aggregate *server.Aggregate
- server *ServerHandler
+ aggregate *server.Aggregate
+ turboAggregate *server.TurboAggregate
+ server *ServerHandler
}
// NewMapCommand returns a new server side mapreduce command.
func newMapCommand(serverHandler *ServerHandler, argc int,
- args []string) (mapCommand, *server.Aggregate, error) {
+ args []string) (mapCommand, *server.Aggregate, *server.TurboAggregate, error) {
m := mapCommand{server: serverHandler}
queryStr := strings.Join(args[1:], " ")
+
+ // If turbo mode is enabled, create a TurboAggregate
+ if config.Server.TurboModeEnable {
+ dlog.Server.Info("Creating turbo aggregate for MapReduce", "query", queryStr)
+ turboAggregate, err := server.NewTurboAggregate(queryStr)
+ if err != nil {
+ return m, nil, nil, err
+ }
+ m.turboAggregate = turboAggregate
+ return m, nil, turboAggregate, nil
+ }
+
+ // Otherwise, create a regular Aggregate
aggregate, err := server.NewAggregate(queryStr)
if err != nil {
- return m, nil, err
+ return m, nil, nil, err
}
m.aggregate = aggregate
- return m, aggregate, nil
+ return m, aggregate, nil, nil
}
func (m mapCommand) Start(ctx context.Context, aggregatedMessages chan<- string) {
- m.aggregate.Start(ctx, aggregatedMessages)
+ if m.turboAggregate != nil {
+ m.turboAggregate.Start(ctx, aggregatedMessages)
+ } else {
+ m.aggregate.Start(ctx, aggregatedMessages)
+ }
}
diff --git a/internal/server/handlers/readcommand.go b/internal/server/handlers/readcommand.go
index bdb7b8b..ce44996 100644
--- a/internal/server/handlers/readcommand.go
+++ b/internal/server/handlers/readcommand.go
@@ -1,6 +1,7 @@
package handlers
import (
+ "bytes"
"context"
"os"
"path/filepath"
@@ -14,6 +15,7 @@ import (
"github.com/mimecast/dtail/internal/io/fs"
"github.com/mimecast/dtail/internal/io/line"
"github.com/mimecast/dtail/internal/lcontext"
+ "github.com/mimecast/dtail/internal/mapr/server"
"github.com/mimecast/dtail/internal/omode"
"github.com/mimecast/dtail/internal/regex"
)
@@ -169,6 +171,14 @@ func (r *readCommand) readFileIfPermissions(ctx context.Context, ltx lcontext.LC
// Check if we should trigger shutdown now
// Only shutdown if no files are pending AND no commands are active
if remaining == 0 && atomic.LoadInt32(&r.server.activeCommands) == 0 {
+ // If we have a turbo aggregate, trigger final serialization
+ if r.server.turboAggregate != nil {
+ dlog.Server.Info(r.server.user, "Triggering final turbo aggregate serialization")
+ r.server.turboAggregate.Serialize(context.Background())
+ // Give time for serialization to complete
+ time.Sleep(100 * time.Millisecond)
+ }
+
// Double-check that we really have no pending work
// In turbo mode, there might be a race condition
time.Sleep(10 * time.Millisecond)
@@ -248,10 +258,11 @@ func (r *readCommand) read(ctx context.Context, ltx lcontext.LContext,
}
// Check if we should use the turbo boost optimizations
- // Enable turbo boost for cat/grep/tail modes, but NOT for aggregate (MapReduce) operations
- // MapReduce requires the traditional channel-based approach to work correctly
- if config.Server.TurboModeEnable && r.server.aggregate == nil &&
- (r.mode == omode.CatClient || r.mode == omode.GrepClient || r.mode == omode.TailClient) {
+ // Enable turbo boost for cat/grep/tail modes, and now also for MapReduce operations
+ // MapReduce now has a turbo mode implementation that bypasses channels
+ if config.Server.TurboModeEnable &&
+ (r.mode == omode.CatClient || r.mode == omode.GrepClient || r.mode == omode.TailClient || r.server.turboAggregate != nil) {
+ dlog.Server.Info(r.server.user, "Using turbo mode for reading", path, "mode", r.mode, "hasTurboAggregate", r.server.turboAggregate != nil)
r.readWithTurboProcessor(ctx, ltx, path, globID, re, reader)
return
}
@@ -390,8 +401,21 @@ func (r *readCommand) readWithTurboProcessor(ctx context.Context, ltx lcontext.L
for {
dlog.Server.Trace(r.server.user, path, globID, "readWithTurboProcessor -> starting read loop iteration")
- // Create a direct processor that writes without channels
- processor := NewDirectLineProcessor(writer, globID)
+ // Create a processor based on whether we're doing MapReduce or not
+ var processor interface {
+ ProcessLine(*bytes.Buffer, uint64, string) error
+ Flush() error
+ Close() error
+ }
+
+ if r.server.turboAggregate != nil {
+ // Use turbo aggregate processor for MapReduce operations
+ dlog.Server.Info(r.server.user, "Using turbo aggregate processor for MapReduce", path, globID)
+ processor = server.NewTurboAggregateProcessor(r.server.turboAggregate, globID)
+ } else {
+ // Use direct line processor for cat/grep/tail
+ processor = NewDirectLineProcessor(writer, globID)
+ }
// Use the optimized reader
dlog.Server.Trace(r.server.user, path, globID, "readWithTurboProcessor -> reader.StartWithPocessorOptimized -> about to start")
diff --git a/internal/server/handlers/serverhandler.go b/internal/server/handlers/serverhandler.go
index da27066..df227ab 100644
--- a/internal/server/handlers/serverhandler.go
+++ b/internal/server/handlers/serverhandler.go
@@ -93,7 +93,7 @@ func (h *ServerHandler) handleUserCommand(ctx context.Context, ltx lcontext.LCon
commandFinished()
}()
case "map":
- command, aggregate, err := newMapCommand(h, argc, args)
+ command, aggregate, turboAggregate, err := newMapCommand(h, argc, args)
if err != nil {
h.sendln(h.serverMessages, err.Error())
dlog.Server.Error(h.user, err)
@@ -101,6 +101,7 @@ func (h *ServerHandler) handleUserCommand(ctx context.Context, ltx lcontext.LCon
return
}
h.aggregate = aggregate
+ h.turboAggregate = turboAggregate
go func() {
command.Start(ctx, h.maprMessages)
commandFinished()
generated by cgit v1.2.3 (git 2.25.1) at 2026-06-10 07:04:37 +0000