You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
AsyncShardFetch Revamp strategy (explained here ) uses ShardId object directly in the key to store metadata of all the shards received from all the nodes. So overall memory usage goes in the factor of
ShardId object size * shard_count * node_count = this goes in GBs as ShardId object contains more data.
Related component
Cluster Manager
To Reproduce
Use the latest code of this project
spin up a new cluster with 500 nodes and 500K shards
Restart all cluster manager nodes at once
We'll see heap getting full, can go up to 50GB
Expected behavior
We should reduce the key size and not use full object, ideally use smaller sized key to reduce overall heap usage.
Additional Details
Screenshots
heap dump collected from a cluster where batch size is 4000 and one batch is taking more than 500MBs.
The text was updated successfully, but these errors were encountered:
Describe the bug
AsyncShardFetch Revamp strategy (explained here ) uses ShardId object directly in the key to store metadata of all the shards received from all the nodes. So overall memory usage goes in the factor of
ShardId object size * shard_count * node_count = this goes in GBs as ShardId object contains more data.
Related component
Cluster Manager
To Reproduce
Expected behavior
We should reduce the key size and not use full object, ideally use smaller sized key to reduce overall heap usage.
Additional Details
Screenshots
heap dump collected from a cluster where batch size is 4000 and one batch is taking more than 500MBs.
The text was updated successfully, but these errors were encountered: