This is an automated email from the ASF dual-hosted git repository.
diwu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 594d4fbf8f6 [feat](cloud) Support Transaction::watch_key (#57408)
add e9414df979d [improve](job) support change offset for streaming job in
cloud mode (#57264)
No new revisions were added by this update.
Summary of changes:
cloud/src/common/bvars.cpp | 9 ++
cloud/src/common/bvars.h | 7 +
cloud/src/meta-service/meta_service.h | 13 ++
cloud/src/meta-service/meta_service_txn.cpp | 104 +++++++++++++++
cloud/test/meta_service_job_test.cpp | 143 +++++++++++++++++++++
.../apache/doris/cloud/rpc/MetaServiceClient.java | 12 ++
.../apache/doris/cloud/rpc/MetaServiceProxy.java | 5 +
.../insert/streaming/StreamingInsertJob.java | 39 +++++-
gensrc/proto/cloud.proto | 13 ++
...t_streaming_job_alter_offset_restart_fe.groovy} | 85 +++++++++---
10 files changed, 408 insertions(+), 22 deletions(-)
copy
regression-test/suites/job_p0/streaming_job/{test_streaming_job_restart_fe.groovy
=> test_streaming_job_alter_offset_restart_fe.groovy} (54%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
