From 497cd506f90a99c5321d6e8c4a4b0e71e3612bb6 Mon Sep 17 00:00:00 2001 From: Jason Wilder Date: Mon, 1 Jun 2015 16:45:08 -0600 Subject: [PATCH] Remove temporary INFLUXDB_ALPHA write path enable flag Real thing exists now. --- cluster/points_writer.go | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/cluster/points_writer.go b/cluster/points_writer.go index 4246289cc1..7bba01b886 100644 --- a/cluster/points_writer.go +++ b/cluster/points_writer.go @@ -2,7 +2,6 @@ package cluster import ( "errors" - "os" "sync" "time" @@ -119,19 +118,6 @@ func (w *PointsWriter) Close() error { // created before returning the mapping. func (w *PointsWriter) MapShards(wp *WritePointsRequest) (*ShardMapping, error) { - // Stub out the MapShards call to return a single node/shard setup - if os.Getenv("INFLUXDB_ALPHA1") != "" { - sm := NewShardMapping() - sh := &meta.ShardInfo{ - ID: uint64(1), - OwnerIDs: []uint64{uint64(1)}, - } - for _, p := range wp.Points { - sm.MapPoint(sh, p) - } - return sm, nil - } - // holds the start time ranges for required shard groups timeRanges := map[time.Time]*meta.ShardGroupInfo{}