еще пару моментов.. приложение на cartridge >= 2.1.1 из роутера и хранилища+приложение
перезапустил инстансы на обоих серверах
сделал цикл который 1000 раз кидал в роутер по 1000 одинаковых записей, которые в итоге делают upsert одних и тех же данных
api.imports.localParams.prices( 1000 х [ 'product_id' => 9787, 'location' => 999, 'type' => 1, 'price' => 10000,] )
без sleepов
дальше роутер на том же сервере, что и мастер делает
function callMaster(method, params) return defaultRouter:callrw(1, 'storage.imports.' .. method, { params }, { timeout = 1800 }) end
return callMaster('localParams.prices', 1000записей)на мастере по каждой из 1000 записей, без транзакций
local tuple = {productId,location,price, -1}
box.space.product_internet:upsert(tuple, { { '=', 3, price } })куча ошибок
SystemError unexpected EOF when reading from socket, called on fd 35, aka
10.1.1.3:3312, peer of
10.1.1.3:41312: Broken pipe
и потом
V> Got a corrupted row:
V> 00000000: 84 00 09 02 01 03 CE 0F EB 4C 8C 04 CB 41 D7 CA
V> 00000010: 58 20 2E 2D 55 84 10 CD 02 08 15 01 28 91 93 A1
V> 00000020: 3D 03 CD 27 10 21 94 CD 01 1A CD 03 E7 CE 00 00
V> 00000030: 00
I> can't read row
xrow.c:207 E> ER_INVALID_MSGPACK: Invalid MsgPack - packet body
расшифровать который я не могу
в данном случае, возможно, слишком много заливается, но в реальности там 5тысяч изменений от силы - должно же хватать и проца (загрузка небольшая) и сети (1G или 10G)