This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git.
from b121ad6 [Refactor] Remove jprotobuf and use grpc client to connect
brpc service (#5650)
add a4f8194 [Audit][Stream Load] Support audit function for stream load
(#5452)
No new revisions were added by this update.
Summary of changes:
be/src/common/config.h | 8 +
be/src/http/action/stream_load.cpp | 26 ++-
be/src/http/action/stream_load.h | 1 +
be/src/olap/storage_engine.cpp | 26 ++-
be/src/olap/storage_engine.h | 7 +
be/src/runtime/CMakeLists.txt | 1 +
.../routine_load/routine_load_task_executor.cpp | 2 +-
be/src/runtime/stream_load/stream_load_context.cpp | 155 +++++++++++++++++-
be/src/runtime/stream_load/stream_load_context.h | 10 +-
.../runtime/stream_load/stream_load_executor.cpp | 2 +-
.../runtime/stream_load/stream_load_recorder.cpp | 121 ++++++++++++++
.../stream_load/stream_load_recorder.h} | 38 +++--
be/src/service/backend_service.cpp | 23 +++
be/src/service/backend_service.h | 3 +
.../java/org/apache/doris/catalog/Catalog.java | 8 +
.../java/org/apache/doris/common/AuditLog.java | 5 +
.../main/java/org/apache/doris/common/Config.java | 10 +-
.../org/apache/doris/journal/JournalEntity.java | 6 +
.../org/apache/doris/load/StreamLoadRecordMgr.java | 177 +++++++++++++++++++++
.../java/org/apache/doris/persist/EditLog.java | 10 ++
.../org/apache/doris/persist/OperationType.java | 2 +
.../java/org/apache/doris/plugin/AuditEvent.java | 3 +-
.../apache/doris/plugin/StreamLoadAuditEvent.java | 144 +++++++++++++++++
.../java/org/apache/doris/qe/AuditLogBuilder.java | 30 +++-
.../main/java/org/apache/doris/system/Backend.java | 12 ++
.../org/apache/doris/common/GenericPoolTest.java | 7 +
.../apache/doris/utframe/MockedBackendFactory.java | 6 +
gensrc/thrift/BackendService.thrift | 27 ++++
28 files changed, 842 insertions(+), 28 deletions(-)
create mode 100644 be/src/runtime/stream_load/stream_load_recorder.cpp
copy be/src/{http/monitor_action.h =>
runtime/stream_load/stream_load_recorder.h} (56%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plugin/StreamLoadAuditEvent.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
