stefanluptak

stefanluptak

Hi there!

When I am trying to build my Commanded aggregate from events, it crashes my Render.com instance saying Out of memory (used over 2Gi).

I am building the aggregate from 100_000 events. That’s a lot, but nothing enormous I hope.
Every event returns something between 150-200 when executing :erts_debug.size(event).
The final (built) aggregate returns around 1_400_000 when calling :erts_debug.size(aggregate). It starts almost from zero and each event increases its size a bit.

EventStore is backed by PostgreSQL and the event data is stored as jsonb.

On my MacBook with this configuration it takes around 20 seconds.

Operating System: macOS
CPU Information: Intel(R) Core(TM) i5-7360U CPU @ 2.30GHz
Number of Available Cores: 4
Available memory: 16 GB
Elixir 1.10.2
Erlang 22.2.8

That seems reasonable, considering the number of events. I am just surprised, that this could consume so much memory. I though that the garbage collector is somehow getting rid of the already consumed events and already discarded versions of aggregate. Isn’t that the case?

This is the part responsible for building the aggregate. I assume it’s correct, I link it here just in case.

I am really curious to know why it is so memory hungry and what exactly is causing this. Any tips how to profile this? Or is it event worth it if that memory consumption is just a fact I have to deal with?

EDIT: Benchee says it consumes around 13GB when benchmarking with parameter memory_time: 10.

Thanks a lot.

Showing Posts 1 to 2

bottlenecked

bottlenecked

Hi there, this reminds me of what can happen when a routing process handles large amounts of messages with reference counted strings in them (>64B) but makes very few (if any) allocations on its own. A strategy to deal with such problems is to force garbage collection every n number of messages, so that the references are removed and the strings can be gc’ed.

So… what if you fetched the events in batches, and forced a gc on the process that does the aggregation before moving on with the next batch? I’m not sure how easy is this to do with commanded, but perhaps it’s worth a try.

stefanluptak

stefanluptak OP

OK, I did some benchmarking and created a PR which should drasticaly improve the consumption. There are more details in its description here
I am really curious why the big difference in the memory consumption.
Any ideas someone?

— All posts loaded —

Where Next? Top

Trending in Questions Top

Blokh
Hey guys, I’ve got a huge CSV ( around 10 GB ) that needs to be processed hourly Do you guys have any suggestions what is the best prac...
New
kszambelanczyk
Hello! Could someone please give me a help/sample code, how to delete a file from s3 using waffle/waffle_ecto from Phoenix app. I creat...
New
RemyXRenard
I’m seeing that a list inside a Kino.DataTable will be interpreted as a charlist, even if the Kino.configure() is set to charlists: :as_l...
New
velrest
So my question is quite simple and i have found no conclusive answer on forum, google or AI. Should we use :erlang.float for Integer to ...
New
samoloth
Hi, I’ve just set up an application with ash_authentication. There is only magic link strategy for now, so there is no confirmation add o...
New
FlyingNoodle
If a change or preparation module uses Ash.Changeset.get_argument/2 or Ash.Query.get_argument/2 (or any of the other get_argument functio...
New
psy-q
I’m trying to set up Emacs with elixir-ls via lsp-mode and credo via Flycheck. This should mostly be preconfigured as Flycheck picks up c...
New

Other Trending Topics Top

mudasobwa
I am happy to introduce the very α version of the new programming language compiled to BEAM. Welcome Cure. It has literally three kille...
New
garrison
Hobbes is a low-level distributed database for the Elixir programming language. Hobbes provides a simple, safe, and scalable storage lay...
New
marciok
Hi there! We created Gust: A task orchestrator inspired by Airflow. For those who have never heard about Aiflow, it’s a Python-based wor...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
mcass19
ExRatatui lets you cook up rich terminal UIs in Elixir, powered by Rust’s ratatui via Rustler NIFs. Build interactive terminal applicatio...
New
Damirados
Hello everyone. After busy few months I am happy to announce v0.1.0 of Emerge & Solve. They are GUI (Emerge) and State management (S...
New

We're in Beta

About us Mission Statement

Options

Thread Display Mode




Thread Preview

Skip Thread Previews