From 3ccd4887556726f13ef07ad6ab1733a010018119 Mon Sep 17 00:00:00 2001 From: Nhat Nguyen Date: Thu, 24 Jan 2019 21:48:50 -0500 Subject: [PATCH] Remove testMappingsPropagatedToMasterNodeImmediately This test is obsolete since #31140 where an index request with dynamic mapping update no longer requires acking. Closes #37816 --- .../index/mapper/DynamicMappingIT.java | 17 ----------------- 1 file changed, 17 deletions(-) diff --git a/server/src/test/java/org/elasticsearch/index/mapper/DynamicMappingIT.java b/server/src/test/java/org/elasticsearch/index/mapper/DynamicMappingIT.java index 47ab7f71b51..5655d741a9d 100644 --- a/server/src/test/java/org/elasticsearch/index/mapper/DynamicMappingIT.java +++ b/server/src/test/java/org/elasticsearch/index/mapper/DynamicMappingIT.java @@ -34,8 +34,6 @@ import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.atomic.AtomicReference; -import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked; - public class DynamicMappingIT extends ESIntegTestCase { @Override @@ -75,21 +73,6 @@ public class DynamicMappingIT extends ESIntegTestCase { assertTrue("Could not find [" + field + "] in " + typeMappingsMap.toString(), properties.containsKey(field)); } - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/37816") - public void testMappingsPropagatedToMasterNodeImmediately() throws IOException { - assertAcked(prepareCreate("index")); - - // works when the type has been dynamically created - client().prepareIndex("index", "type", "1").setSource("foo", 3).get(); - GetMappingsResponse mappings = client().admin().indices().prepareGetMappings("index").setTypes("type").get(); - assertMappingsHaveField(mappings, "index", "type", "foo"); - - // works if the type already existed - client().prepareIndex("index", "type", "1").setSource("bar", "baz").get(); - mappings = client().admin().indices().prepareGetMappings("index").setTypes("type").get(); - assertMappingsHaveField(mappings, "index", "type", "bar"); - } - public void testConcurrentDynamicUpdates() throws Throwable { createIndex("index"); final Thread[] indexThreads = new Thread[32];