This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch auto-pick-63219-branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from 97d04001d7e branch-4.1: [fix](streaming-job) start counting task max
interval after the first record is received #63141 (#63163)
add 6d5646e067d [fix](streaming-job) restore split-bound Java types when
reading FE-persisted CDC offset (#63219)
No new revisions were added by this update.
Summary of changes:
.../source/reader/AbstractCdcSourceReader.java | 45 ++++++
.../source/reader/JdbcIncrementalSourceReader.java | 39 ++++-
.../source/reader/mysql/MySqlSourceReader.java | 58 +++++++-
.../reader/postgres/PostgresSourceReader.java | 23 +++
.../source/reader/AbstractCdcSourceReaderTest.java | 165 +++++++++++++++++++++
.../cdc/test_streaming_mysql_job_date_pk.out | 29 ++++
.../cdc/test_streaming_postgres_job_date_pk.out | 29 ++++
.../cdc/test_streaming_mysql_job_date_pk.groovy | 129 ++++++++++++++++
.../cdc/test_streaming_postgres_job_date_pk.groovy | 131 ++++++++++++++++
9 files changed, 635 insertions(+), 13 deletions(-)
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/source/reader/AbstractCdcSourceReaderTest.java
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_date_pk.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_date_pk.out
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_date_pk.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_date_pk.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]