Skip to content

Commit de9ee4f

Browse files
author
Christoph Büscher
committed
Adressing comments
1 parent 88fbe41 commit de9ee4f

File tree

1 file changed

+5
-7
lines changed
  • client/rest-high-level/src/test/java/org/elasticsearch/client

1 file changed

+5
-7
lines changed

client/rest-high-level/src/test/java/org/elasticsearch/client/CrudIT.java

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -655,16 +655,14 @@ public void testReindex() throws Exception {
655655
.build();
656656
createIndex(sourceIndex, settings);
657657
createIndex(destinationIndex, settings);
658-
BulkRequest setRefreshPolicy = new BulkRequest()
659-
.add(new IndexRequest(sourceIndex, "type", "1")
660-
.source(Collections.singletonMap("foo", "bar"), XContentType.JSON))
661-
.add(new IndexRequest(sourceIndex, "type", "2")
662-
.source(Collections.singletonMap("foo2", "bar2"), XContentType.JSON))
663-
.setRefreshPolicy(RefreshPolicy.IMMEDIATE);
658+
BulkRequest bulkRequest = new BulkRequest()
659+
.add(new IndexRequest(sourceIndex, "type", "1").source(Collections.singletonMap("foo", "bar"), XContentType.JSON))
660+
.add(new IndexRequest(sourceIndex, "type", "2").source(Collections.singletonMap("foo2", "bar2"), XContentType.JSON))
661+
.setRefreshPolicy(RefreshPolicy.IMMEDIATE);
664662
assertEquals(
665663
RestStatus.OK,
666664
highLevelClient().bulk(
667-
setRefreshPolicy,
665+
bulkRequest,
668666
RequestOptions.DEFAULT
669667
).status()
670668
);

0 commit comments

Comments
 (0)