Commit Graph

151 Commits

Author SHA1 Message Date
chaokunyang d1dd3410c8 [Java] Format ray java code (#13056) 2020-12-29 10:36:16 +08:00
Yi Cheng 40032541dc [core] Introduce fetch_local to ray.wait (#12526) 2020-12-16 23:44:28 -08:00
Lixin Wei 867d2a8aa3 [Streaming] Add more documents. (#12746)
* add doc

draft

draft

draft

draft

draft

fix

fix

fix

fix

fix

fix

fix

Update README.md

fix

fix

fix

* md to rst

* fix

* fix

* fix

* jpg modified

* add getting envolved

* jpg modified

* Update README.rst

* fix

* fix
2020-12-11 20:36:17 +08:00
Sumanth Ratna 932837eb4c [streaming] Remove unused imports in streaming CI tests (#12722) 2020-12-10 16:27:06 -06:00
Kai Yang e3b5deb741 [Multi-tenancy] Delete flag enable_multi_tenancy and remove old code path (#10573) 2020-12-10 19:01:40 +08:00
Philipp Moritz 73a1a232b9 Ray debugger stepping between tasks (#12075) 2020-12-06 21:50:18 -08:00
Kai Yang 21fcee28f9 [Java] Simplify Ray.init() by invoking ray start internally (#10762) 2020-12-04 14:33:45 +08:00
chaokunyang bea0031491 fix linux wheel build (#9896) 2020-11-17 15:49:42 +08:00
chaokunyang 1979ea9c0a fix disable javadoc lint (#11907) 2020-11-11 13:40:50 +08:00
Kai Yang 904f48ebd9 [Core] Multi-tenancy: Pass job ID from Raylet to worker via env variable (#11829)
* Pass job ID from Raylet to worker via env variable

* fix

* fix

* fix

* lint

* fix

* fix test_object_spilling

* address comments

* lint

* fix
2020-11-09 11:02:15 -08:00
Lingxuan Zuo 2f3ec4ef75 add streaming data writer unit tests (#11387) 2020-10-16 14:42:44 +08:00
Lingxuan Zuo c84a9b457c [Streaming] add barrier helper tests (#11107) 2020-10-13 09:55:55 +08:00
chaokunyang 0737e78445 [Java] upgrade common-collections version (#10613) 2020-10-10 11:16:12 +08:00
Kai Yang 0c254878db [Java] Upgrade TestNG to 7.3.0 (#11135) 2020-09-30 14:38:52 +08:00
chaokunyang 842861b4fc [Streaming] refine streaming tests sleep condition (#10991) 2020-09-24 17:06:55 +08:00
Alex Wu 9a07c7b963 [1.0] Remove args from ray start (#10659) 2020-09-18 16:41:23 -07:00
chaokunyang 322f12600f bump java version to 1.1.0 (#10795) 2020-09-16 12:05:11 +08:00
Hao Chen 1a5cfe0b79 [Java] rename config ray.redis.address to ray.address (#10772) 2020-09-15 11:13:19 +08:00
chaokunyang 1aad8aa39c [Java] Fix java doc building error (#10757) 2020-09-14 17:44:45 +08:00
Kai Yang afa0216280 Remove the '--include-java' option (#10594) 2020-09-09 17:01:17 +08:00
chaokunyang ccf27a9ad2 [Streaming] Fix streaming ci (#10665) 2020-09-09 16:53:43 +08:00
chaokunyang a96af94e56 [Java] add developer section (#10670) 2020-09-09 15:45:49 +08:00
SangBin Cho b7040f1310 Revert "[Streaming] fix streaming ci (#9675)" (#10656)
This reverts commit 3645a05644.
2020-09-08 19:07:21 -07:00
chaokunyang 3645a05644 [Streaming] fix streaming ci (#9675) 2020-09-08 22:20:58 +08:00
Lixin Wei 2b95e71dac [Streaming] Test build fixed (#10617) 2020-09-08 14:31:54 +08:00
Lixin Wei 66e125d6e6 [Streaming] Remove useless generated protobuf directory to fix CI. (#10616) 2020-09-08 12:19:59 +08:00
kisuke95 b7003839bd [Core] Use core worker options to initialize (#10467)
* fix

* fix

* .
2020-09-07 16:36:43 -07:00
Lixin Wei f31ee84bfd [Streaming] Fault Tolerance Implementation (#10595) 2020-09-05 16:40:47 +08:00
chaokunyang 7ee0fdba3d [Java] Throw exception if Ray.init() is not called and users try to access ray API (#10497) 2020-09-05 10:09:19 +08:00
SangBin Cho cb919c5e5c Revert "[Streaming] Fault Tolerance Implementation (#10008)" (#10582)
This reverts commit 1b1466748f.
2020-09-04 13:21:18 -07:00
Lixin Wei 1b1466748f [Streaming] Fault Tolerance Implementation (#10008) 2020-09-04 20:44:34 +08:00
Clark Zinzow 0c0b0d0a73 [Core] Added support for submission-time task names. (#10449)
* Added support for submission-time task names.

* Suggestions from code review: add missing consts

Co-authored-by: SangBin Cho <rkooo567@gmail.com>

* Add num_returns arg to actor method options docstring example.

* Add process name line and proctitle assertion to submission-time task name section of advanced docs.

* Add submission-time task name --> proctitle test for Python worker.

* Added Python actor options tests for num_returns and name.

* Added Java test for submission-time task names.

* Add dashboard image to task name docs section.

* Move to fstrings.

Co-authored-by: SangBin Cho <rkooo567@gmail.com>
2020-09-03 11:45:24 -07:00
Lixin Wei d8ac4bc719 [Streaming] Remove is_direct_call param (#10525) 2020-09-03 17:13:18 +08:00
Lixin Wei 2597b56f48 [Streaming] Change ID caption (#10523) 2020-09-03 14:15:33 +08:00
Lixin Wei 2f03bb5100 Fix streaming py test for 1.0 APIs (#10520) 2020-09-03 14:15:09 +08:00
chaokunyang f10a5a40b0 [Java] Simplify ray cmd params (#10394) 2020-09-02 19:47:52 +08:00
Lixin Wei 6bde6b493e [Streaming]Format java code using IDEA (#10440) 2020-08-31 19:45:00 +08:00
Stephanie Wang f75dfd60a3 [api] API deprecations and cleanups for 1.0 (internal_config and Checkpointable actor) (#10333)
* remove

* internal config updates, remove Checkpointable

* Lower object timeout default

* remove json

* Fix flaky test

* Fix unit test
2020-08-27 10:19:53 -07:00
kisuke95 24a7a8a04d [Streaming] Build fix (#10233) 2020-08-25 11:37:21 -07:00
Ian Rodney b14c56e599 fix lint (#10315) 2020-08-25 10:07:20 -07:00
wanxing e816e3aefb [Streaming]Streaming queue support failover (#8161) 2020-08-25 14:19:45 +08:00
chaokunyang 7ffb37f711 [Java] add maven repo (#10109) 2020-08-14 11:31:01 -07:00
Barak Michener 8e76796fd0 ci: Redo format.sh --all script & backfill lint fixes (#9956) 2020-08-07 16:49:49 -07:00
SangBin Cho ec2f1a225e [Stats] Metrics Export User Interface Part 1 (#9913)
* Metrics export port expose done.

* Support exposing metrics port + metrics agent service discovery through ray.nodes()

* Formatting.

* Added a doc.

* Linting.

* Change the location of metrics agent port.

* Addressed code review.

* Addressed code review.
2020-08-06 16:16:29 -07:00
chaokunyang 64d6446cf3 change version from 0.1-SNAPSHOT to 0.9.0-SNAPSHOT (#9778) 2020-08-01 22:38:22 +08:00
Kai Yang 02fd950252 [Java] Local and distributed ref counting in Java (#9371) 2020-07-31 11:49:31 +08:00
chaokunyang 6464bf55c6 [dist] Mvn deploy (#9777) 2020-07-30 11:48:31 +08:00
chaokunyang 5aba53e9b2 [dist] Fix travis deploy for java dist (#9768) 2020-07-30 10:59:11 +08:00
SangBin Cho 423dc96cc4 Revert "[dist] swap mac/linux wheel build order (#9746)" and "Fix package and upload ray jar (#9742)" (#9758)
* Revert "[dist] swap mac/linux wheel build order (#9746)"

This reverts commit a9340565ff.

* Revert "Fix package and upload ray jar (#9742)"

This reverts commit c290c308fe.
2020-07-28 15:34:29 -07:00
chaokunyang c290c308fe Fix package and upload ray jar (#9742) 2020-07-28 11:53:25 +08:00