diff --git a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/LockManager.java b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/LockManager.java
index 1d47c0b..aeb54b5 100644
--- a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/LockManager.java
+++ b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/locking/LockManager.java
@@ -207,7 +207,7 @@
             if (isEscalated) {
                 releaseDatasetISLocks(jobInfo, jobId, datasetId, txnContext);
             }
-            if (datasetLockMode == LockMode.IS) {
+            if (jobInfo != null && datasetLockMode == LockMode.IS) {
                 jobInfo.increaseDatasetISLockCount(dId);
             }
         }
@@ -1086,7 +1086,7 @@
             if (isEscalated) {
                 releaseDatasetISLocks(jobInfo, jobId, datasetId, txnContext);
             }
-            if (datasetLockMode == LockMode.IS) {
+            if (jobInfo != null && datasetLockMode == LockMode.IS) {
                 jobInfo.increaseDatasetISLockCount(dId);
             }
         }