diff --git a/internal_client.go b/internal_client.go
index 21ba3fba3..9470892d8 100644
--- a/internal_client.go
+++ b/internal_client.go
@@ -2259,9 +2259,17 @@ func (c *InternalClient) IndexTranslateDataReader(ctx context.Context, index str
 func (c *InternalClient) FieldTranslateDataReader(ctx context.Context, index, field string) (io.ReadCloser, error) {
 	span, ctx := tracing.StartSpanFromContext(ctx, "InternalClient.FieldTranslateDataReader")
 	defer span.Finish()
+	nodes, err := c.Nodes(ctx)
+	if err != nil {
+		return nil, err
+	}
 
+	primary := getPrimaryNode(nodes)
+	if primary == nil {
+		return nil, errors.New("no primary")
+	}
 	// Execute request against the host.
-	u := fmt.Sprintf("%s%s/internal/translate/data?index=%s&field=%s", c.defaultURI, c.prefix(), url.QueryEscape(index), url.QueryEscape(field))
+	u := fmt.Sprintf("%s%s/internal/translate/data?index=%s&field=%s", primary.URI, c.prefix(), url.QueryEscape(index), url.QueryEscape(field))
 
 	// Build request.
 	req, err := http.NewRequest("GET", u, nil)