From 4035763ef4ffecb2c1ef908679d17c07458f8557 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Thu, 7 Jul 2016 11:22:15 -0500 Subject: [PATCH] ignore checksum on single node clusters --- fragment.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/fragment.go b/fragment.go index 90deb153f..e38867474 100644 --- a/fragment.go +++ b/fragment.go @@ -1245,13 +1245,17 @@ func (s *FragmentSyncer) isClosing() bool { func (s *FragmentSyncer) SyncFragment() error { // Determine replica set. nodes := s.Cluster.FragmentNodes(s.Fragment.DB(), s.Fragment.Slice()) - + if len(nodes) == 1 { + //fmt.Println("no place to replicate", s.Fragment.DB(), s.Fragment.Frame(), s.Fragment.Slice()) + return nil + } // Create a set of blocks. blockSets := make([][]FragmentBlock, 0, len(nodes)) for _, node := range nodes { // Read local blocks. if node.Host == s.Host { - blockSets = append(blockSets, s.Fragment.Blocks()) + b := s.Fragment.Blocks() + blockSets = append(blockSets, b) continue }