This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch branch-catalog-spi
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 0793f032662 [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
omit 2b1a3bb2197 [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
omit 72d6d0109b9 [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
omit 7a16003c968 [doc](connector) add project tracking system for catalog
SPI migration
add adbff78c0a7 Revert "[Fix](variance) Fix sample variance/stddev NaN res
for single value" (#64099)
add e2c834003fc [regression-test](streaming-job) add cdc cases for
source/jdbc timezone and TIMESTAMP/timestamptz pk (#63543)
add a4857a55662 [fix](be) Release backend thrift service on shutdown
(#64110)
add da0cb3bc1b1 [fix](nereids) Make role-mapping keywords RULE/CEL/MAPPING
non-reserved (#64104)
add 66922d06bd0 [fix](streaming-job) fix postgres cdc multi-table
publication data loss and binlog duplicate key (#64075)
add 43cf4fd43af [fix](auto partition) keep load row metrics monotonic for
auto partition (#64109)
add 31b6fbb3e50 [opt](job) delay Kafka read committed zero-row retries
(#64046)
add 8de3a2fba9f [improvement](fe) Add configurable return mode for insert
publish timeout in ETL scenarios (#63919)
add a567cfe375e [fix](pipeline) fix comment-trigger workflow crash due to
GitHub API rate limit (#63304)
add 1834f8aa8e5 [chore](conf) Remove deprecated/unused FE/BE configs and
stale session variables (#63744)
add 092abb9dd85 [fix](fe) Align convert_tz folding with BE DST handling
(#64029)
new b921778a648 [doc](connector) add project tracking system for catalog
SPI migration
new e5dce49618b [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
new efbbef6be2b [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
new 63fb7e9fec7 [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0793f032662)
\
N -- N -- N refs/heads/branch-catalog-spi (63fb7e9fec7)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/comment-to-trigger-teamcity.yml | 6 +
be/src/cloud/config.cpp | 4 -
be/src/cloud/config.h | 3 -
be/src/common/config.cpp | 85 +-
be/src/common/config.h | 45 +-
be/src/exec/sink/vrow_distribution.cpp | 3 -
be/src/exec/sink/writer/vtablet_writer.cpp | 7 +-
be/src/exec/sink/writer/vtablet_writer_v2.cpp | 7 +-
be/src/exprs/aggregate/aggregate_function_stddev.h | 28 +-
be/src/exprs/function/function_convert_tz.cpp | 21 +-
.../server/oss/be_server_starter_factory.cpp | 5 +-
be/test/exprs/function/function_time_test.cpp | 17 +
.../server/be_server_starter_factory_test.cpp} | 35 +-
.../main/java/org/apache/doris/common/Config.java | 80 --
.../java/org/apache/doris/common/ConfigBase.java | 29 +
.../load/routineload/RoutineLoadTaskInfo.java | 9 +
.../routineload/kafka/KafkaRoutineLoadJob.java | 10 +-
.../load/routineload/kafka/KafkaTaskInfo.java | 7 +
.../executable/DateTimeExtractAndTransform.java | 6 +-
.../trees/expressions/literal/DateTimeLiteral.java | 36 +-
.../plans/commands/insert/OlapInsertExecutor.java | 16 +
.../java/org/apache/doris/qe/SessionVariable.java | 241 ++----
.../main/java/org/apache/doris/qe/VariableMgr.java | 54 ++
.../load/routineload/KafkaRoutineLoadJobTest.java | 48 ++
.../nereids/parser/RoleMappingParserTest.java | 67 ++
.../DateTimeExtractAndTransformTest.java | 43 +
.../literal/TimestampTzLiteralTest.java | 18 +
.../commands/insert/OlapInsertExecutorTest.java | 274 ++++++
.../org/apache/doris/qe/SessionVariablesTest.java | 88 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 3 +
.../postgresql/connection/PostgresConnection.java | 9 +-
.../connection/PostgresReplicationConnection.java | 932 --------------------
.../cdcclient/service/PipelineCoordinator.java | 9 +-
.../doris/cdcclient/sink/DorisBatchStreamLoad.java | 7 +-
.../deserialize/DebeziumJsonDeserializer.java | 15 +
.../source/reader/AbstractCdcSourceReader.java | 23 +-
.../source/reader/mysql/MySqlSourceReader.java | 7 +-
.../reader/postgres/PostgresSourceReader.java | 93 +-
.../src/main/resources/application.properties | 4 +-
.../deserialize/DebeziumJsonDeserializerTest.java | 50 ++
.../test_select_stddev_variance_window.out | 933 +++++++++++----------
.../timestamptz/test_timestamptz_dst_gap.out | 4 +-
.../data/function_p0/test_agg_foreach.out | 3 +-
.../data/function_p0/test_agg_foreach_notnull.out | 3 +-
.../test_insert_visible_timeout_return_mode.out} | 5 +-
...est_streaming_mysql_job_jdbc_servertimezone.out | 14 +
.../test_streaming_mysql_job_source_timezone.out | 29 +
...t => test_streaming_mysql_job_timestamp_pk.out} | 5 +-
..._streaming_postgres_job_jdbc_servertimezone.out | 15 +
...ob_snapshot_with_concurrent_dml_multi_table.out | 43 +
...test_streaming_postgres_job_source_timezone.out | 29 +
...> test_streaming_postgres_job_timestamp_pk.out} | 19 +-
.../data/nereids_function_p0/agg_function/agg.out | 672 +++++++--------
.../normalize_window_nullable_agg_test.out | 5 +-
.../nereids_syntax_p0/mv/aggregate/agg_sync_mv.out | 157 ++--
.../data/query_p0/aggregate/agg_nullable_2.out | 19 +-
.../data/query_p0/aggregate/aggregate.out | 4 +-
.../set/test_removed_session_variables.out | 13 +
.../datetime_functions/test_convert_tz.out | 3 +
.../test_select_stddev_variance_window.out | 169 ++--
regression-test/pipeline/common/github-utils.sh | 5 +-
.../test_insert_visible_timeout_return_mode.groovy | 83 ++
..._streaming_mysql_job_jdbc_servertimezone.groovy | 144 ++++
...test_streaming_mysql_job_source_timezone.groovy | 218 +++++
...> test_streaming_mysql_job_timestamp_pk.groovy} | 66 +-
...eaming_postgres_job_jdbc_servertimezone.groovy} | 104 ++-
...snapshot_with_concurrent_dml_multi_table.groovy | 163 ++++
...t_streaming_postgres_job_source_timezone.groovy | 226 +++++
...st_streaming_postgres_job_special_offset.groovy | 11 +-
...test_streaming_postgres_job_timestamp_pk.groovy | 193 +++++
...st_streaming_insert_job_fetch_meta_error.groovy | 9 +-
.../suites/query_p0/aggregate/aggregate.groovy | 1 -
.../keyword/test_role_mapping_keyword.groovy | 75 ++
.../set/test_removed_session_variables.groovy | 87 ++
.../datetime_functions/test_convert_tz.groovy | 2 +
75 files changed, 3560 insertions(+), 2415 deletions(-)
copy be/test/{exec/schema_scanner/schema_encryption_keys_scanner_test.cpp =>
service/server/be_server_starter_factory_test.cpp} (52%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/insert/OlapInsertExecutorTest.java
delete mode 100644
fs_brokers/cdc_client/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java
copy regression-test/data/{load/insert/test_publish_slow_not_wait.out =>
insert_p0/test_insert_visible_timeout_return_mode.out} (79%)
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_jdbc_servertimezone.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_mysql_job_source_timezone.out
copy
regression-test/data/job_p0/streaming_job/cdc/{test_streaming_mysql_job_datetime_pk.out
=> test_streaming_mysql_job_timestamp_pk.out} (89%)
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_jdbc_servertimezone.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_snapshot_with_concurrent_dml_multi_table.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_source_timezone.out
copy
regression-test/data/job_p0/streaming_job/cdc/{test_streaming_mysql_job_datetime_pk.out
=> test_streaming_postgres_job_timestamp_pk.out} (62%)
create mode 100644
regression-test/data/query_p0/set/test_removed_session_variables.out
create mode 100644
regression-test/suites/insert_p0/test_insert_visible_timeout_return_mode.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_jdbc_servertimezone.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_source_timezone.groovy
copy
regression-test/suites/job_p0/streaming_job/cdc/{test_streaming_mysql_job_datetime_pk.groovy
=> test_streaming_mysql_job_timestamp_pk.groovy} (73%)
copy
regression-test/suites/job_p0/streaming_job/cdc/{test_streaming_postgres_job_decimal_pk.groovy
=> test_streaming_postgres_job_jdbc_servertimezone.groovy} (51%)
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_snapshot_with_concurrent_dml_multi_table.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_source_timezone.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_timestamp_pk.groovy
create mode 100644
regression-test/suites/query_p0/keyword/test_role_mapping_keyword.groovy
create mode 100644
regression-test/suites/query_p0/set/test_removed_session_variables.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
