Runkang He created FLINK-36572: ---------------------------------- Summary: The local time zone is wrongly set in StarRocks pipeline sink Key: FLINK-36572 URL: https://issues.apache.org/jira/browse/FLINK-36572 Project: Flink Issue Type: Bug Components: Flink CDC Affects Versions: cdc-3.2.1 Reporter: Runkang He
The local time zone is wrongly set in StarRocks pipeline sink. In `StarRocksDataSinkFactory`, it should get the zone id from `Context.getPipelineConfiguration().get(PIPELINE_LOCAL_TIME_ZONE)`, but now is `Context.getFactoryConfiguration().get(PIPELINE_LOCAL_TIME_ZONE)`, which is wrong. -- This message was sent by Atlassian Jira (v8.20.10#820010)