|
34 | 34 | import java.util.concurrent.CountDownLatch;
|
35 | 35 | import java.util.concurrent.atomic.AtomicReference;
|
36 | 36 |
|
37 |
| -import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked; |
38 |
| - |
39 | 37 | public class DynamicMappingIT extends ESIntegTestCase {
|
40 | 38 |
|
41 | 39 | @Override
|
@@ -75,21 +73,6 @@ private static void assertMappingsHaveField(GetMappingsResponse mappings, String
|
75 | 73 | assertTrue("Could not find [" + field + "] in " + typeMappingsMap.toString(), properties.containsKey(field));
|
76 | 74 | }
|
77 | 75 |
|
78 |
| - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/37816") |
79 |
| - public void testMappingsPropagatedToMasterNodeImmediately() throws IOException { |
80 |
| - assertAcked(prepareCreate("index")); |
81 |
| - |
82 |
| - // works when the type has been dynamically created |
83 |
| - client().prepareIndex("index", "type", "1").setSource("foo", 3).get(); |
84 |
| - GetMappingsResponse mappings = client().admin().indices().prepareGetMappings("index").setTypes("type").get(); |
85 |
| - assertMappingsHaveField(mappings, "index", "type", "foo"); |
86 |
| - |
87 |
| - // works if the type already existed |
88 |
| - client().prepareIndex("index", "type", "1").setSource("bar", "baz").get(); |
89 |
| - mappings = client().admin().indices().prepareGetMappings("index").setTypes("type").get(); |
90 |
| - assertMappingsHaveField(mappings, "index", "type", "bar"); |
91 |
| - } |
92 |
| - |
93 | 76 | public void testConcurrentDynamicUpdates() throws Throwable {
|
94 | 77 | createIndex("index");
|
95 | 78 | final Thread[] indexThreads = new Thread[32];
|
|
0 commit comments