diff --git a/marklogic-client-api/src/main/java/com/marklogic/client/datamovement/filter/ContentExclusionUtil.java b/marklogic-client-api/src/main/java/com/marklogic/client/datamovement/filter/ContentExclusionUtil.java
index a2d5c4fb8..cd2ba9618 100644
--- a/marklogic-client-api/src/main/java/com/marklogic/client/datamovement/filter/ContentExclusionUtil.java
+++ b/marklogic-client-api/src/main/java/com/marklogic/client/datamovement/filter/ContentExclusionUtil.java
@@ -83,8 +83,11 @@ private static void removeNodeAtPointer(String uri, JsonNode rootNode, String js
 		JsonNode parentNode = rootNode.at(parentPointer);
 
 		if (parentNode.isObject()) {
-			String fieldName = pointer.last().getMatchingProperty();
-			((ObjectNode) parentNode).remove(fieldName);
+			JsonPointer lastSegment = pointer.last();
+			if (lastSegment != null) {
+				String fieldName = lastSegment.getMatchingProperty();
+				((ObjectNode) parentNode).remove(fieldName);
+			}
 		} else if (parentNode.isArray()) {
 			logger.warn("Array element exclusion not supported for JSONPointer '{}'. " +
 				"Consider excluding the entire array property instead.", jsonPointer);
diff --git a/marklogic-client-api/src/main/java/com/marklogic/client/datamovement/filter/IncrementalWriteFilter.java b/marklogic-client-api/src/main/java/com/marklogic/client/datamovement/filter/IncrementalWriteFilter.java
index 46dd06cd8..73f4fd5f9 100644
--- a/marklogic-client-api/src/main/java/com/marklogic/client/datamovement/filter/IncrementalWriteFilter.java
+++ b/marklogic-client-api/src/main/java/com/marklogic/client/datamovement/filter/IncrementalWriteFilter.java
@@ -152,7 +152,15 @@ protected final DocumentWriteSet filterDocuments(Context context, Function<Strin
 				continue;
 			}
 
-			final String contentHash = computeHash(serializeContent(doc));
+			final String serializedContent = serializeContent(doc);
+			if (serializedContent == null) {
+				// Not sure if the doc can have null content - possibly for a naked properties document? - but if it
+				// does, just include it in the write set.
+				newWriteSet.add(doc);
+				continue;
+			}
+
+			final String contentHash = computeHash(serializedContent);
 			final String existingHash = hashRetriever.apply(doc.getUri());
 			if (logger.isTraceEnabled()) {
 				logger.trace("URI: {}, existing Hash: {}, new Hash: {}", doc.getUri(), existingHash, contentHash);
@@ -171,7 +179,7 @@ protected final DocumentWriteSet filterDocuments(Context context, Function<Strin
 			}
 		}
 
-		if (!skippedDocuments.isEmpty()) {
+		if (!skippedDocuments.isEmpty() && skippedDocumentsConsumer != null) {
 			skippedDocumentsConsumer.accept(skippedDocuments.toArray(new DocumentWriteOperation[0]));
 		}
 
diff --git a/marklogic-client-api/src/main/java/com/marklogic/client/impl/OkHttpServices.java b/marklogic-client-api/src/main/java/com/marklogic/client/impl/OkHttpServices.java
index cd7bf9e6f..dc28aa80f 100644
--- a/marklogic-client-api/src/main/java/com/marklogic/client/impl/OkHttpServices.java
+++ b/marklogic-client-api/src/main/java/com/marklogic/client/impl/OkHttpServices.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2010-2025 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.
+ * Copyright (c) 2010-2026 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.
  */
 package com.marklogic.client.impl;
 
@@ -618,6 +618,7 @@ public Response apply(Request.Builder funcBuilder) {
 			}
 		};
 		Response response = sendRequestWithRetry(requestBldr, (transaction == null), doGetFunction, null);
+		Objects.requireNonNull(response);
 
 		int status = response.code();
 		if (status == STATUS_NOT_FOUND) {
@@ -895,6 +896,7 @@ public Response apply(Request.Builder funcBuilder) {
 			}
 		};
 		Response response = sendRequestWithRetry(requestBldr, (transaction == null), doGetFunction, null);
+		Objects.requireNonNull(response);
 		int status = response.code();
 		if (status == STATUS_NOT_FOUND) {
 			throw new ResourceNotFoundException(
@@ -1501,6 +1503,7 @@ public Response apply(Request.Builder funcBuilder) {
 			}
 		};
 		Response response = sendRequestWithRetry(requestBldr, doPostFunction, null);
+		Objects.requireNonNull(response);
 		int status = response.code();
 		if (status == STATUS_FORBIDDEN) {
 			throw new ForbiddenUserException("User is not allowed to open transactions", extractErrorFields(response));
@@ -1510,12 +1513,14 @@ public Response apply(Request.Builder funcBuilder) {
 				getReasonPhrase(response), extractErrorFields(response));
 		}
 
-		String location = response.headers().get("Location");
-		List<ClientCookie> cookies = new ArrayList<>();
+		final String location = response.headers().get("Location");
+
+		final List<ClientCookie> cookies = new ArrayList<>();
 		for (String setCookie : response.headers(HEADER_SET_COOKIE)) {
 			ClientCookie cookie = parseClientCookie(requestBldr.build().url(), setCookie);
 			cookies.add(cookie);
 		}
+
 		closeResponse(response);
 		if (location == null) throw new MarkLogicInternalException("transaction open failed to provide location");
 		if (!location.contains("/")) {
@@ -2562,6 +2567,7 @@ public Response apply(Request.Builder funcBuilder) {
 			}
 		};
 		Response response = sendRequestWithRetry(requestBldr, doGetFunction, null);
+		Objects.requireNonNull(response);
 		int status = response.code();
 		if (status == STATUS_FORBIDDEN) {
 			throw new ForbiddenUserException("User is not allowed to read "
@@ -2749,6 +2755,7 @@ public Response apply(Request.Builder funcBuilder) {
 			}
 		};
 		Response response = sendRequestWithRetry(requestBldr, doDeleteFunction, null);
+		Objects.requireNonNull(response);
 		int status = response.code();
 		if (status == STATUS_FORBIDDEN) {
 			throw new ForbiddenUserException("User is not allowed to delete "
@@ -3181,6 +3188,7 @@ public Response apply(Request.Builder funcBuilder) {
 		};
 
 		Response response = sendRequestWithRetry(requestBldr, (transaction == null), doPostFunction, resendableConsumer);
+		Objects.requireNonNull(response);
 		int status = response.code();
 		checkStatus(response, status, operation, "resource", path,
 			ResponseStatus.OK_OR_CREATED_OR_NO_CONTENT);
@@ -3712,6 +3720,7 @@ public RESTServiceResultIterator postMultipartForm(
 		Consumer<Boolean> resendableConsumer = null;
 
 		Response response = sendRequestWithRetry(requestBldr, (transaction == null), doPostFunction, resendableConsumer);
+		Objects.requireNonNull(response);
 		int status = response.code();
 		checkStatus(response, status, "apply", "resource", path, ResponseStatus.OK_OR_CREATED_OR_NO_CONTENT);
 		return makeResults(OkHttpServiceResultIterator::new, reqlog, "apply", "resource", response);
@@ -3782,6 +3791,7 @@ private <U extends OkHttpResultIterator> U postIteratedResourceImpl(
 		);
 
 		Response response = sendRequestWithRetry(requestBldr, (transaction == null), doPostFunction, resendableConsumer);
+		Objects.requireNonNull(response);
 		checkStatus(response, response.code(), "apply", "resource", path, ResponseStatus.OK_OR_CREATED_OR_NO_CONTENT);
 
 		boolean shouldStreamResults = "eval".equalsIgnoreCase(path) || "invoke".equalsIgnoreCase(path);
@@ -4820,6 +4830,7 @@ public Response apply(Request.Builder funcBuilder) {
 			}
 		};
 		Response response = sendRequestWithRetry(requestBldr, doGetFunction, null);
+		Objects.requireNonNull(response);
 		int status = response.code();
 		if (status == STATUS_FORBIDDEN) {
 			throw new ForbiddenUserException(
@@ -5040,7 +5051,8 @@ public Response apply(Request.Builder funcBuilder) {
 			}
 		};
 		Response response = sendRequestWithRetry(requestBldr, doGetFunction, null);
-		int status = response.code();
+		Objects.requireNonNull(response);
+		final int status = response.code();
 		if (status == STATUS_FORBIDDEN) {
 			throw new ForbiddenUserException("User is not allowed to match",
 				extractErrorFields(response));
@@ -5618,9 +5630,11 @@ private void executeRequest(CallResponseImpl responseImpl) {
 
 			if (session != null) {
 				List<ClientCookie> cookies = new ArrayList<>();
-				for (String setCookie : response.headers(HEADER_SET_COOKIE)) {
-					ClientCookie cookie = parseClientCookie(requestBldr.build().url(), setCookie);
-					cookies.add(cookie);
+				if (response != null) {
+					for (String setCookie : response.headers(HEADER_SET_COOKIE)) {
+						ClientCookie cookie = parseClientCookie(requestBldr.build().url(), setCookie);
+						cookies.add(cookie);
+					}
 				}
 				((SessionStateImpl) session).setCookies(cookies);
 			}