From 9df9aa7adfc32c41df0c702ce6a9e846f8c86b61 Mon Sep 17 00:00:00 2001 From: Bart Wyatt Date: Thu, 3 May 2018 18:25:48 -0400 Subject: [PATCH] only do the watermark initialization for producers on this node --- plugins/producer_plugin/producer_plugin.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/plugins/producer_plugin/producer_plugin.cpp b/plugins/producer_plugin/producer_plugin.cpp index d83ee999d..cbc5c2e18 100644 --- a/plugins/producer_plugin/producer_plugin.cpp +++ b/plugins/producer_plugin/producer_plugin.cpp @@ -474,7 +474,8 @@ block_production_condition::block_production_condition_enum producer_plugin_impl flat_set new_producers; new_producers.reserve(new_bs->active_schedule.producers.size()); for( const auto& p: new_bs->active_schedule.producers) { - new_producers.insert(p.producer_name); + if (_producers.count(p.producer_name) > 0) + new_producers.insert(p.producer_name); } for( const auto& p: hbs->active_schedule.producers) { -- GitLab