diff --git a/metadata-integration/java/datahub-client/src/main/java/datahub/client/rest/RestEmitter.java b/metadata-integration/java/datahub-client/src/main/java/datahub/client/rest/RestEmitter.java
index 221a00bd4376f1..dbf8f58b46486f 100644
--- a/metadata-integration/java/datahub-client/src/main/java/datahub/client/rest/RestEmitter.java
+++ b/metadata-integration/java/datahub-client/src/main/java/datahub/client/rest/RestEmitter.java
@@ -198,19 +198,23 @@ public void completed(HttpResponse response) {
 
       @Override
       public void failed(Exception ex) {
-        try {
-          callback.onFailure(ex);
-        } catch (Exception e) {
-          log.error("Error executing user callback on failure.", e);
+        if (callback != null) {
+          try {
+            callback.onFailure(ex);
+          } catch (Exception e) {
+            log.error("Error executing user callback on failure.", e);
+          }
         }
       }
 
       @Override
       public void cancelled() {
-        try {
-          callback.onFailure(new RuntimeException("Cancelled"));
-        } catch (Exception e) {
-          log.error("Error executing user callback on failure due to cancellation.", e);
+        if (callback != null) {
+          try {
+            callback.onFailure(new RuntimeException("Cancelled"));
+          } catch (Exception e) {
+            log.error("Error executing user callback on failure due to cancellation.", e);
+          }
         }
       }
     };