This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch auto-pick-66238-branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from 87a7187512a branch-4.1: [refactor](search) Simplify Variant search
iterator binding #66449 (#66487)
add d62eb6d2a40 [fix](streaming-job) Optimize snapshot offset persistence
(#66238)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/doris/common/Config.java | 4 +
.../apache/doris/job/cdc/DataSourceConfigKeys.java | 1 +
.../insert/streaming/StreamingInsertJob.java | 30 ++-
.../streaming/StreamingJobSchedulerTask.java | 1 +
.../job/offset/jdbc/JdbcSourceOffsetProvider.java | 30 +++
.../offset/jdbc/JdbcTvfSourceOffsetProvider.java | 9 +-
.../StreamingInsertJobOffsetPersistenceTest.java | 263 +++++++++++++++++++++
.../jdbc/JdbcSourceOffsetProviderOffsetTest.java | 211 +++++++++++++++++
.../source/reader/mysql/MySqlSourceReader.java | 9 +-
.../reader/postgres/PostgresSourceReader.java | 10 +-
...g_mysql_job_snapshot_finished_restart_fe.groovy | 160 +++++++++++++
11 files changed, 708 insertions(+), 20 deletions(-)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/extensions/insert/streaming/StreamingInsertJobOffsetPersistenceTest.java
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_snapshot_finished_restart_fe.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
