fixes

deps/rabbit/src/rabbit.erl

@@ -284,6 +284,8 @@
 %% 100 ms
 -define(BOOT_STATUS_CHECK_INTERVAL, 100).
 
+-define(COORD_WAL_MAX_SIZE_B, 64_000_000).
+
 %%----------------------------------------------------------------------------
 
 -type restart_type() :: 'permanent' | 'transient' | 'temporary'.
@@ -375,6 +377,7 @@ run_prelaunch_second_phase() ->
     Coord = Default#{name => coordination,
                      data_dir => CoordDataDir,
                      wal_data_dir => CoordDataDir,
+                     wal_max_size_bytes => ?COORD_WAL_MAX_SIZE_B,
                      names => ra_system:derive_names(coordination)},
 
     {ok, _} = ra_system:start(Quorum),

deps/rabbit/src/rabbit_stream_coordinator.erl

@@ -116,7 +116,7 @@ start() ->
     end.
 
 recover() ->
-    ra:restart_server({?MODULE, node()}).
+    ra:restart_server(?RA_SYSTEM, {?MODULE, node()}).
 
 %% new api
 

deps/rabbit/test/quorum_queue_SUITE.erl

@@ -1617,8 +1617,8 @@ cleanup_data_dir(Config) ->
 
     UId1 = proplists:get_value(ra_name(QQ), rpc:call(Server1, ra_directory, list_registered, [quorum])),
     UId2 = proplists:get_value(ra_name(QQ), rpc:call(Server2, ra_directory, list_registered, [quorum])),
-    DataDir1 = rpc:call(Server1, ra_env, server_data_dir, [UId1]),
-    DataDir2 = rpc:call(Server2, ra_env, server_data_dir, [UId2]),
+    DataDir1 = rpc:call(Server1, ra_env, server_data_dir, [quorum, UId1]),
+    DataDir2 = rpc:call(Server2, ra_env, server_data_dir, [quorum, UId2]),
     ?assert(filelib:is_dir(DataDir1)),
     ?assert(filelib:is_dir(DataDir2)),