ziyanTOP opened a new pull request, #670:
URL: https://github.com/apache/doris-flink-connector/pull/670
## Problem Summary
`MongoDateConverter` hardcodes `Asia/Shanghai`, making it impossible to
configure the target timezone. Additionally:
1. Debezium serializes BSON Date as ISO 8601 strings (e.g.
`\"2024-06-04T08:03:37Z\"`) instead of `{\"$date\": ...}` objects. The existing
`formatSpecialFieldData()` only handles the object form.
2. `MongoDateConverter.timeZone` is a static variable that resets to default
`\"UTC\"` after serializer deserialization to TaskManagers.
## Changes
1. Add `date.timezone` ConfigOption (default `UTC`).
2. Add ISO 8601 string parsing in `formatSpecialFieldData()`.
3. Pass timezone through `JsonDebeziumChangeContext` (Serializable) to
TaskManagers.
4. Remove hardcoded `Asia/Shanghai` from `MongoDateConverter`.
Fixes #666
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
