Add partition key to PersistedState , when mapper return null update statement , end the commiting without update anything.