@@ -71,7 +71,7 @@ public void createIndex() throws IOException {
7171 newVersion = nodes .getNewNodes ().get (0 ).getVersion ();
7272 isBwcNodeBeforeFieldsApiInQL = bwcVersion .before (FIELDS_API_QL_INTRODUCTION );
7373 isBwcNodeBeforeFieldsApiInES = bwcVersion .before (SWITCH_TO_FIELDS_API_VERSION );
74-
74+
7575 String mappings = readResource (SqlSearchIT .class .getResourceAsStream ("/all_field_types.json" ));
7676 createIndex (
7777 index ,
@@ -90,6 +90,7 @@ public void cleanUpIndex() throws IOException {
9090 }
9191 }
9292
93+ @ AwaitsFix (bugUrl = "https://github.com/elastic/elasticsearch/issues/70630" )
9394 public void testAllTypesWithRequestToOldNodes () throws Exception {
9495 Map <String , Object > expectedResponse = prepareTestData (
9596 columns -> {
@@ -173,7 +174,7 @@ private Map<String, Object> prepareTestData(Consumer<List<Map<String, Object>>>
173174 columns .add (columnInfo ("geo_point_no_dv_field" , "geo_point" ));
174175 columns .add (columnInfo ("geo_shape_field" , "geo_shape" ));
175176 columns .add (columnInfo ("shape_field" , "shape" ));
176-
177+
177178 expectedResponse .put ("columns" , columns );
178179 additionalColumns .accept (columns );
179180 List <List <Object >> rows = new ArrayList <>(numDocs );
@@ -196,7 +197,7 @@ private Map<String, Object> prepareTestData(Consumer<List<Map<String, Object>>>
196197 builder .append ("\" double_field\" :" + fieldValues .computeIfAbsent ("double_field" , v -> randomDouble ()) + "," );
197198 builder .append ("\" scaled_float_field\" :" + fieldValues .computeIfAbsent ("scaled_float_field" , v -> 123.5d ) + "," );
198199 builder .append ("\" boolean_field\" :" + fieldValues .computeIfAbsent ("boolean_field" , v -> randomBoolean ()) + "," );
199- builder .append ("\" ip_field\" :\" " + fieldValues .computeIfAbsent ("ip_field" , v -> "123.123.123.123" ) + "\" ," );
200+ builder .append ("\" ip_field\" :\" " + fieldValues .computeIfAbsent ("ip_field" , v -> "123.123.123.123" ) + "\" ," );
200201 builder .append ("\" text_field\" : \" " + fieldValues .computeIfAbsent ("text_field" , v -> randomAlphaOfLength (5 )) + "\" ," );
201202 builder .append ("\" keyword_field\" : \" " + fieldValues .computeIfAbsent ("keyword_field" , v -> randomAlphaOfLength (5 )) + "\" ," );
202203 builder .append ("\" constant_keyword_field\" : \" " + fieldValues .computeIfAbsent ("constant_keyword_field" ,
@@ -210,7 +211,7 @@ private Map<String, Object> prepareTestData(Consumer<List<Map<String, Object>>>
210211 fieldValues .put ("shape_field" , "POINT (-122.083843 37.386483 30.0)" );
211212 additionalValues .accept (builder , fieldValues );
212213 builder .append ("}" );
213-
214+
214215 Request request = new Request ("PUT" , index + "/_doc/" + i );
215216 request .setJsonEntity (builder .toString ());
216217 assertOK (client ().performRequest (request ));
0 commit comments