Alex Wu
a78c5d5ef2
[New scheduler] Queueing refactor ( #9491 )
...
* .
* test_args passes
* .
* test_basic.py::test_many_fractional_resources causes ray to hang
* test_basic.py::test_many_fractional_resources causes ray to hang
* .
* .
* useful
* test_many_fractional_resources fails instead of hanging now :)
* Passes test_fractional_resources
* .
* .
* Some cleanup
* git is hard
* cleanup
* .
* .
* .
* .
* .
* .
* .
* cleanup
* address reviews
* address reviews
* more refactor
* :)
* travis pls
* .
* travis pls
* .
2020-07-17 11:08:03 -07:00
Gabriele Oliaro
026c009086
Pipelining task submission to workers ( #9363 )
...
* first step of pipelining
* pipelining tests & default configs
- added pipelining unit tests in direct_task_transport_test.cc
- added an entry in ray_config_def.h, ray_config.pxi, and ray_config.pxd to configure the parameter controlling the maximum number of tasks that can be in fligh to each worker
- consolidated worker_to_lease_client_ and worker_to_lease_client_ hash maps in direct_task_transport.h into a single one called worker_to_lease_entry_
* post-review revisions
* linting, following naming/style convention
* linting
2020-07-17 10:45:13 -07:00
Stephanie Wang
b351d13940
[core] Add flag to enable object reconstruction during ray start ( #9488 )
...
* Add flag
* doc
* Fix tests
2020-07-17 10:13:14 -07:00
Alisa
f080aa6ce3
Add placement group manager and some code in core_worker ( #9120 )
...
Co-authored-by: Lingxuan Zuo <skyzlxuan@gmail.com>
2020-07-17 20:49:51 +08:00
mehrdadn
37942ea1e7
Windows cleanup ( #9508 )
...
* Remove unneeded code for Windows
* Get rid of usleep()
* Make platform_shims includes non-transitive
Co-authored-by: Mehrdad <noreply@github.com>
2020-07-17 02:08:15 -07:00
Lingxuan Zuo
3a74164289
[Stats] Fix metric exporter test ( #9376 )
2020-07-17 14:38:24 +08:00
SangBin Cho
94e94ae0c3
[Core] Fix Java detached error ( #9526 )
2020-07-16 16:39:42 -07:00
Siyuan (Ryans) Zhuang
d61d92afc7
Cleanup Plasma Store (hash utilities) ( #9524 )
2020-07-16 14:52:14 -07:00
SangBin Cho
63e052a5f3
Fix. ( #9464 )
2020-07-16 11:51:32 -05:00
SangBin Cho
2f674728a6
[GCS Actor Management] Gcs actor management broken detached actor ( #9473 )
2020-07-16 15:41:18 +08:00
mehrdadn
06ed2313e2
Fix clang-cl build ( #9494 )
...
Co-authored-by: Mehrdad <noreply@github.com>
2020-07-15 22:17:11 -07:00
chaokunyang
9318e76b81
[Java] Named java actor ( #9037 )
2020-07-16 11:31:18 +08:00
Stephanie Wang
4e81804cba
[core] Replace task resubmission in raylet with ownership protocol ( #9394 )
...
* Add intended worker ID to GetObjectStatus, tests
* Remove TaskID owner_id
* lint
* Add owner address to task args
* Make TaskArg a virtual class, remove multi args
* Set owner address for task args
* merge
* Fix tests
* Add ObjectRefs to task dependency manager, pass from task spec args
* tmp
* tmp
* Fix
* Add ownership info for task arguments
* Convert WaitForDirectActorCallArgs
* lint
* build
* update
* build
* java
* Move code
* build
* Revert "Fix Google log directory again (#9063 )"
This reverts commit 275da2e400
2020-07-15 14:55:51 -07:00
Kai Yang
005ea1e125
Add job configs to gcs ( #9374 )
2020-07-15 15:18:48 +08:00
mehrdadn
33e400998c
Fix name clash on Windows ( #9412 )
...
Co-authored-by: Mehrdad <noreply@github.com>
2020-07-14 23:14:53 -07:00
Stephanie Wang
6d99aa34a5
[core] Handle out-of-order actor table notifications ( #9449 )
...
* Drop stale actor table notifications
* build
* Add num_restarts to disconnect handler
* Unit test and increment num_restarts on ALIVE, not RESTARTING
* Wait for pid to exit
2020-07-14 22:55:04 -07:00
Zhuohan Li
003518619f
[Core] remove create_and_seal and create_and_seal_batch ( #9457 )
2020-07-14 14:37:13 -07:00
SangBin Cho
539c51a003
[Core] Support GCS server port assignment. ( #8962 )
2020-07-14 11:49:56 -05:00
SangBin Cho
f6eb47fc1f
[Stats] metrics agent exporter ( #9361 )
2020-07-14 11:49:16 -05:00
Siyuan (Ryans) Zhuang
d57ff5e2af
Remove legacy C++ code ( #9459 )
2020-07-14 00:57:42 -07:00
kisuke95
276fe109c5
change error code name of boost timer ( #9417 )
2020-07-14 11:50:58 +08:00
fangfengbin
3c90f960fb
Fix gcs_pubsub_test bug( #9438 )
...
Co-authored-by: 灵洵 <fengbin.ffb@antfin.com>
2020-07-14 11:34:50 +08:00
Siyuan (Ryans) Zhuang
4da97a7c99
[Core] Build raylet client as an independent component ( #9434 )
2020-07-13 16:00:32 -07:00
Hao Chen
e6225bdfa1
[GCS] Fix the bug about raylet receiving duplicate actor creation tasks ( #9422 )
2020-07-13 11:34:02 -07:00
Siyuan (Ryans) Zhuang
381c242f6b
[Core] Simplify Raylet Client ( #9420 )
2020-07-12 12:42:54 -07:00
Siyuan (Ryans) Zhuang
1798deae94
[Core] Plasma RAII support ( #9370 )
2020-07-10 09:22:29 -07:00
SangBin Cho
d8a0d76d02
Fix macos compliation bug ( #9391 )
...
* Fix.
2020-07-10 09:18:09 -07:00
Kai Yang
c89b59cf48
Remove the RAY_CHECK in Worker::Port() ( #9348 )
2020-07-10 18:06:25 +08:00
Kai Yang
a98cd0670e
[Java] Improve JNI performance when submitting and executing tasks ( #9032 )
2020-07-10 17:51:07 +08:00
Hao Chen
d49dadf891
Change Python's ObjectID to ObjectRef ( #9353 )
2020-07-10 17:49:04 +08:00
Tao Wang
6311e5a947
[HOTFIX] Fix compile direct_actor_transport_test on mac ( #9403 )
2020-07-10 17:19:34 +08:00
fangfengbin
35861f17a3
Fix gcs_table_storage testcase bug ( #9393 )
...
Co-authored-by: 灵洵 <fengbin.ffb@antfin.com>
2020-07-10 16:16:28 +08:00
mehrdadn
dd2cc6eb48
Update hiredis and remove Windows patches ( #9289 )
...
Co-authored-by: Mehrdad <noreply@github.com>
2020-07-09 18:45:44 -07:00
Zhuohan Li
8a76f4cbb5
[Core] put small objects in memory store ( #8972 )
...
* remove the put in memory store
* put small objects directly in memory store
* cast data type
* fix another place that uses Put to spill to plasma store
* fix multiple tests related to memory limits
* partially fix test_metrics
* remove not functioning codes
* fix core_worker_test
* refactor put to plasma codes
* add a flag for the new feature
* add flag to more places
* do a warmup round for the plasma store
* lint
* lint again
* fix warmup store
* Update _raylet.pyx
Co-authored-by: Eric Liang <ekhliang@gmail.com>
2020-07-09 15:39:40 -07:00
Alex Wu
34b85659d4
[Core] New scheduler fixes ( #9186 )
...
* .
* test_args passes
* .
* test_basic.py::test_many_fractional_resources causes ray to hang
* test_basic.py::test_many_fractional_resources causes ray to hang
* .
* .
* useful
* test_many_fractional_resources fails instead of hanging now :)
* Passes test_fractional_resources
* .
* .
* Some cleanup
* git is hard
* cleanup
* Fixed scheduling tests
* .
* .
2020-07-09 15:37:51 -07:00
Alisa
f0a72ad985
[Core] Add placement group scheduler and some api in resource scheduler ( #9039 )
...
* Add placement group scheduler and some api of resource scheduler.
Merge fix cv hang in multithread variables race (#8984 ).
* change the bundle id and delete unit count in bundle
change vector<bundle_spec> to vector<shared_ptr<bundle_spec>>
Add placement group scheduler and some api of resource scheduler.
Merge fix cv hang in multithread variables race (#8984 ).
change the bundle id and delete unit count in bundle
remove CheckIfSchedulable()
add comments and fix the bug in resource
* fix placement group schedule
* add placement group scheduler and change some api in resource scheduler
* fix by the comments
* fix conflict
* fix lint
* fix lint
* fix bug in merge
* fix lint
Co-authored-by: Lingxuan Zuo <skyzlxuan@gmail.com>
2020-07-09 15:37:18 -07:00
Stephanie Wang
0389735d7a
[core] Pass owner address from the workers to the raylet ( #9299 )
...
* Add intended worker ID to GetObjectStatus, tests
* Remove TaskID owner_id
* lint
* Add owner address to task args
* Make TaskArg a virtual class, remove multi args
* Set owner address for task args
* merge
* Fix tests
* Add ObjectRefs to task dependency manager, pass from task spec args
* tmp
* tmp
* Fix
* Add ownership info for task arguments
* Convert WaitForDirectActorCallArgs
* lint
* build
* update
* build
* java
* Move code
* build
* Revert "Fix Google log directory again (#9063 )"
This reverts commit 275da2e400
2020-07-09 14:35:54 -07:00
mehrdadn
4687b807c4
Combine different severities into the same log files ( #9230 )
...
* Combine different severities into the same log files
Co-authored-by: Mehrdad <noreply@github.com>
2020-07-09 14:14:28 -07:00
Siyuan (Ryans) Zhuang
7e1326c0f6
[Core] Enhance common client connection ( #9367 )
...
* enhance client connection
* add write buffer async
* read message
* add test
2020-07-09 08:59:37 -07:00
fangfengbin
b97b474ae9
Fix GcsActorManagerTest multi-thread bug ( #9358 )
2020-07-09 20:03:46 +08:00
fangfengbin
62fe403a57
Fix the bug that PollOwnerForActorOutOfScope's reply may be missing ( #9330 )
2020-07-09 17:33:52 +08:00
Lingxuan Zuo
0562236533
[Stats] Make aggeration window and report interval configurable. ( #9235 )
2020-07-09 12:44:38 +08:00
SangBin Cho
9f8ff2e3b1
[Core] GCS Actor Management Race Condition ( #9215 )
...
* GCS Actor management on by default.
* Fix travis config.
* Change condition.
* Finish the initial race condition fix.
* Lint.
* Refine the codebase.
* Finish the initial version
* Improve logic.
* Remove unnecessary log messages.
* Address code review.
* Add tests
* Revert the second race condition that doesn't happen anymore, handle some edge cases. add tests.
* Address the second race condition found.
* Addressed code review.
* Addressed code review.
* Run a new unit test only when gcs actor management is on.
2020-07-08 10:56:52 -07:00
SangBin Cho
c5aa1eb042
[GCS Actor Management] Fix a dashboard doesn't show the correct actor state. ( #9275 )
...
* Fix a bug.
* Address code review.
* Remove an unnecessary comment.
2020-07-08 10:55:47 -07:00
Ian Rodney
9172f8c3a6
[core] Store Internal Config in GCS ( #8921 )
2020-07-08 11:22:08 -05:00
ZhuSenlin
42f8f16c04
[GCS] Fix detached actor with empty name ( #9283 )
2020-07-08 12:21:24 +08:00
yncxcw
4ba4110dec
[Core] Make worker_register_timeout_seconds configurable ( #9221 )
2020-07-07 18:27:15 -05:00
SangBin Cho
8f19f1eafb
[Core] Actor handle refactoring ( #8895 )
...
* Marking needed changes.
* Resolve basic dependencies.
* In progress.
* linting.
* In progress 2.
* Linting.
* Refactor done. Cleanup needed.
* Linting.
* Recover kill actor in core worker because it is used inside raylet
* Cleanup.
* Use unique pointer instead. Unit tests are broken now.
* Fix the upstream change.
* Addressed code review 1.
* Lint.
* Addressed code review 2.
* Fix weird github history.
* Lint.
* Linting using clang 7.0.
* Use a better check message.
* Revert cpp stuff.
* Fix weird linting errors.
* Manuall fix all lint issues.
* Update a newline.
* Refactor some interface.
* Addressed all code review.
* Addressed code review
2020-07-07 11:11:41 -07:00
Ian Rodney
a1e14380ce
[core] Switch Async Callback to C++ [WIP] ( #9228 )
...
Co-authored-by: simon-mo <simon.mo@hey.com>
2020-07-07 09:47:25 -07:00
fangfengbin
8391f66086
Fix gcs actor manager destroy actor crash bug ( #9329 )
2020-07-07 21:12:30 +08:00
