687de41273
[GCS] refactor the GCS Client Node Interface ( #6010 )
2019-12-24 20:36:37 +08:00
6b1a57542e
Add actor.__ray_kill__() to terminate actors immediately ( #6523 )
2019-12-23 23:12:57 -06:00
84d3d4b67b
[GCS]refactor the GCS Client Task Interface ( #6556 )
2019-12-23 17:54:21 +08:00
bac6f3b61e
[Dashboard] Collecting worker stats in node manager and implement webui display in the backend ( #6574 )
2019-12-22 17:50:23 -08:00
7bbfa85c66
[Streaming] Streaming data transfer java ( #6474 )
2019-12-22 10:56:05 +08:00
932cb3c297
check connected ( #6565 )
2019-12-20 22:04:25 -07:00
e50aa99be1
Reference counting for direct call submitted tasks ( #6514 )
...
Co-authored-by: Zhijun Fu <37800433+zhijunfu@users.noreply.github.com >
2019-12-20 17:06:33 -08:00
b0b6b56bb7
Platform shims for Windows ( #6548 )
...
* Platform shims for Windows
* Satisfy linter
2019-12-20 12:32:07 -08:00
3c0164419b
Add gcs server job info & actor info handler ( #6469 )
2019-12-20 14:28:04 +08:00
e556b729c2
[direct call] Fix max_calls interaction with background tasks. ( #6536 )
2019-12-19 13:48:32 -08:00
41fa2e9604
Remove object id translation ( #6531 )
2019-12-19 12:47:49 -08:00
634b437543
Work around some compile errors for boost::asio::generic::stream_protocol ( #6545 )
2019-12-19 12:05:41 -08:00
7e2addb424
Revert "[GCS] refactor the GCS Client Task Interface ( #5515 )" ( #6543 )
...
This reverts commit f78583147c
2019-12-19 17:11:36 +08:00
f78583147c
[GCS] refactor the GCS Client Task Interface ( #5515 )
2019-12-19 15:02:21 +08:00
012c0ca7dc
Fix some missing header files ( #6527 )
2019-12-18 16:54:51 -08:00
c507859a83
[Dashboard] Node resource display fix ( #6521 )
2019-12-18 12:07:37 -08:00
26ec500ef9
Implement async get for direct actor call ( #6339 )
2019-12-18 11:50:21 -08:00
978d72be0a
Disable port sharing in grpc server ( #6479 )
2019-12-18 14:48:54 +08:00
166560e428
[Dashboard] displays resources row ( #6516 )
2019-12-17 01:05:57 -08:00
1a1324d2a2
Bump version from 0.8.0.dev6 -> 0.9.0.dev ( #6508 )
2019-12-16 23:57:42 -08:00
38b43fb3ca
Optimize O(n^2) behavior in dependency resolver ( #6509 )
...
* Optimize O(n^2) behavior in dependency resolver
* fix check
* checks
2019-12-16 18:41:02 -08:00
74b2e871b7
Tentative workaround for some forks and signals on Windows ( #6362 )
...
* Platform shims for Windows
* Tentative workaround for some forks and signals on Windows
* Rewrite WorkerPool::StartProcess by moving spawnvp wrapper to a separate function
* Separate spawnvp the wrappers for POSIX and Windows
* Fix rv use
2019-12-16 16:57:49 -08:00
c3ef8581d2
[Java] fix UT segmentation fault on exit ( #6455 )
...
* fix segmentation fault in Java test
* update comments
* address comments
2019-12-15 17:52:34 +08:00
9cc0ecc6ff
Fix duplicated logging if log dir is not set ( #6342 )
2019-12-15 13:29:36 +08:00
6c0531683f
Add gcs server as well as the unit test ( #6401 )
2019-12-15 13:23:42 +08:00
e2b7459bfc
Fix worker exit cleanup ( #6450 )
...
* working but ugly
* comments
* proper but hanging in grpc server destructor
* grpc server shutdown deadline
* fix disconnect
* lint
* shutdown_only in test
* replace shutdown
2019-12-13 16:52:50 -08:00
335dade1e6
Check worker id for all core worker RPCs ( #6472 )
...
* check worker id
* fix test
* owner
* fix tests
* comments
2019-12-13 10:15:56 -08:00
eb6f3f86e5
Seed using multiple samples ( #6471 )
2019-12-12 21:41:19 -08:00
c57dcc82d1
Port actor creation to use direct calls ( #6375 )
2019-12-12 19:50:51 -08:00
5a5c94939f
[direct call] Retry failed tasks with delay ( #6453 )
...
* retry failed tasks with delay
* set to 0 for direct tests
2019-12-12 17:12:38 -08:00
3adbe29450
fix core worker test hanging due to heartbeat is not working ( #6416 )
2019-12-12 18:16:28 +08:00
8c1520d18e
[GCS] refactor the GCS Client Job Interface ( #5503 )
2019-12-12 16:57:32 +08:00
64d8626d6d
Optimize ray::LocalMemoryBuffer performance ( #6384 )
2019-12-11 21:49:52 -08:00
58ac8639b9
Fix bad checks and race condition from actor_deaths and node_failures tests ( #6411 )
2019-12-11 14:47:24 -08:00
82f7dbc7a7
Increase TaskID size by 2 bytes, taken from JobID ( #6425 )
...
* Increase TaskID size by 2 bytes, taken from JobID
* comments
* check max job id
* fix doc
* fix local mode
2019-12-11 10:45:14 -08:00
a131082767
fix startup worker process count for multi-threading ( #6382 )
2019-12-11 20:19:49 +08:00
044527adb8
Remove ref counting dependencies on ray.get() ( #6412 )
...
* Remove ref counting dependencies on Get()
* comment
* don't send IDs when disabled
* pass through internal config
* fix
* allow reinit
* remove flag
2019-12-10 18:11:34 -08:00
2f19b01898
Factor out stream protocols for Windows ( #6408 )
2019-12-10 15:23:30 -08:00
6272907a57
[Streaming] Streaming data transfer and python integration ( #6185 )
2019-12-10 20:33:24 +08:00
c1d4ab8bb4
Move top level RayletClient to ray::raylet::RayletClient ( #6404 )
2019-12-09 21:08:59 -08:00
a6bc2b1842
Misc direct call fixes from unit tests ( #6394 )
2019-12-08 19:34:02 -08:00
eb912b68b1
[Java] Fix instanceof RayPyActor ( #6377 )
2019-12-07 16:28:29 +08:00
7e9fddf3ed
[Java] Add java exception check in JNI ( #6378 )
2019-12-07 16:25:17 +08:00
2003d2d952
explicit delete local reference in task_execution_callback for garbage collection ( #6379 )
2019-12-06 18:53:24 +08:00
b88b8202cc
fix java build failure ( #6062 )
2019-12-06 14:38:43 +08:00
1c638a11a7
Refactor helper methods for new scheduler integration ( #6354 )
2019-12-05 18:49:25 -08:00
f63b64310a
Bump version to 0.8.0.dev7 ( #6303 )
2019-12-05 18:33:54 -08:00
6223d2ed0b
[direct call] Assign resource ids for direct call tasks ( #6364 )
2019-12-05 10:16:04 -08:00
668ce47360
[GCS]Add abstract interface of actor to GCS Client ( #6269 )
2019-12-05 13:38:29 +08:00
7611e484ec
properly handle a forwarded task that gets forwarded back ( #6271 )
2019-12-05 13:37:52 +08:00
micafan