-
Notifications
You must be signed in to change notification settings - Fork 2.2k
Closed
Labels
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
batch模式从doris中同步数据到console中,读取datetime类型数据错误。
doris表结构:
CREATE TABLE `test_sync` (
`id` int NULL,
`dt` datetime NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
) ENGINE=OLAP
UNIQUE KEY(`id`)
DISTRIBUTED BY HASH(`id`) BUCKETS 2
PROPERTIES (
"storage_format" = "V2",
"inverted_index_storage_format" = "V1",
"enable_unique_key_merge_on_write" = "true"
);
数据如下:
| id | dt |
|---|---|
| 1 | 2024-12-03 10:20:32 |
seatunnel任务打印结果是:
2024-12-20 19:39:16,193 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex=0 rowIndex=1: SeaTunnelRow#tableId= SeaTunnelRow#kind=INSERT : 1, 1970-01-01T00:28:53.192432
seatunnel将2024-12-03 10:20:32读成了1970-01-01T00:28:53.192432
doris 版本: 2.1.7
SeaTunnel Version
2.3.8
SeaTunnel Config
env {
job.name = "doris-mysql"
job.mode = "BATCH"
}
source {
Doris {
fenodes = "${doris_fe}"
username = "***"
password = "***"
database = "test"
table = "test_sync"
}
}
transform {
}
sink {
Console {}
}
Running Command
./bin/seatunnel.sh -c job/doris-mysql.config -m localError Exception
no exception
Zeta or Flink or Spark Version
No response
Java or Scala Version
No response
Screenshots
No response
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct
Metadata
Metadata
Assignees
Labels
Type
Projects
Status
Done