diff --git a/src/plugins/accounting_storage/mysql/accounting_storage_mysql.c b/src/plugins/accounting_storage/mysql/accounting_storage_mysql.c index 21c64faba61f4ff36e042c80f9994898ea99523b..1b111dbe5c1b4fa4394fe8b4ca989b389b6fb784 100644 --- a/src/plugins/accounting_storage/mysql/accounting_storage_mysql.c +++ b/src/plugins/accounting_storage/mysql/accounting_storage_mysql.c @@ -4246,9 +4246,17 @@ extern List acct_storage_p_modify_clusters(mysql_conn_t *mysql_conn, error("can not open socket back to slurmctld"); } else { slurm_msg_t out_msg; + accounting_update_msg_t update; + /* We have to put this update message here so + we can tell the sender to send the correct + RPC version. + */ + memset(&update, 0, sizeof(accounting_update_msg_t)); + update.rpc_version = cluster->rpc_version; slurm_msg_t_init(&out_msg); out_msg.msg_type = ACCOUNTING_FIRST_REG; out_msg.flags = SLURM_GLOBAL_AUTH_KEY; + out_msg.data = &update; slurm_send_node_msg(fd, &out_msg); /* We probably need to add matching recv_msg function * for an arbitray fd or should these be fire