diff --git a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
index 0d3476c..e6527aa 100644
--- a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
+++ b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
@@ -33,6 +33,7 @@
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.ExpectedException;
@@ -83,6 +84,7 @@
 
   @Rule public TestPipeline pipeline = TestPipeline.create();
 
+  @Ignore("https://issues.apache.org/jira/browse/BEAM-5172")
   @Test
   public void testSizes() throws Exception {
     // need to create the index using the helper method (not create it at first insertion)
@@ -142,6 +144,7 @@
     elasticsearchIOTestCommon.testWriteWithMaxBatchSizeBytes();
   }
 
+  @Ignore("https://issues.apache.org/jira/browse/BEAM-5172")
   @Test
   public void testSplit() throws Exception {
     // need to create the index using the helper method (not create it at first insertion)
diff --git a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
index 9812403..520b590 100644
--- a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
+++ b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
@@ -33,6 +33,7 @@
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.ExpectedException;
@@ -82,6 +83,7 @@
 
   @Rule public TestPipeline pipeline = TestPipeline.create();
 
+  @Ignore("https://issues.apache.org/jira/browse/BEAM-5172")
   @Test
   public void testSizes() throws Exception {
     // need to create the index using the helper method (not create it at first insertion)
@@ -141,6 +143,7 @@
     elasticsearchIOTestCommon.testWriteWithMaxBatchSizeBytes();
   }
 
+  @Ignore("https://issues.apache.org/jira/browse/BEAM-5172")
   @Test
   public void testSplit() throws Exception {
     // need to create the index using the helper method (not create it at first insertion)
diff --git a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-7/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-7/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
index e503013..05f4bd9 100644
--- a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-7/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
+++ b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-7/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
@@ -33,6 +33,7 @@
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.ExpectedException;
@@ -83,6 +84,7 @@
 
   @Rule public TestPipeline pipeline = TestPipeline.create();
 
+  @Ignore("https://issues.apache.org/jira/browse/BEAM-5172")
   @Test
   public void testSizes() throws Exception {
     // need to create the index using the helper method (not create it at first insertion)
@@ -142,6 +144,7 @@
     elasticsearchIOTestCommon.testWriteWithMaxBatchSizeBytes();
   }
 
+  @Ignore("https://issues.apache.org/jira/browse/BEAM-5172")
   @Test
   public void testSplit() throws Exception {
     // need to create the index using the helper method (not create it at first insertion)