This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch auto-pick-65647-branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from 1286bb19770 branch-4.1: [fix](docker) Backport external Docker
improvements (#65913)
add 33acdc9bb64 [fix](fe) Normalize MySQL JDBC URLs for streaming jobs
(#65647)
No new revisions were added by this update.
Summary of changes:
.../insert/streaming/StreamingInsertJob.java | 17 ++-
.../streaming/StreamingJdbcUrlNormalizer.java | 83 ++++++++++++++
.../offset/jdbc/JdbcTvfSourceOffsetProvider.java | 3 +
.../CdcStreamTableValuedFunction.java | 10 +-
.../streaming/StreamingJdbcUrlNormalizerTest.java | 78 +++++++++++++
.../jdbc/JdbcTvfSourceOffsetProviderTest.java} | 31 ++---
.../CdcStreamTableValuedFunctionTest.java | 15 +++
.../source/reader/mysql/MySqlSourceReader.java | 8 ++
.../source/reader/mysql/MySqlYearConverter.java | 70 ++++++++++++
.../source/reader/mysql/MySqlSourceReaderTest.java | 29 +++++
.../reader/mysql/MySqlYearConverterTest.java | 75 ++++++++++++
.../cdc/test_streaming_mysql_job_all_type.out | 9 +-
.../test_streaming_mysql_job_integer_boundary.out | 33 +++---
.../cdc/tvf/test_cdc_stream_tvf_mysql.out | 13 +--
...ng_job_cdc_stream_mysql_jdbc_type_defaults.out} | 19 ++--
.../cdc/test_streaming_mysql_job_all_type.groovy | 4 +-
..._streaming_mysql_job_charset_and_strings.groovy | 6 +-
.../test_streaming_mysql_job_create_alter.groovy | 37 +-----
...est_streaming_mysql_job_integer_boundary.groovy | 41 +++----
.../test_streaming_mysql_job_special_offset.groovy | 11 +-
.../cdc/tvf/test_cdc_stream_tvf_mysql.groovy | 11 +-
..._job_cdc_stream_mysql_jdbc_type_defaults.groovy | 126 +++++++++++++++++++++
22 files changed, 599 insertions(+), 130 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJdbcUrlNormalizer.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/extensions/insert/streaming/StreamingJdbcUrlNormalizerTest.java
copy
fe/fe-core/src/test/java/org/apache/doris/job/{extensions/insert/streaming/PostgresResourceValidatorTest.java
=> offset/jdbc/JdbcTvfSourceOffsetProviderTest.java} (50%)
create mode 100644
fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/mysql/MySqlYearConverter.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/source/reader/mysql/MySqlYearConverterTest.java
copy
regression-test/data/job_p0/streaming_job/cdc/tvf/{test_streaming_job_cdc_stream_postgres_pause_resume.out
=> test_streaming_job_cdc_stream_mysql_jdbc_type_defaults.out} (59%)
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_mysql_jdbc_type_defaults.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
