Fix aggregator error no connection data loaded for child connection if more than one plugin instance is in use. Closes #3899 (#3898)

* Update PopulateChildren.PopulateChildren to take plugin instance into account
* Fix GetNewConnectionStateFromConnectionInsertSql to use connection names not map of connections
This commit is contained in:
kaidaguerre
2023-09-25 17:14:01 +01:00
committed by GitHub
parent 69dfe5be5c
commit 49d58d4f52
5 changed files with 28 additions and 14 deletions

View File

@@ -149,7 +149,7 @@ func (m *PluginManager) Get(req *pb.GetRequest) (_ *pb.GetResponse, err error) {
reattach, err := m.ensurePlugin(pluginInstance, connectionConfigs, req)
if err != nil {
log.Printf("[WARN] PluginManager Get failed for %s: %s (%p)", pluginInstance, err.Error(), resp)
resp.FailureMap[pluginInstance] = sperr.WrapWithMessage(err, "failed to start '%s'", pluginInstance).Error()
resp.FailureMap[pluginInstance] = sperr.WrapWithMessage(err, "failed to start plugin instance '%s'", pluginInstance).Error()
} else {
log.Printf("[TRACE] PluginManager Get succeeded for %s, pid %d (%p)", pluginInstance, reattach.Pid, resp)