diff --git a/executor_internal_test.go b/executor_internal_test.go index 7ccb26b15..b4487dca6 100644 --- a/executor_internal_test.go +++ b/executor_internal_test.go @@ -30,7 +30,9 @@ func TestExecutor_TranslateGroupByCall(t *testing.T) { cluster := newCluster() cluster.holder = holder cluster.Node = &Node{ID: "node1", URI: NewTestURIFromHostPort("node1", 0)} - cluster.addNode(cluster.Node) + if err := cluster.addNode(cluster.Node); err != nil { + t.Fatal(err) + } e := &executor{ Holder: holder, diff --git a/holder.go b/holder.go index f4e61cc48..73e907be8 100644 --- a/holder.go +++ b/holder.go @@ -81,9 +81,6 @@ type Holder struct { snapshotQueue snapshotQueue - // Manages replication from the primary node. - primaryTranslateNode *Node - // Instantiates new translation stores OpenTranslateStore OpenTranslateStoreFunc OpenTranslateReader OpenTranslateReaderFunc