Skip to content

Commit 10ec96d

Browse files
committed
Revert CrossClusterSearchIT changes
1 parent b407a4f commit 10ec96d

File tree

1 file changed

+0
-16
lines changed

1 file changed

+0
-16
lines changed

server/src/internalClusterTest/java/org/elasticsearch/search/ccs/CrossClusterSearchIT.java

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
import org.elasticsearch.common.util.CollectionUtils;
2626
import org.elasticsearch.core.TimeValue;
2727
import org.elasticsearch.index.query.MatchAllQueryBuilder;
28-
import org.elasticsearch.index.query.MatchQueryBuilder;
2928
import org.elasticsearch.index.query.RangeQueryBuilder;
3029
import org.elasticsearch.plugins.Plugin;
3130
import org.elasticsearch.plugins.SearchPlugin;
@@ -162,21 +161,6 @@ public void testClusterDetailsAfterSuccessfulCCS() throws Exception {
162161
});
163162
}
164163

165-
public void testCCSQueryRewrite() throws Exception {
166-
Map<String, Object> testClusterInfo = setupTwoClusters();
167-
String localIndex = (String) testClusterInfo.get("local.index");
168-
String remoteIndex = (String) testClusterInfo.get("remote.index");
169-
int localNumShards = (Integer) testClusterInfo.get("local.num_shards");
170-
int remoteNumShards = (Integer) testClusterInfo.get("remote.num_shards");
171-
172-
SearchRequest searchRequest = new SearchRequest(localIndex, REMOTE_CLUSTER + ":" + remoteIndex);
173-
// searchRequest.setCcsMinimizeRoundtrips(false);
174-
175-
searchRequest.source(new SearchSourceBuilder().query(new MatchQueryBuilder("foo", "bar")).size(10));
176-
177-
assertResponse(client(LOCAL_CLUSTER).search(searchRequest), response -> { assertNotNull(response); });
178-
}
179-
180164
// CCS with a search where the timestamp of the query cannot match so should be SUCCESSFUL with all shards skipped
181165
// during can-match
182166
public void testCCSClusterDetailsWhereAllShardsSkippedInCanMatch() throws Exception {

0 commit comments

Comments
 (0)