diff --git a/node/src/main/kotlin/net/corda/node/services/vault/NodeVaultService.kt b/node/src/main/kotlin/net/corda/node/services/vault/NodeVaultService.kt
index cca094eb34..26b20544f6 100644
--- a/node/src/main/kotlin/net/corda/node/services/vault/NodeVaultService.kt
+++ b/node/src/main/kotlin/net/corda/node/services/vault/NodeVaultService.kt
@@ -231,7 +231,7 @@ class NodeVaultService(
                     if (stateStatus != Vault.StateStatus.CONSUMED) {
                         stateStatus = Vault.StateStatus.CONSUMED
                         consumedTime = clock.instant()
-                        consumingTxId = update.consumingTxIds[stateRef]?.toString() ?: ""
+                        consumingTxId = update.consumingTxIds[stateRef]?.toString()
                         // remove lock (if held)
                         if (lockId != null) {
                             lockId = null
diff --git a/node/src/main/kotlin/net/corda/node/services/vault/VaultSchema.kt b/node/src/main/kotlin/net/corda/node/services/vault/VaultSchema.kt
index fc7fc9f9db..ee59ee170f 100644
--- a/node/src/main/kotlin/net/corda/node/services/vault/VaultSchema.kt
+++ b/node/src/main/kotlin/net/corda/node/services/vault/VaultSchema.kt
@@ -94,8 +94,8 @@ object VaultSchemaV1 : MappedSchema(
             var constraintData: ByteArray? = null,
 
             /** consuming transaction */
-            @Column(name = "consuming_tx_id", length = 144, nullable = false)
-            var consumingTxId: String = ""
+            @Column(name = "consuming_tx_id", length = 144, nullable = true)
+            var consumingTxId: String? = null
     ) : PersistentState()
 
     @Entity
diff --git a/node/src/main/resources/migration/vault-schema.changelog-v14.xml b/node/src/main/resources/migration/vault-schema.changelog-v14.xml
new file mode 100644
index 0000000000..75f576f214
--- /dev/null
+++ b/node/src/main/resources/migration/vault-schema.changelog-v14.xml
@@ -0,0 +1,15 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                   xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-3.5.xsd">
+    <changeSet author="R3.Corda" id="add_consuming_tx_id_column">
+        <preConditions onFail="MARK_RAN">
+            <not>
+                <columnExists tableName="vault_states" columnName="consuming_tx_id"/>
+            </not>
+        </preConditions>
+        <addColumn tableName="vault_states">
+            <column name="consuming_tx_id" type="NVARCHAR(144)"/>
+        </addColumn>
+    </changeSet>
+</databaseChangeLog>
\ No newline at end of file