These 7 commits are when the Protocol Buffers files have changed:
| Commit: | 78bad38 | |
|---|---|---|
| Author: | Lingxuan Zuo | |
| Committer: | GitHub | |
compatiable for ray lastest 2.9.3 version (#60) * compatiable for ray lastest 2.9.3 version * build in temp ray branch with internal symbol in * upgrade testng version to skip security * use bazel 5.4.1 for building * deb bazel package name fix * fix unused set variables * use aliyun mirror source list * use bazel tools new jdk deps * streaming java api reference upgrade 1.x to 2.9.3 * rename default resource from MEM to memory * use internal exported taykey symbol * no more for unseal ray pack * python config parse fix * update function descriptor and use master commit linking to ray * fix stats report unittest in streaming * fix cpp event service test namespace abm
The documentation is generated from this commit.
| Commit: | b3aa39e | |
|---|---|---|
| Author: | NKcqx | |
| Committer: | GitHub | |
Replace scheduler (#55) * stash * deve * fix package name & imports for configs and utils * add more files for ExecutionGraph * more for CheckpointCoordinator * add AbstractStreamOperator & update relevant codes * add more files for JobGraphOptimizer * add more files for JobGraphBuilder * add more files for Processor * add more files for ExecutionVertex * update all kinds of 'state' & 'store' & 'backend' * rm memory manager for state * rm unneccessary TypeSerializer for state * rm old strategy & fix some checkstyle * add UT * some for metric & config * replace fury serialize * replace state * update protobuf messages * resolve submit job & PG & Bundle * complete state, sync to ray-state * rm state's Row(kepler) * pass state compile * pass api compile * pass all compile * pass all state UT * pass some api UT * update doc & comment, rm ant fields * pass runtime UT compile * fix dependency conflicts * fix dependency conflicts * spotless apply * spotless apply * lint codes * spotless apply * spotless apply * add bazel dep * wrap modules with profiles tag * rm BUILD runtime dep.. * clean maven deps * change import path of ray-runtime * lint * change import path of ray * fix pom fst version duplicate declaration * fix workflow: mvn clean before setup * rm duplicate <modules> * mv deps declared in pom_template to BUILD * mvn clean package before spotless * fix cicd * fix fst version * add bazel dep * fix indirect bazel deps * add kryo deps for state * add org_objenesis_objenesis to state module * add bazel dep to streaming-api * add log4j bazel dep * rm fastjson, rm log4j * rm log4j2 * rm shade_rule to temporaly avoid 'duplicate jar entry' * spotless apply * restrict protobuf version <4 * rename statebackend config key name * fix jobconfig NPE bug * build execution edeg * change guava import source * simplify fst deps（use ray's version） * Revert "simplify fst deps（use ray's version）" This reverts commit 4039ff68d0bc835198e3fe33eeef0da8f6411f49. * use commit ray version as runtime test deps * transfer ray import from bazel to pom_template to add 'provided' scope * replace ray import path * revert shade rule * fix ci * fix ci * fix ci * remove unused code * add deps for api * add deps for runtime * retry ray 1.12.0 * remove all the input ray deps * refactor deps * refactor deps * set ray api and runtime compile-only * merge env util * lint * skip cluster test for now * skip java test for code merging Co-authored-by: chentianyi.cty@antfin.com <chentianyi.cty@antfin.com>
| Commit: | 1eb2818 | |
|---|---|---|
| Author: | NKcqx | |
update protobuf messages
| Commit: | e210963 | |
|---|---|---|
| Author: | Tianyi Chen | |
| Committer: | GitHub | |
Add format script (#31) * add format.sh and format code * format shell * format code * rm unused files * rm unused files * add bazel formatting
| Commit: | 92afce5 | |
|---|---|---|
| Author: | Lingxuan Zuo | |
| Committer: | GitHub | |
[FlowControl]Flowcontrol on empty messages (#15) * Flowcontrol on empty messages * mock queue empty message flow control * Update streaming/src/channel/channel.h Co-authored-by: Qing Wang <kingchin1218@126.com> * convert -1 to uint64_t max * timer interval init Co-authored-by: ashione <lingxuan.zlx@antgroup.com> Co-authored-by: Qing Wang <kingchin1218@126.com>
| Commit: | d6008ad | |
|---|---|---|
| Author: | Lingxuan Zuo | |
| Committer: | GitHub | |
[Streaming]Online-learning : streaming source codes transporting (#3) * Online-learning : streaming source codes transporting * make streaming cpp compiling successfully Co-authored-by: lingxuan.zlx <lingxuzn.zlx@antgroup.com>
| Commit: | f5a2abe | |
|---|---|---|
| Author: | alexbao | |
| Committer: | GitHub | |
initial commit for e2e pipeline demo (#1) Co-authored-by: alex.bao <alex.bao@antfin.com>