diff --git a/fdbclient/NativeAPI.actor.cpp b/fdbclient/NativeAPI.actor.cpp index cb1c54a9ee..dad8df6e04 100644 --- a/fdbclient/NativeAPI.actor.cpp +++ b/fdbclient/NativeAPI.actor.cpp @@ -8039,7 +8039,7 @@ ACTOR Future popChangeFeedMutationsActor(Reference db, Ke } } catch (Error& e) { if (e.code() != error_code_unknown_change_feed && e.code() != error_code_wrong_shard_server && - e.code() != error_code_all_alternatives_failed) { + e.code() != error_code_all_alternatives_failed && e.code() != error_code_broken_promise) { throw; } db->changeFeedCache.erase(rangeID);