diff --git a/.github/workflows/build_hive.yml b/.github/workflows/build_hive.yml
index 914eee2f1..b67374909 100644
--- a/.github/workflows/build_hive.yml
+++ b/.github/workflows/build_hive.yml
@@ -47,4 +47,11 @@ jobs:
         uses: gradle/gradle-build-action@v2
 
       - name: Build with Gradle
-        run: ./gradlew opensearch-hadoop-hive:build
\ No newline at end of file
+        run: ./gradlew opensearch-hadoop-hive:build
+
+      - name: Publish Test Results
+        if: failure()
+        uses: actions/upload-artifact@v2
+        with:
+          name: test-results-${{ matrix.os }}
+          path: '**/build/test-results'
\ No newline at end of file
diff --git a/.github/workflows/build_mr.yml b/.github/workflows/build_mr.yml
index 7a7780f08..21d00bcb2 100644
--- a/.github/workflows/build_mr.yml
+++ b/.github/workflows/build_mr.yml
@@ -47,4 +47,11 @@ jobs:
         uses: gradle/gradle-build-action@v2
 
       - name: Build with Gradle
-        run: ./gradlew opensearch-hadoop-mr:build
\ No newline at end of file
+        run: ./gradlew opensearch-hadoop-mr:build
+
+      - name: Publish Test Results
+        if: failure()
+        uses: actions/upload-artifact@v2
+        with:
+          name: test-results-${{ matrix.os }}
+          path: '**/build/test-results'
\ No newline at end of file
diff --git a/.github/workflows/build_spark.yml b/.github/workflows/build_spark.yml
index 64adbac98..0f5fceb76 100644
--- a/.github/workflows/build_spark.yml
+++ b/.github/workflows/build_spark.yml
@@ -47,4 +47,11 @@ jobs:
         uses: gradle/gradle-build-action@v2
 
       - name: Build with Gradle
-        run: ./gradlew opensearch-spark:build
\ No newline at end of file
+        run: ./gradlew opensearch-spark:build
+
+      - name: Publish Test Results
+        if: failure()
+        uses: actions/upload-artifact@v2
+        with:
+          name: test-results-${{ matrix.os }}
+          path: '**/build/test-results'
\ No newline at end of file
diff --git a/.github/workflows/build_spark_20.yml b/.github/workflows/build_spark_20.yml
index 8f1b7435d..26dadd7a4 100644
--- a/.github/workflows/build_spark_20.yml
+++ b/.github/workflows/build_spark_20.yml
@@ -47,4 +47,11 @@ jobs:
         uses: gradle/gradle-build-action@v2
 
       - name: Build with Gradle
-        run: ./gradlew opensearch-spark-20:integrationTest
\ No newline at end of file
+        run: ./gradlew opensearch-spark-20:integrationTest
+
+      - name: Publish Test Results
+        if: failure()
+        uses: actions/upload-artifact@v2
+        with:
+          name: test-results-${{ matrix.os }}
+          path: '**/build/test-results'
\ No newline at end of file
diff --git a/.github/workflows/build_spark_20_scala_210.yml b/.github/workflows/build_spark_20_scala_210.yml
index 009ea5536..4c5e0a4de 100644
--- a/.github/workflows/build_spark_20_scala_210.yml
+++ b/.github/workflows/build_spark_20_scala_210.yml
@@ -47,4 +47,11 @@ jobs:
         uses: gradle/gradle-build-action@v2
 
       - name: Build with Gradle
-        run: ./gradlew opensearch-spark-20:integrationTestSpark20scala210
\ No newline at end of file
+        run: ./gradlew opensearch-spark-20:integrationTestSpark20scala210
+
+      - name: Publish Test Results
+        if: failure()
+        uses: actions/upload-artifact@v2
+        with:
+          name: test-results-${{ matrix.os }}
+          path: '**/build/test-results'
\ No newline at end of file
diff --git a/.github/workflows/build_spark_20_scala_211.yml b/.github/workflows/build_spark_20_scala_211.yml
index d51afd5ab..003918843 100644
--- a/.github/workflows/build_spark_20_scala_211.yml
+++ b/.github/workflows/build_spark_20_scala_211.yml
@@ -47,4 +47,11 @@ jobs:
         uses: gradle/gradle-build-action@v2
 
       - name: Build with Gradle
-        run: ./gradlew opensearch-spark-20:integrationTestSpark20scala210
\ No newline at end of file
+        run: ./gradlew opensearch-spark-20:integrationTestSpark20scala210
+
+      - name: Publish Test Results
+        if: failure()
+        uses: actions/upload-artifact@v2
+        with:
+          name: test-results-${{ matrix.os }}
+          path: '**/build/test-results'
\ No newline at end of file
diff --git a/.github/workflows/build_spark_30.yml b/.github/workflows/build_spark_30.yml
index 8f9a979dd..04968dda6 100644
--- a/.github/workflows/build_spark_30.yml
+++ b/.github/workflows/build_spark_30.yml
@@ -47,4 +47,11 @@ jobs:
         uses: gradle/gradle-build-action@v2
 
       - name: Build with Gradle
-        run: ./gradlew opensearch-spark-30:integrationTest
\ No newline at end of file
+        run: ./gradlew opensearch-spark-30:integrationTest
+
+      - name: Publish Test Results
+        if: failure()
+        uses: actions/upload-artifact@v2
+        with:
+          name: test-results-${{ matrix.os }}
+          path: '**/build/test-results'
\ No newline at end of file
diff --git a/.github/workflows/build_spark_30_scala_213.yml b/.github/workflows/build_spark_30_scala_213.yml
index d56005440..05126cb09 100644
--- a/.github/workflows/build_spark_30_scala_213.yml
+++ b/.github/workflows/build_spark_30_scala_213.yml
@@ -47,4 +47,11 @@ jobs:
         uses: gradle/gradle-build-action@v2
 
       - name: Build with Gradle
-        run: ./gradlew opensearch-spark-30:integrationTestSpark30scala213
\ No newline at end of file
+        run: ./gradlew opensearch-spark-30:integrationTestSpark30scala213
+
+      - name: Publish Test Results
+        if: failure()
+        uses: actions/upload-artifact@v2
+        with:
+          name: test-results-${{ matrix.os }}
+          path: '**/build/test-results'
\ No newline at end of file
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 9e28d500d..4bf51d01a 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -29,6 +29,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 ### Removed
 
 ### Fixed
+- Corrected the delete by query endpoint to match the OpenSearch API ([#350](https://github.com/opensearch-project/opensearch-hadoop/pull/350))
 
 ### Security
 
diff --git a/mr/src/itest/java/org/opensearch/hadoop/integration/rest/AbstractRestQueryTest.java b/mr/src/itest/java/org/opensearch/hadoop/integration/rest/AbstractRestQueryTest.java
index 1586d734a..0b73cdae3 100644
--- a/mr/src/itest/java/org/opensearch/hadoop/integration/rest/AbstractRestQueryTest.java
+++ b/mr/src/itest/java/org/opensearch/hadoop/integration/rest/AbstractRestQueryTest.java
@@ -69,7 +69,7 @@ public class AbstractRestQueryTest {
     @Before
     public void start() throws IOException {
         version = TestUtils.getOpenSearchClusterInfo().getMajorVersion();
-        settings = new TestSettings("rest/savebulk");
+        settings = new TestSettings("rest_save_bulk");
         settings.setInternalVersion(version);
         //testSettings.setPort(9200)
         settings.setProperty(ConfigurationOptions.OPENSEARCH_SERIALIZATION_WRITER_VALUE_CLASS, JdkValueWriter.class.getName());
diff --git a/mr/src/itest/java/org/opensearch/hadoop/integration/rest/AbstractRestSaveTest.java b/mr/src/itest/java/org/opensearch/hadoop/integration/rest/AbstractRestSaveTest.java
index 005a78a9d..608969411 100644
--- a/mr/src/itest/java/org/opensearch/hadoop/integration/rest/AbstractRestSaveTest.java
+++ b/mr/src/itest/java/org/opensearch/hadoop/integration/rest/AbstractRestSaveTest.java
@@ -34,6 +34,7 @@
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.junit.Ignore;
 import org.opensearch.hadoop.OpenSearchHadoopIllegalArgumentException;
 import org.opensearch.hadoop.cfg.ConfigurationOptions;
 import org.opensearch.hadoop.cfg.Settings;
@@ -66,9 +67,11 @@ public class AbstractRestSaveTest {
 
     private static final Log LOG = LogFactory.getLog(AbstractRestSaveTest.class);
 
+    private static final JsonUtils.Query HITS_TOTAL_VALUE = JsonUtils.query("hits").get("total").get("value");
+
     @Test
     public void testBulkWrite() throws Exception {
-        TestSettings testSettings = new TestSettings("rest/savebulk");
+        TestSettings testSettings = new TestSettings("rest_save_bulk");
         //testSettings.setPort(9200)
         testSettings.setProperty(ConfigurationOptions.OPENSEARCH_SERIALIZATION_WRITER_VALUE_CLASS, JdkValueWriter.class.getName());
         RestRepository client = new RestRepository(testSettings);
@@ -83,6 +86,7 @@ public void testBulkWrite() throws Exception {
             line.put("name", in.next());
             line.put("url", in.next());
             line.put("picture", in.next());
+            in.nextLine();
             client.writeToIndex(line);
             line.clear();
         }
@@ -90,9 +94,10 @@ public void testBulkWrite() throws Exception {
         client.close();
     }
 
+    @Ignore("OpenSearch throws an error on empty bulk request")
     @Test
     public void testEmptyBulkWrite() throws Exception {
-        TestSettings testSettings = new TestSettings("rest/emptybulk");
+        TestSettings testSettings = new TestSettings("rest_empty_bulk");
         testSettings.setInternalClusterInfo(TestUtils.getOpenSearchClusterInfo());
         testSettings.setProperty(ConfigurationOptions.OPENSEARCH_SERIALIZATION_WRITER_VALUE_CLASS, JdkValueWriter.class.getName());
         RestRepository restRepo = new RestRepository(testSettings);
@@ -105,8 +110,9 @@ public void testEmptyBulkWrite() throws Exception {
 
     @Test
     public void testRepositoryDelete() throws Exception {
-        Settings settings = new TestSettings("rest/deletebulk");
-        RestUtils.delete("rest");
+        String index = "rest_delete_bulk";
+        Settings settings = new TestSettings(index);
+        RestUtils.delete(index);
         InitializationUtils.discoverClusterInfo(settings, LOG);
         settings.setProperty(ConfigurationOptions.OPENSEARCH_SERIALIZATION_WRITER_VALUE_CLASS, JdkValueWriter.class.getName());
         settings.setProperty(ConfigurationOptions.OPENSEARCH_MAPPING_DEFAULT_EXTRACTOR_CLASS, ConstantFieldExtractor.class.getName());
@@ -120,18 +126,18 @@ public void testRepositoryDelete() throws Exception {
         String doc = "{\"index\":{\"_id\":\"" + StringUtils.jsonEncoding(id) + "\"}}\n{\"field\":1}\n";
         repository.writeProcessedToIndex(new BytesArray(doc));
         repository.flush();
-        RestUtils.refresh("rest");
+        RestUtils.refresh(index);
 
-        assertThat(JsonUtils.query("hits").get("total").apply(JsonUtils.asMap(RestUtils.get("rest/deletebulk/_search"))), is(equalTo(1)));
+        assertThat(HITS_TOTAL_VALUE.apply(JsonUtils.asMap(RestUtils.get(index + "/_search"))), is(equalTo(1)));
 
         repository.delete();
 
-        assertThat(JsonUtils.query("hits").get("total").apply(JsonUtils.asMap(RestUtils.get("rest/deletebulk/_search"))), is(equalTo(0)));
+        assertThat(HITS_TOTAL_VALUE.apply(JsonUtils.asMap(RestUtils.get(index + "/_search"))), is(equalTo(0)));
     }
 
     @Test
     public void testRepositoryDeleteEmptyIndex() throws Exception {
-        Settings settings = new TestSettings("delete_empty/test");
+        Settings settings = new TestSettings("delete_empty");
         RestUtils.delete("delete_empty");
         InitializationUtils.discoverClusterInfo(settings, LOG);
         settings.setProperty(ConfigurationOptions.OPENSEARCH_SERIALIZATION_WRITER_VALUE_CLASS, JdkValueWriter.class.getName());
@@ -143,11 +149,11 @@ public void testRepositoryDeleteEmptyIndex() throws Exception {
         RestRepository repository = new RestRepository(settings);
         repository.touch();
 
-        assertThat(JsonUtils.query("hits").get("total").apply(JsonUtils.asMap(RestUtils.get("delete_empty/test/_search"))), is(equalTo(0)));
+        assertThat(HITS_TOTAL_VALUE.apply(JsonUtils.asMap(RestUtils.get("delete_empty/_search"))), is(equalTo(0)));
 
         repository.delete();
 
-        assertThat(JsonUtils.query("hits").get("total").apply(JsonUtils.asMap(RestUtils.get("delete_empty/test/_search"))), is(equalTo(0)));
+        assertThat(HITS_TOTAL_VALUE.apply(JsonUtils.asMap(RestUtils.get("delete_empty/_search"))), is(equalTo(0)));
     }
 
 
diff --git a/mr/src/itest/java/org/opensearch/hadoop/integration/rest/RestSuite.java b/mr/src/itest/java/org/opensearch/hadoop/integration/rest/RestSuite.java
index cdd9ecf65..0a190ca4a 100644
--- a/mr/src/itest/java/org/opensearch/hadoop/integration/rest/RestSuite.java
+++ b/mr/src/itest/java/org/opensearch/hadoop/integration/rest/RestSuite.java
@@ -35,7 +35,6 @@
 import org.junit.runner.RunWith;
 import org.junit.runners.Suite;
 
-@Ignore
 @RunWith(Suite.class)
 @Suite.SuiteClasses({ AbstractRestSaveTest.class, AbstractRestQueryTest.class })
 public class RestSuite {
diff --git a/mr/src/main/java/org/opensearch/hadoop/rest/RestClient.java b/mr/src/main/java/org/opensearch/hadoop/rest/RestClient.java
index 8b901340a..6722f7d5a 100644
--- a/mr/src/main/java/org/opensearch/hadoop/rest/RestClient.java
+++ b/mr/src/main/java/org/opensearch/hadoop/rest/RestClient.java
@@ -238,7 +238,7 @@ public int getResponseCode() {
     public BulkActionResponse bulk(Resource resource, TrackingBytesArray data) {
         // NB: dynamically get the stats since the transport can change
         long start = network.transportStats().netTotalTime;
-        Response response = execute(PUT, resource.bulk(), data);
+        Response response = execute(POST, resource.bulk(), data);
         long spent = network.transportStats().netTotalTime - start;
 
         stats.bulkTotal++;
@@ -499,6 +499,13 @@ public boolean delete(String indexOrType) {
         return (res.status() == HttpStatus.OK ? true : false);
     }
 
+    public int deleteByQuery(String indexOrType, QueryBuilder query) {
+        BytesArray body = searchRequest(query);
+        Request req = new SimpleRequest(POST, null, indexOrType + "/_delete_by_query", body);
+        Response res = executeNotFoundAllowed(req);
+        return parseContent(res.body(), "deleted");
+    }
+
     public boolean deleteScroll(String scrollId) {
         BytesArray body = new BytesArray(("{\"scroll_id\":[\"" + scrollId + "\"]}").getBytes(StringUtils.UTF_8));
         Request req = new SimpleRequest(DELETE, null, "_search/scroll", body);
diff --git a/mr/src/main/java/org/opensearch/hadoop/rest/RestRepository.java b/mr/src/main/java/org/opensearch/hadoop/rest/RestRepository.java
index a55f86cae..3556608e6 100644
--- a/mr/src/main/java/org/opensearch/hadoop/rest/RestRepository.java
+++ b/mr/src/main/java/org/opensearch/hadoop/rest/RestRepository.java
@@ -44,6 +44,7 @@
 import org.opensearch.hadoop.cfg.Settings;
 import org.opensearch.hadoop.rest.bulk.BulkProcessor;
 import org.opensearch.hadoop.rest.bulk.BulkResponse;
+import org.opensearch.hadoop.rest.query.MatchAllQueryBuilder;
 import org.opensearch.hadoop.rest.query.QueryUtils;
 import org.opensearch.hadoop.rest.stats.Stats;
 import org.opensearch.hadoop.rest.stats.StatsAware;
@@ -376,15 +377,16 @@ public boolean touch() {
     }
 
     public void delete() {
-        // try first a blind delete by query (since the plugin might be installed)
+        // try first a blind delete by query
         try {
-            if (resources.getResourceWrite().isTyped()) {
-                client.delete(resources.getResourceWrite().index() + "/" + resources.getResourceWrite().type() + "/_query?q=*");
-            } else {
-                client.delete(resources.getResourceWrite().index() + "/_query?q=*");
-            }
+            Resource res = resources.getResourceWrite();
+            client.deleteByQuery(
+                    res.isTyped()
+                            ? res.index() + "/" + res.type()
+                            : res.index(),
+                    MatchAllQueryBuilder.MATCH_ALL);
         } catch (OpenSearchHadoopInvalidRequest ehir) {
-            log.info("Skipping delete by query as the plugin is not installed...");
+            log.error("Delete by query was not successful...", ehir);
         }
 
         // in ES 2.0 and higher this means scrolling and deleting the docs by hand...