diff --git a/server/src/main/java/org/opensearch/action/admin/indices/segments/PitSegmentsRequest.java b/server/src/main/java/org/opensearch/action/admin/indices/segments/PitSegmentsRequest.java
index 84f5e5ad6a1e8..c26ce48a210b4 100644
--- a/server/src/main/java/org/opensearch/action/admin/indices/segments/PitSegmentsRequest.java
+++ b/server/src/main/java/org/opensearch/action/admin/indices/segments/PitSegmentsRequest.java
@@ -13,6 +13,7 @@
 import org.opensearch.common.Strings;
 import org.opensearch.common.io.stream.StreamInput;
 import org.opensearch.common.io.stream.StreamOutput;
+import org.opensearch.common.xcontent.XContentParser;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -84,4 +85,37 @@ public ActionRequestValidationException validate() {
         }
         return validationException;
     }
+
+    public void fromXContent(XContentParser parser) throws IOException {
+        pitIds.clear();
+        if (parser.nextToken() != XContentParser.Token.START_OBJECT) {
+            throw new IllegalArgumentException("Malformed content, must start with an object");
+        } else {
+            XContentParser.Token token;
+            String currentFieldName = null;
+            while ((token = parser.nextToken()) != XContentParser.Token.END_OBJECT) {
+                if (token == XContentParser.Token.FIELD_NAME) {
+                    currentFieldName = parser.currentName();
+                } else if ("pit_id".equals(currentFieldName)) {
+                    if (token == XContentParser.Token.START_ARRAY) {
+                        while ((token = parser.nextToken()) != XContentParser.Token.END_ARRAY) {
+                            if (token.isValue() == false) {
+                                throw new IllegalArgumentException("pit_id array element should only contain pit_id");
+                            }
+                            pitIds.add(parser.text());
+                        }
+                    } else {
+                        if (token.isValue() == false) {
+                            throw new IllegalArgumentException("pit_id element should only contain pit_id");
+                        }
+                        pitIds.add(parser.text());
+                    }
+                } else {
+                    throw new IllegalArgumentException(
+                        "Unknown parameter [" + currentFieldName + "] in request body or parameter is of the wrong type[" + token + "] "
+                    );
+                }
+            }
+        }
+    }
 }
diff --git a/server/src/main/java/org/opensearch/action/admin/indices/segments/TransportPitSegmentsAction.java b/server/src/main/java/org/opensearch/action/admin/indices/segments/TransportPitSegmentsAction.java
index 9d4ece74a7270..6a4b4b6b4019a 100644
--- a/server/src/main/java/org/opensearch/action/admin/indices/segments/TransportPitSegmentsAction.java
+++ b/server/src/main/java/org/opensearch/action/admin/indices/segments/TransportPitSegmentsAction.java
@@ -95,7 +95,11 @@ public TransportPitSegmentsAction(
     @Override
     protected void doExecute(Task task, PitSegmentsRequest request, ActionListener<IndicesSegmentResponse> listener) {
         List<String> pitIds = request.getPitIds();
-        if (pitIds.size() == 1 && "_all".equals(pitIds.get(0))) {
+        // when security plugin intercepts the request, if PITs are not present in the cluster the PIT IDs in request will be empty
+        // and in this case return empty response
+        if (pitIds.isEmpty()) {
+            listener.onResponse(new IndicesSegmentResponse(new ShardSegments[] {}, 0, 0, 0, new ArrayList<>()));
+        } else if (pitIds.size() == 1 && "_all".equals(pitIds.get(0))) {
             pitService.getAllPits(ActionListener.wrap(response -> {
                 request.clearAndSetPitIds(response.getPitInfos().stream().map(ListPitInfo::getPitId).collect(Collectors.toList()));
                 super.doExecute(task, request, listener);
diff --git a/server/src/main/java/org/opensearch/rest/action/cat/RestPitSegmentsAction.java b/server/src/main/java/org/opensearch/rest/action/cat/RestPitSegmentsAction.java
index 49c1357e2436c..7075ea13d4f27 100644
--- a/server/src/main/java/org/opensearch/rest/action/cat/RestPitSegmentsAction.java
+++ b/server/src/main/java/org/opensearch/rest/action/cat/RestPitSegmentsAction.java
@@ -18,7 +18,6 @@
 import org.opensearch.action.admin.indices.segments.ShardSegments;
 import org.opensearch.client.node.NodeClient;
 import org.opensearch.cluster.node.DiscoveryNodes;
-import org.opensearch.common.Strings;
 import org.opensearch.common.Table;
 import org.opensearch.common.logging.DeprecationLogger;
 import org.opensearch.index.engine.Segment;
@@ -29,6 +28,7 @@
 import org.opensearch.rest.action.RestActionListener;
 import org.opensearch.rest.action.RestResponseListener;
 
+import java.io.IOException;
 import java.util.List;
 import java.util.Map;
 
@@ -45,7 +45,7 @@ public class RestPitSegmentsAction extends AbstractCatAction {
 
     @Override
     public List<RestHandler.Route> routes() {
-        return unmodifiableList(asList(new Route(GET, "/_cat/pit_segments"), new Route(GET, "/_cat/pit_segments/{pit_id}")));
+        return unmodifiableList(asList(new Route(GET, "/_cat/pit_segments/_all"), new Route(GET, "/_cat/pit_segments")));
     }
 
     @Override
@@ -60,7 +60,6 @@ public boolean allowSystemIndexAccessByDefault() {
 
     @Override
     protected BaseRestHandler.RestChannelConsumer doCatRequest(final RestRequest request, final NodeClient client) {
-        final String[] pitIds = Strings.splitStringByCommaToArray(request.param("pit_id"));
         final ClusterStateRequest clusterStateRequest = new ClusterStateRequest();
         clusterStateRequest.local(false);
         clusterStateRequest.clusterManagerNodeTimeout(
@@ -70,8 +69,23 @@ protected BaseRestHandler.RestChannelConsumer doCatRequest(final RestRequest req
         clusterStateRequest.clear().nodes(true).routingTable(true).indices("*");
         return channel -> client.admin().cluster().state(clusterStateRequest, new RestActionListener<>(channel) {
             @Override
-            public void processResponse(final ClusterStateResponse clusterStateResponse) {
-                final PitSegmentsRequest pitSegmentsRequest = new PitSegmentsRequest(pitIds);
+            public void processResponse(final ClusterStateResponse clusterStateResponse) throws IOException {
+                String allPitIdsQualifier = "_all";
+                final PitSegmentsRequest pitSegmentsRequest;
+                if (request.path().contains(allPitIdsQualifier)) {
+                    pitSegmentsRequest = new PitSegmentsRequest(allPitIdsQualifier);
+                } else {
+                    pitSegmentsRequest = new PitSegmentsRequest();
+                    request.withContentOrSourceParamParserOrNull((xContentParser -> {
+                        if (xContentParser != null) {
+                            try {
+                                pitSegmentsRequest.fromXContent(xContentParser);
+                            } catch (IOException e) {
+                                throw new IllegalArgumentException("Failed to parse request body", e);
+                            }
+                        }
+                    }));
+                }
                 client.execute(PitSegmentsAction.INSTANCE, pitSegmentsRequest, new RestResponseListener<>(channel) {
                     @Override
                     public RestResponse buildResponse(final IndicesSegmentResponse indicesSegmentResponse) throws Exception {