failed to transfer data with float64 column type under full-refresh mode #49
Description
Issue Description
- Description of the issue:
failed to transfer data from database to database with float64 column type underfull-refreshmode,incrementalmode work
timeplusd:2.9.9-rc.26
.sling/env.yaml
connections:
timeplus:
url: 'proton://default@localhost:8463/default'reproduce:
drop stream if exists src;
drop stream if exists tgt;
select sleep(1) format Null;
create stream src(f float64);
create stream tgt(f float64);
select sleep(2) format Null;
insert into src(f) values (11.1)(22.2)(33.3);./sling run --src-conn TIMEPLUS --src-stream "src" --tgt-conn TIMEPLUS --tgt-object "tgt" --mode full-refresh -d-
Sling version (
sling --version):
Version: 1.2.20-timeplus.2 -
Operating System (
linux,mac,windows):
linux -
Replication Configuration:
-
Log Output (please run command with
-d):
2025-08-05 11:00:25 WRN Batch 1 failed, retrying in 964.151208ms: ~ could not execute statement
proton [AppendRow]: f proton [AppendRow]: converting decimal.Decimal to float64 is unsupported
2025-08-05 11:00:26 DBG closed "proton" connection (conn-proton-LL7)
2025-08-05 11:00:26 WRN Operation failed, retrying in 367.21469ms: ~ could not insert into `default`.`tgt`
--- task_run.go:112 func1 ---
--- task_run.go:562 runDbToDb ---
--- task_run.go:822 runProtonToProton ---
--- task_run.go:845 retryWithBackoff ---
--- retry.go:49 RetryNotify ---
--- retry.go:61 RetryNotifyWithTimer ---
--- retry.go:88 ] ---
--- retry.go:18 func1 ---
--- task_run.go:823 func5 ---
--- task_run.go:440 runFileToDB ---
--- task_run_write.go:146 WriteToDb ---
--- task_run_write.go:545 writeDirectly ---
--- database.go:2354 BulkImportFlow ---
--- database.go:2341 func1 ---
--- database_proton.go:246 BulkImportStream ---
--- database_proton.go:830 processBatch ---
--- retry.go:49 RetryNotify ---
--- retry.go:61 RetryNotifyWithTimer ---
--- retry.go:88 ] ---
--- retry.go:18 func1 ---
~ could not insert into table `default`.`tgt`, row: []interface {}{decimal.Decimal{value:(*big.Int)(0xc0011704e0), exp:-11}, time.Date(2025, time.August, 5, 3, 0, 23, 424000000, time.Location("+00"))}
--- database_proton.go:809 func1 ---
proton [AppendRow]: f proton [AppendRow]: converting decimal.Decimal to float64 is unsupported
context canceled
--- task_run.go:112 func1 ---
--- task_run.go:562 runDbToDb ---
--- task_run.go:822 runProtonToProton ---
--- task_run.go:845 retryWithBackoff ---
--- retry.go:49 RetryNotify ---
--- retry.go:61 RetryNotifyWithTimer ---
--- retry.go:88 ] ---
--- retry.go:18 func1 ---
--- task_run.go:823 func5 ---
--- task_run.go:440 runFileToDB ---
--- task_run_write.go:146 WriteToDb ---
--- task_run_write.go:545 writeDirectly ---
--- database.go:2354 BulkImportFlow ---
--- database.go:2341 func1 ---
--- database_proton.go:246 BulkImportStream ---
--- database_proton.go:830 processBatch ---
--- retry.go:49 RetryNotify ---
--- retry.go:61 RetryNotifyWithTimer ---
~ could not bulk import
--- retry.go:88 ] ---
~ failed to process batch 1 after retries
--- retry.go:18 func1 ---
~ context cancelled
--- database_proton.go:278 func1 ---
context canceled
Metadata
Metadata
Assignees
Labels
No labels