jwilder

package merge

import (
	"sort"
	"testing"
	"time"

	"github.com/influxdata/influxdb/tsdb/engine/tsm1"
)

jwilder

func BenchmarkWAL_Write_1(b *testing.B) {
	benchmarkWALWrite(b, 1)
}

// func BenchmarkWAL_Write_10(b *testing.B) {
// 	benchmarkWALWrite(b, 10)
// }

func benchmarkWALWrite(b *testing.B, concurrency int) {
	points := map[string][]tsm1.Value{}

jwilder

diff --git a/coordinator/query_executor.go b/coordinator/query_executor.go
index 34ec5a4..a93680c 100644
--- a/coordinator/query_executor.go
+++ b/coordinator/query_executor.go
@@ -1076,22 +1076,6 @@ func (d *NodeDialer) DialNode(nodeID uint64) (net.Conn, error) {
        return conn, nil
 }

-// TSDBStore is an interface for accessing the time series data store.
-type TSDBStore interface {

jwilder

[monitor] 2015/10/23 14:00:08 failed to store statistics: timeout
^\SIGQUIT: quit
PC=0x6347b m=0

goroutine 0 [idle]:
runtime.mach_semaphore_wait(0xe03, 0x0, 0x33401, 0xc820124180, 0xc989a0, 0xc989a0, 0x55c59, 0xffffffffffffffff, 0x0, 0x7fff5fbff8ec, ...)
	/usr/local/go/src/runtime/sys_darwin_amd64.s:407 +0xb
runtime.semasleep1(0xffffffffffffffff, 0x0)
	/usr/local/go/src/runtime/os1_darwin.go:385 +0xe5
runtime.semasleep.func1()

jwilder

Summary:
  File: /Users/jason/.influxdb/data/stress/default/2/0000001.tsm1
  Time Range: 1974-07-30T19:40:14.048274791Z - 1974-07-30T19:40:14.248274792Z
  Duration: 200.000001ms   Series: 20   File Size: 1385

Index:
  Pos	ID			Ofs	Key			Field
  0	1457934444615313758	4	cpu,host=server-49999	value
  1	1530265636438342380	61	cpu,host=server-69999	value
  2	1674605844894586950	115	cpu,host=server-74999	value

jwilder

diff --git a/influxql/functions.go b/influxql/functions.go
index 3d75c5a..918f241 100644
--- a/influxql/functions.go
+++ b/influxql/functions.go
@@ -949,6 +949,8 @@ func MapFirst(itr Iterator) interface{} {
                if k < out.Time {
                        out.Time = k
                        out.Val = v
+               } else if k == out.Time && greaterThan(v, out.Val) {
+                       out.Val = v

jwilder

package main

import (
	crand "crypto/rand"
	"encoding/base64"
	"fmt"
	"math/rand"
	"net/url"
	"os"
	"strings"

jwilder

influxdb:influxdb jason$ cpulimit -l 10 -i go test -v -run Test5 ./cmd/influxd/
System Info: CPU=8 GOMAXPROCS=1
=== RUN Test5NodeClusterPartiallyReplicated
2015/04/22 15:59:13 influxdb started, version 0.9, commit
2015/04/22 15:59:13 Cluster server listening on [::]:62064
2015/04/22 15:59:13 broker opened at /var/folders/lj/vlbynqp52pxdxxlxx64j6bk80000gn/T/influxdb-541380742/broker-integration-test/0
[raft] 2015/04/22 15:59:13 Open: fsm: index=0
[raft] 2015/04/22 15:59:13 log pending: waiting for initialization or join
[raft] 2015/04/22 15:59:13 changing term: 0 => 1
[raft] 2015/04/22 15:59:13 log state change: stopped => leader (term=1)

jwilder

diff --git a/remote_mapper.go b/remote_mapper.go
index ee03e8a..3b520fb 100644
--- a/remote_mapper.go
+++ b/remote_mapper.go
@@ -4,13 +4,14 @@ import (
        "bytes"
        "encoding/json"
        "errors"
+       "io"
        "net/http"