alibaba/GraphScope

[BUG] Loading from large dataframe/large numpy requires holding all chunks in coordinator

Open

#2,342 opened on Dec 23, 2022

View on GitHub
 (0 comments) (1 reaction) (0 assignees)HTML (301 forks)batch import
bugcomponent:coordinatorgood first issue

Repository metrics

Stars
 (2,401 stars)
PR merge metrics
 (Avg merge 1m) (7 merged PRs in 30d)

Description

Describe the bug

It looks strange that we need to accumulate all chunks in the request stream into a list in coordinator before sending to analytical engine, that would requires large available memory for the coordinator pod.

https://github.com/alibaba/GraphScope/blob/b80a35599424580325a750e734f8a3b2dead2a5b/coordinator/gscoordinator/dag_manager.py#L77-L107

Contributor guide

Research direction
Investigate the coordinator's request stream handling in dag manager.py and explore options to stream chunks directly to the analytical engine without accumulating them in memory.
Tech stack
python
Domain
backend
Issue type
Bug
DifficultyEstimated implementation difficulty for a new contributor, from 1 for very small changes to 5 for expert-level work.
3
Estimated timeA rough time range for an experienced contributor to investigate, implement, test, and prepare a pull request.
1-3 hours
Activity statusHow available the issue appears right now: fresh, active, stale, blocked, or waiting on maintainer input.
Fresh
ClarityHow clearly the issue explains the expected change, acceptance criteria, and next step.
Mostly clear
Prerequisites
PythonDistributed systems
Newbie friendlinessA 1-100 score estimating how approachable this issue is for first-time contributors.
40