These 81 commits are when the Protocol Buffers files have changed:
| Commit: | 3f04ad3 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
Update Project Copyright Header (#737) * Update rat plugin config * Update copyright header
The documentation is generated from this commit.
| Commit: | 1ff8eff | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
Add checkstyle and spotless (#718) * Add check style rules * Add spotless plugin * Apply spotless * Fix style of dl-on-flink-framework * Fix style of dl-on-flink-operator * Fix style of dl-on-flink-tensorflow-common * Fix style of dl-on-flink-tensorflow * Fix style of dl-on-flink-tensorflow-2.x * Fix style of dl-on-flink-pytorch * Fix style of dl-on-flink-lib * Fix style of dl-on-flink-example
| Commit: | 0525829 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | sxnan | |
Rename modules from flink-ml-* to dl-on-flink-* (#702) * Update module name in pom * Update usage of flink-ml-* to dl-on-flink-* * Rename directory * Update python package name * Update python package directory * Fix test (cherry picked from commit c43fa8185a647d0ee8768678a341865bb79fcfee)
| Commit: | c43fa81 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
Rename modules from flink-ml-* to dl-on-flink-* (#702) * Update module name in pom * Update usage of flink-ml-* to dl-on-flink-* * Rename directory * Update python package name * Update python package directory * Fix test
| Commit: | 60646aa | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
Add license check and update license notice (#691) * Add license check * Update license
| Commit: | 7d4f561 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
Cleanup the repo after removing ai-flow (#668) * Update group id to org.flinkextended * move deep learning on flink to root
| Commit: | 11d8be7 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
Move AIFlow to flink-extended/aiflow (#656) * [AIFlow] Move AIFlow * [AIFlow] Remove AIFlow workflow * Update README.md
| Commit: | 9b1c302 | |
|---|---|---|
| Author: | bgeng777 | |
| Committer: | GitHub | |
[Notification Service] Add close and is_exist check method for notification client (#559) - Add close() method for notification clients and add corresponding rpc/db_storage methods. - Add is_client_exists() method in notification service. - Add tests.
| Commit: | ecaaf74 | |
|---|---|---|
| Author: | bgeng777 | |
| Committer: | GitHub | |
[Notification Service] Add close and is_exist check method for notification client (#559) - Add close() method for notification clients and add corresponding rpc/db_storage methods. - Add is_client_exists() method in notification service. - Add tests.
| Commit: | 6d094db | |
|---|---|---|
| Author: | jiangxin | |
| Committer: | JiangXin | |
[Flink AI Flow] Notification service support idempotence
| Commit: | a69c017 | |
|---|---|---|
| Author: | jiangxin | |
| Committer: | JiangXin | |
[Flink AI Flow] Notification service support idempotence
| Commit: | 285e5ef | |
|---|---|---|
| Author: | bgeng777 | |
| Committer: | GitHub | |
[Notification Service] Add registration method of notification client to support idempotent `send_event` (#551) - GRPC: Add ClientMeta in proto and registration rpc and regenerate grpc files. - DB: Add notification client table to sqlalchemy and mongodb. - Tests: Add unit tests.
| Commit: | f66bd59 | |
|---|---|---|
| Author: | bgeng777 | |
| Committer: | GitHub | |
[Notification Service] Add registration method of notification client to support idempotent `send_event` (#551) - GRPC: Add ClientMeta in proto and registration rpc and regenerate grpc files. - DB: Add notification client table to sqlalchemy and mongodb. - Tests: Add unit tests.
| Commit: | 88eef3f | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
[AIFlow] Support job execution label (#529) - AIFlowOperator update execution label periodically - AIFlow support get job execution with execution label
| Commit: | 65207d7 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
[AIFlow] Support job execution label (#529) - AIFlowOperator update execution label periodically - AIFlow support get job execution with execution label
| Commit: | 2e6f18e | |
|---|---|---|
| Author: | SteNicholas | |
| Committer: | SteNicholas | |
introduce the workflow frontend of the AIFlow UI
| Commit: | 5ee79b4 | |
|---|---|---|
| Author: | SteNicholas | |
| Committer: | SteNicholas | |
introduce the workflow frontend of the AIFlow UI
| Commit: | 5d36083 | |
|---|---|---|
| Author: | bgeng777 | |
| Committer: | GitHub | |
[Flink AI Flow] Fix update workflow() to update ContextExtractor (#493) - Add a bytes field in flink-ai-flow/ai_flow/protobuf/proto/metadata_service.proto to save context_extractor_in_bytes - Update client and service methods to transfer the context_extractor_in_bytes and save context_extractor_in_bytes to DB - Update the test - Add shell script to add licenses for generated codes of grpc.
| Commit: | a2be461 | |
|---|---|---|
| Author: | bgeng777 | |
| Committer: | GitHub | |
[Flink AI Flow] Fix update workflow() to update ContextExtractor (#493) - Add a bytes field in flink-ai-flow/ai_flow/protobuf/proto/metadata_service.proto to save context_extractor_in_bytes - Update client and service methods to transfer the context_extractor_in_bytes and save context_extractor_in_bytes to DB - Update the test - Add shell script to add licenses for generated codes of grpc.
| Commit: | ddae3df | |
|---|---|---|
| Author: | bgeng777 | |
| Committer: | GitHub | |
[Flink AI Flow] Add Serde of ContextExtractor to persist it in aiflow database with Workflow (#485) Add Serde of ContextExtractor to persist it in aiflow database with Workflow - Use cloudpickle to do serde of ContextExtractor instance. - Add a new field in WorkflowMeta in `message.proto`: `context_extractor_in_bytes`, whose type is `bytes`. It stores the serialized bytes of ContextExtractor instance. - Modify the metadata service to adapt to the CRUD of `context_extractor_in_bytes` field. - Add tests for above change
| Commit: | 3f5c353 | |
|---|---|---|
| Author: | bgeng777 | |
| Committer: | GitHub | |
[Flink AI Flow] Add Serde of ContextExtractor to persist it in aiflow database with Workflow (#485) Add Serde of ContextExtractor to persist it in aiflow database with Workflow - Use cloudpickle to do serde of ContextExtractor instance. - Add a new field in WorkflowMeta in `message.proto`: `context_extractor_in_bytes`, whose type is `bytes`. It stores the serialized bytes of ContextExtractor instance. - Modify the metadata service to adapt to the CRUD of `context_extractor_in_bytes` field. - Add tests for above change
| Commit: | 073513e | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
[AIFlow] Add start/stop workflow execution on event and ContextExtractor API (#476) Add start_new_workflow_execution_on_event and stop_workflow_execution_on_event API at workflow operation to support starting/stopping workflow execution when EventConditions are met. Add ContextExtractor to extract workflow execution context from events.
| Commit: | 3635707 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | GitHub | |
[AIFlow] Add start/stop workflow execution on event and ContextExtractor API (#476) Add start_new_workflow_execution_on_event and stop_workflow_execution_on_event API at workflow operation to support starting/stopping workflow execution when EventConditions are met. Add ContextExtractor to extract workflow execution context from events.
| Commit: | b0ea5e0 | |
|---|---|---|
| Author: | sxnan | |
| Committer: | Xuannan | |
[AIFlow] AIFlow proto update java_package
| Commit: | 0324163 | |
|---|---|---|
| Author: | sxnan | |
| Committer: | Xuannan | |
[AIFlow] AIFlow proto update java_package
| Commit: | 8b9ef81 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Rename rest_endpoint dir to endpoint (#306)
| Commit: | 0446d74 | |
|---|---|---|
| Author: | SteNicholas | |
| Committer: | Xuannan | |
metric center refactor
| Commit: | 33056fc | |
|---|---|---|
| Author: | SteNicholas | |
| Committer: | Xuannan | |
support GRPC restful interface (#357)
| Commit: | 19d1d56 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Add Workflow Meta to AIFlow (#349) * [Flink AI Flow] Add Workflow Meta to AIFlow
| Commit: | 44341ba | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Refactor model center and model meta (#344) * [Flink AI Flow] Refactor model center and model meta
| Commit: | 8460b52 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | Xuannan | |
[AIFlow][Metadata] Remove workflow execution and job meta (#340) * [AIFlow][Metadata] Remove WorkflowExecutionMeta and JobMeta * [AIFlow][Metadata] Remove WorkflowExecution and Job grpc service * [AIFlow][Metadata] Remove WorkflowExecution and Job tables * [AIFlow][Metadata] Remove WorkflowExecution Request proto
| Commit: | 09bb111 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Remove create_time and update_time from register and update dataset operation (#333) * [Flink AI Flow] Remove create_time and update_time from register and update dataset operation * [Flink AI Flow] Remove deploy_service from gen_protobuf.sh * [Flink AI Flow] Set update_time same to create_time when register dataset and artifact
| Commit: | 332a029 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Artifact refactor (#330) * [Flink AI Flow] Artifact refactor
| Commit: | 8ca8ba4 | |
|---|---|---|
| Author: | sxnan | |
| Committer: | Xuannan | |
[AIFlow][Refactor] Remove deployer
| Commit: | 46653a1 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
Example refactor (#317)
| Commit: | ba06374 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Refactor project meta (#312) * [Flink AI Flow] Refactor project meta
| Commit: | caa430d | |
|---|---|---|
| Author: | sxnan | |
| Committer: | Xuannan | |
[AIFlow][Refactor] Remove deployer
| Commit: | 44e4b88 | |
|---|---|---|
| Author: | SteNicholas | |
| Committer: | Xuannan | |
metric center refactor
| Commit: | dfab540 | |
|---|---|---|
| Author: | SteNicholas | |
| Committer: | Xuannan | |
support GRPC restful interface (#357)
| Commit: | 0049927 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Add Workflow Meta to AIFlow (#349) * [Flink AI Flow] Add Workflow Meta to AIFlow
| Commit: | 2ea472d | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Refactor model center and model meta (#344) * [Flink AI Flow] Refactor model center and model meta
| Commit: | 066d9f7 | |
|---|---|---|
| Author: | Xuannan | |
| Committer: | Xuannan | |
[AIFlow][Metadata] Remove workflow execution and job meta (#340) * [AIFlow][Metadata] Remove WorkflowExecutionMeta and JobMeta * [AIFlow][Metadata] Remove WorkflowExecution and Job grpc service * [AIFlow][Metadata] Remove WorkflowExecution and Job tables * [AIFlow][Metadata] Remove WorkflowExecution Request proto
| Commit: | 77f5da9 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Remove create_time and update_time from register and update dataset operation (#333) * [Flink AI Flow] Remove create_time and update_time from register and update dataset operation * [Flink AI Flow] Remove deploy_service from gen_protobuf.sh * [Flink AI Flow] Set update_time same to create_time when register dataset and artifact
| Commit: | b6da5a0 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Artifact refactor (#330) * [Flink AI Flow] Artifact refactor
| Commit: | e1b98b3 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
Example refactor (#317)
| Commit: | ce743e3 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Refactor project meta (#312) * [Flink AI Flow] Refactor project meta
| Commit: | 7da37d3 | |
|---|---|---|
| Author: | JiangXin | |
| Committer: | Xuannan | |
[Flink AI Flow] Rename rest_endpoint dir to endpoint (#306)
| Commit: | 31202ca | |
|---|---|---|
| Author: | wuchaochen | |
| Committer: | GitHub | |
[Notification service] BaseEvent 添加sender字段 (#252) Base event add sender field and frontend subscribed event
| Commit: | 31d25e8 | |
|---|---|---|
| Author: | wuchaochen | |
| Committer: | GitHub | |
[Notification service] BaseEvent 添加sender字段 (#252) Base event add sender field and frontend subscribed event
| Commit: | 878cc4b | |
|---|---|---|
| Author: | wuchaochen | |
add workflow operation tests
| Commit: | d49f00f | |
|---|---|---|
| Author: | wuchaochen | |
add workflow operation tests
| Commit: | 349f960 | |
|---|---|---|
| Author: | wuchaochen | |
cmd job using workflow operation api can run
| Commit: | d1d6c1e | |
|---|---|---|
| Author: | wuchaochen | |
cmd job using workflow operation api can run
| Commit: | 16afbbf | |
|---|---|---|
| Author: | wuchaochen | |
add scheduling service unittest
| Commit: | 5297aa8 | |
|---|---|---|
| Author: | wuchaochen | |
add scheduling service unittest
| Commit: | 7be7be3 | |
|---|---|---|
| Author: | wuchaochen | |
add scheduler service
| Commit: | 3405b89 | |
|---|---|---|
| Author: | wuchaochen | |
add scheduler service
| Commit: | 53bab1d | |
|---|---|---|
| Author: | wuchaochen | |
add go package to proto files.
| Commit: | 06cfb72 | |
|---|---|---|
| Author: | wuchaochen | |
add go package to proto files.
| Commit: | bbc5679 | |
|---|---|---|
| Author: | SteNicholas | |
service endpoint proto package
| Commit: | fad67c9 | |
|---|---|---|
| Author: | SteNicholas | |
service endpoint proto package
| Commit: | 2edde71 | |
|---|---|---|
| Author: | SteNicholas | |
service endpoint proto package
| Commit: | 62121aa | |
|---|---|---|
| Author: | SteNicholas | |
service endpoint proto package
| Commit: | 4f3a2b4 | |
|---|---|---|
| Author: | SteNicholas | |
notification service protobuf
| Commit: | 804e0ba | |
|---|---|---|
| Author: | SteNicholas | |
notification service protobuf
| Commit: | fb7b382 | |
|---|---|---|
| Author: | SteNicholas | |
support grpc restful API
| Commit: | 3041392 | |
|---|---|---|
| Author: | SteNicholas | |
support grpc restful API
| Commit: | fc426b2 | |
|---|---|---|
| Author: | Wei Zhong | |
AIFlow server and client support working on high-availability mode.
| Commit: | b694ac7 | |
|---|---|---|
| Author: | Wei Zhong | |
AIFlow server and client support working on high-availability mode.
| Commit: | f6bf540 | |
|---|---|---|
| Author: | Wei Zhong | |
notification service support high availability.
| Commit: | 50d0c9c | |
|---|---|---|
| Author: | Wei Zhong | |
notification service support high availability.
| Commit: | 59c8b22 | |
|---|---|---|
| Author: | Wei Zhong | |
Upgrade the functionality of the notification service.
| Commit: | 98cb1d0 | |
|---|---|---|
| Author: | Wei Zhong | |
Upgrade the functionality of the notification service.
| Commit: | 53d62a3 | |
|---|---|---|
| Author: | MarvinMiao | |
feature(client): support mongodb
| Commit: | ebc0a3d | |
|---|---|---|
| Author: | MarvinMiao | |
feature(client): support mongodb
| Commit: | 95c6e78 | |
|---|---|---|
| Author: | Wei Zhong | |
change the structure of total project
| Commit: | 3f27f29 | |
|---|---|---|
| Author: | Wei Zhong | |
change the structure of total project
| Commit: | 6b4c0b2 | |
|---|---|---|
| Author: | Wei Zhong | |
add flink-ai-flow project
| Commit: | b4c091a | |
|---|---|---|
| Author: | Wei Zhong | |
add flink-ai-flow project
| Commit: | 6ff34c1 | |
|---|---|---|
| Author: | wuchao.cwc | |
add flink-ai-extended code
| Commit: | 6021a1b | |
|---|---|---|
| Author: | wuchao.cwc | |
add flink-ai-extended code