[Bug] source doris to doris sink decimal schema value data inconsistency #9641
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
seatunnel doris source decimal(10,2) sine schema modify decimal(10,10) amount alll value 0.9999999999
SeaTunnel Version
test 2.3.9 and 2.3.11
SeaTunnel Config
env{
parallelism = 4
job.mode = "BATCH"
job.timezone = "Asia/Shanghai"
}
source{
Doris {
fenodes = "xxxxxxxxxxxxxxxxxx"
username = xxxxxxxxxxx
password = "**************"
table_list = [
{
database = "xxxxxx"
table = "xxxxxx"
doris.read.field = "id, amount "
doris.filter.query = "created_time BETWEEN '2025-07-28 00:00:00' AND '2025-07-28 23:59:59'"
}
]
}
}
transform {}
sink{
Doris {
fenodes = "xxxxxxxxxxx"
query-port = 9030
schema_save_mode = "RECREATE_SCHEMA"
username = xxxxxxxxxxx
password = "**************"
database = "xxxxxx"
table = "${table_name}"
sink.enable-2pc = "false"
doris.batch.size = 20000
doris.config = {
format = "csv"
column_separator = ","
}
}
}
Running Command
2.3.9
seatunnel.sh --config /data/seatunnel/conf/doris-batch.conf -m local
2.3.11
docker run --rm -it -v /tmp/job/:/config apache/seatunnel:2.3.11 ./bin/seatunnel.sh -m local -c /config/doris-batch.confError Exception
source data
<img width="496" height="294" alt="Image" src="https://github.com/user-attachments/assets/248e20d2-5016-477b-a499-cd84053f094f" />
sink result data
<img width="629" height="292" alt="Image" src="https://github.com/user-attachments/assets/c314a41b-0bad-442f-8d39-83af7bfa8a60" />
have any other modify fix?
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