panic when import data from database to database

Issue Description

Description of the issue:
Sling version (sling --version): dev
Operating System (linux, mac, windows): linux

Replication Configuration: ~/.sling/env.yaml

connections:
daily_timeplus:
url: 'proton://default@172.31.29.101:30863/default'

historical_timeplus:
type: proton
host: 172.31.29.101
user: default
password: ""
port: 30863
database: default

daily_to_his.yaml


source: DAILY_TIMEPLUS
target: HISTORICAL_TIMEPLUS

defaults: mode: incremental

streams: rtdc_exchange_order: update_key: _tp_time object: gj_rtdc_exchange_order rtdc_execution: update_key: _tp_time object: gj_rtdc_execution rtdc_position: update_key: _tp_time object: gj_rtdc_position rtdc_fund: update_key: _tp_time object: gj_rtdc_fund t_metrics: update_key: _tp_time object: gj_metrics ...


- Log Output (please run command with `-d`):

[root@node0 sling]# ./sling-timeplus run -r daily_to_his.yaml WARN[0000]log.go:244 gosnowflake.(*defaultLogger).Warn DBUS_SESSION_BUS_ADDRESS envvar looks to be not set, this can lead to runaway dbus-daemon processes. To avoid this, set envvar DBUS_SESSION_BUS_ADDRESS=$XDG_RUNTIME_DIR/bus (if it exists) or DBUS_SESSION_BUS_ADDRESS=/dev/null. 8:56PM INF Sling Replication [5 streams] | DAILY_TIMEPLUS -> HISTORICAL_TIMEPLUS

8:56PM INF [1 / 5] running stream rtdc_exchange_order 8:56PM INF connecting to source database (proton) 8:56PM INF connecting to target database (proton) 8:56PM INF getting checkpoint value 8:56PM INF reading from source database 8:56PM INF writing to target database [mode: incremental] 8:56PM INF streaming data 24s 455,105 19968 r/s 270 MB 8:56PM INF inserted 470773 rows into default.gj_rtdc_exchange_order in 35 secs [13,354 r/s] [280 MB] 8:56PM INF execution succeeded

8:56PM INF [2 / 5] running stream rtdc_execution 8:56PM INF connecting to source database (proton) 8:56PM INF connecting to target database (proton) 8:56PM INF getting checkpoint value 8:56PM INF reading from source database 8:56PM INF writing to target database [mode: incremental] 8:56PM INF streaming data 15s 465,285 32688 r/s 201 MB 8:57PM INF inserted 470756 rows into default.gj_rtdc_execution in 25 secs [18,210 r/s] [203 MB] 8:57PM INF execution succeeded

8:57PM INF [3 / 5] running stream rtdc_position 8:57PM INF connecting to source database (proton) 8:57PM INF connecting to target database (proton) 8:57PM INF getting checkpoint value 8:57PM INF reading from source database 8:57PM INF writing to target database [mode: incremental] 8:57PM INF streaming data 6s 236,987 58640 r/s 50 MB 8:57PM INF inserted 237420 rows into default.gj_rtdc_position in 14 secs [16,791 r/s] [50 MB] 8:57PM INF execution succeeded

8:57PM INF [4 / 5] running stream rtdc_fund 8:57PM INF connecting to source database (proton) 8:57PM INF connecting to target database (proton) 8:57PM INF getting checkpoint value 8:57PM INF reading from source database 8:57PM INF writing to target database [mode: incremental] 8:57PM INF streaming data 8:57PM INF inserted 50 rows into default.gj_rtdc_fund in 7 secs [7 r/s] [7.5 kB] 8:57PM INF execution succeeded

8:57PM INF [5 / 5] running stream t_metrics 8:57PM INF connecting to source database (proton) 8:57PM INF connecting to target database (proton) 8:57PM INF getting checkpoint value 8:57PM INF reading from source database 8:57PM INF writing to target database [mode: incremental] 8:57PM INF streaming data unexpected fault address 0x0 fatal error: fault [signal SIGSEGV: segmentation violation code=0x80 addr=0x0 pc=0x1174a89]

goroutine 817 gp=0xc0010af6c0 m=8 mp=0xc000780008 [running]: runtime.throw({0x33b76fc?, 0xc00b456120?}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/panic.go:1023 +0x5c fp=0xc003606d90 sp=0xc003606d60 pc=0x43df1c runtime.sigpanic() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/signal_unix.go:895 +0x285 fp=0xc003606df0 sp=0xc003606d90 pc=0x456965 math/big.nat.bitLen(...) /opt/hostedtoolcache/go/1.22.8/x64/src/math/big/nat.go:664 math/big.(Int).BitLen(...) /opt/hostedtoolcache/go/1.22.8/x64/src/math/big/int.go:550 github.com/shopspring/decimal.Decimal.NumDigits({0xc00a07a040?, 0x2d138c0?}) /home/runner/go/pkg/mod/github.com/shopspring/decimal@v1.4.0/decimal.go:1255 +0x109 fp=0xc003606e70 sp=0xc003606df0 pc=0x1174a89 github.com/slingdata-io/sling-cli/core/dbio/iop.(StreamProcessor).CastToStringSafeMask(0xc002a3ac40, 0x0?, {0x3397820?, 0xc00b453e20?}, {0xc003606ee0?, 0x681015?, 0xc003606eb0?}) /home/runner/work/sling-cli/sling-cli/core/dbio/iop/stream_processor.go:939 +0x105 fp=0xc003606e98 sp=0xc003606e70 pc=0x11d7085 github.com/slingdata-io/sling-cli/core/dbio/iop.(Datastream).CastToStringSafeMask(0xc0032fdba0, {0xc00b451b00, 0x11, 0x0?}) /home/runner/work/sling-cli/sling-cli/core/dbio/iop/datastream.go:311 +0xfa fp=0xc003606f10 sp=0xc003606e98 pc=0x11920ba github.com/slingdata-io/sling-cli/core/dbio/iop.(Datastream).processBwRows.func1() /home/runner/work/sling-cli/sling-cli/core/dbio/iop/datastream.go:225 +0xae fp=0xc003606f80 sp=0xc003606f10 pc=0x11916ce github.com/slingdata-io/sling-cli/core/dbio/iop.(Datastream).processBwRows(0xc0032fdba0) /home/runner/work/sling-cli/sling-cli/core/dbio/iop/datastream.go:234 +0x91 fp=0xc003606fc8 sp=0xc003606f80 pc=0x11915f1 github.com/slingdata-io/sling-cli/core/dbio/iop.(Datastream).Start.gowrap1() /home/runner/work/sling-cli/sling-cli/core/dbio/iop/datastream.go:819 +0x25 fp=0xc003606fe0 sp=0xc003606fc8 pc=0x1197ea5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc003606fe8 sp=0xc003606fe0 pc=0x478c21 created by github.com/slingdata-io/sling-cli/core/dbio/iop.(*Datastream).Start in goroutine 797 /home/runner/work/sling-cli/sling-cli/core/dbio/iop/datastream.go:819 +0x1445

goroutine 1 gp=0xc0000061c0 m=nil [select]: runtime.gopark(0xc003b7ca20?, 0x2?, 0x78?, 0xa4?, 0xc003b7c914?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc003b7c720 sp=0xc003b7c700 pc=0x440e2e runtime.selectgo(0xc003b7ca20, 0xc003b7c910, 0x2d138c0?, 0x0, 0x33b53de?, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/select.go:327 +0x725 fp=0xc003b7c840 sp=0xc003b7c720 pc=0x452c05 github.com/slingdata-io/sling-cli/core/sling.(*TaskExecution).Execute(0xc002a74480) /home/runner/work/sling-cli/sling-cli/core/sling/task_run.go:113 +0x41a fp=0xc003b7ca88 sp=0xc003b7c840 pc=0x2b19d3a main.runTask(0xc00139fb08, 0xc000a8d7c0) /home/runner/work/sling-cli/sling-cli/cmd/sling/sling_run.go:396 +0x705 fp=0xc003b7cd80 sp=0xc003b7ca88 pc=0x2b369e5 main.runReplication({0x7ffe745c980b, 0x11}, 0xc000fb9688, {0xc000cbf700, 0x0, 0x0}) /home/runner/work/sling-cli/sling-cli/cmd/sling/sling_run.go:494 +0xa65 fp=0xc003b7d5a0 sp=0xc003b7cd80 pc=0x2b39365 main.processRun(0x6726460) /home/runner/work/sling-cli/sling-cli/cmd/sling/sling_run.go:200 +0x2419 fp=0xc003b7dc38 sp=0xc003b7d5a0 pc=0x2b35e99 github.com/flarco/g.CliProcess() /home/runner/go/pkg/mod/github.com/flarco/g@v0.1.119/cli.go:286 +0x43b fp=0xc003b7ddb8 sp=0xc003b7dc38 pc=0x998d7b main.cliInit(0x2d138c0?) /home/runner/work/sling-cli/sling-cli/cmd/sling/sling_cli.go:509 +0x205 fp=0xc003b7dee8 sp=0xc003b7ddb8 pc=0x2b2fec5 main.main() /home/runner/work/sling-cli/sling-cli/cmd/sling/sling_cli.go:473 +0x1fc fp=0xc003b7df50 sp=0xc003b7dee8 pc=0x2b2fa3c runtime.main() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:271 +0x29d fp=0xc003b7dfe0 sp=0xc003b7df50 pc=0x4409dd runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc003b7dfe8 sp=0xc003b7dfe0 pc=0x478c21

goroutine 2 gp=0xc000006700 m=nil [force gc (idle), 1 minutes]: runtime.gopark(0x0?, 0x0?, 0x0?, 0x0?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000098fa8 sp=0xc000098f88 pc=0x440e2e runtime.goparkunlock(...) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:408 runtime.forcegchelper() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:326 +0xb3 fp=0xc000098fe0 sp=0xc000098fa8 pc=0x440c93 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc000098fe8 sp=0xc000098fe0 pc=0x478c21 created by runtime.init.6 in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:314 +0x1a

goroutine 3 gp=0xc000006c40 m=nil [GC sweep wait]: runtime.gopark(0x1?, 0x0?, 0x0?, 0x0?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000099780 sp=0xc000099760 pc=0x440e2e runtime.goparkunlock(...) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:408 runtime.bgsweep(0xc0000b8000) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgcsweep.go:318 +0xdf fp=0xc0000997c8 sp=0xc000099780 pc=0x42a71f runtime.gcenable.gowrap1() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:203 +0x25 fp=0xc0000997e0 sp=0xc0000997c8 pc=0x41f005 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0000997e8 sp=0xc0000997e0 pc=0x478c21 created by runtime.gcenable in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:203 +0x66

goroutine 4 gp=0xc000006e00 m=nil [GC scavenge wait]: runtime.gopark(0x50330c?, 0x4b856b?, 0x0?, 0x0?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000099f78 sp=0xc000099f58 pc=0x440e2e runtime.goparkunlock(...) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:408 runtime.(*scavengerState).park(0x675bc20) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgcscavenge.go:425 +0x49 fp=0xc000099fa8 sp=0xc000099f78 pc=0x4280a9 runtime.bgscavenge(0xc0000b8000) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgcscavenge.go:658 +0x59 fp=0xc000099fc8 sp=0xc000099fa8 pc=0x428659 runtime.gcenable.gowrap2() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:204 +0x25 fp=0xc000099fe0 sp=0xc000099fc8 pc=0x41efa5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc000099fe8 sp=0xc000099fe0 pc=0x478c21 created by runtime.gcenable in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:204 +0xa5

goroutine 17 gp=0xc000102380 m=nil [finalizer wait]: runtime.gopark(0x0?, 0x35aeb38?, 0x0?, 0x80?, 0x2000000020?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000098620 sp=0xc000098600 pc=0x440e2e runtime.runfinq() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mfinal.go:194 +0x107 fp=0xc0000987e0 sp=0xc000098620 pc=0x41e047 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0000987e8 sp=0xc0000987e0 pc=0x478c21 created by runtime.createfing in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mfinal.go:164 +0x3d

goroutine 18 gp=0xc000102540 m=nil [GC worker (idle)]: runtime.gopark(0xfd905c73232?, 0x1?, 0x10?, 0xc4?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000094750 sp=0xc000094730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0000947e0 sp=0xc000094750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0000947e8 sp=0xc0000947e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 33 gp=0xc0005a4000 m=nil [GC worker (idle)]: runtime.gopark(0xfd905bf9f55?, 0x3?, 0xf2?, 0x4e?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005aa750 sp=0xc0005aa730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0005aa7e0 sp=0xc0005aa750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005aa7e8 sp=0xc0005aa7e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 5 gp=0xc000007340 m=nil [GC worker (idle)]: runtime.gopark(0xfd905b999ab?, 0x1?, 0xc8?, 0xb3?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc00009a750 sp=0xc00009a730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc00009a7e0 sp=0xc00009a750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc00009a7e8 sp=0xc00009a7e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 19 gp=0xc000102700 m=nil [GC worker (idle)]: runtime.gopark(0xfd88b49f8b7?, 0x3?, 0xbc?, 0x6a?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000094f50 sp=0xc000094f30 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc000094fe0 sp=0xc000094f50 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc000094fe8 sp=0xc000094fe0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 34 gp=0xc0005a41c0 m=nil [GC worker (idle)]: runtime.gopark(0xfd905dc7abc?, 0x1?, 0x48?, 0x41?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005aaf50 sp=0xc0005aaf30 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0005aafe0 sp=0xc0005aaf50 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005aafe8 sp=0xc0005aafe0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 20 gp=0xc0001028c0 m=nil [GC worker (idle)]: runtime.gopark(0xfd905c245b5?, 0x3?, 0xd7?, 0x67?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000095750 sp=0xc000095730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0000957e0 sp=0xc000095750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0000957e8 sp=0xc0000957e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 35 gp=0xc0005a4380 m=nil [GC worker (idle)]: runtime.gopark(0xfd905be4620?, 0x3?, 0x31?, 0xdf?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005ab750 sp=0xc0005ab730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0005ab7e0 sp=0xc0005ab750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005ab7e8 sp=0xc0005ab7e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 6 gp=0xc000007500 m=nil [GC worker (idle)]: runtime.gopark(0xfd905c79c9e?, 0x3?, 0xa6?, 0x57?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc00009af50 sp=0xc00009af30 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc00009afe0 sp=0xc00009af50 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc00009afe8 sp=0xc00009afe0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 36 gp=0xc0005a4540 m=nil [GC worker (idle)]: runtime.gopark(0xfd905d2d391?, 0x3?, 0x6d?, 0xa0?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005abf50 sp=0xc0005abf30 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0005abfe0 sp=0xc0005abf50 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005abfe8 sp=0xc0005abfe0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 7 gp=0xc0000076c0 m=nil [GC worker (idle)]: runtime.gopark(0xfd905c47cc7?, 0x3?, 0x17?, 0xad?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc00009b750 sp=0xc00009b730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc00009b7e0 sp=0xc00009b750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc00009b7e8 sp=0xc00009b7e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 21 gp=0xc000102a80 m=nil [GC worker (idle)]: runtime.gopark(0xfd905e980cc?, 0x3?, 0x6a?, 0x5b?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000095f50 sp=0xc000095f30 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc000095fe0 sp=0xc000095f50 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc000095fe8 sp=0xc000095fe0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 8 gp=0xc000007880 m=nil [GC worker (idle)]: runtime.gopark(0xfd905cf475b?, 0x3?, 0x4d?, 0x60?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc00009bf50 sp=0xc00009bf30 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc00009bfe0 sp=0xc00009bf50 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc00009bfe8 sp=0xc00009bfe0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 37 gp=0xc0005a4700 m=nil [GC worker (idle)]: runtime.gopark(0xfd905c48a7e?, 0x3?, 0x64?, 0x42?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005ac750 sp=0xc0005ac730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0005ac7e0 sp=0xc0005ac750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005ac7e8 sp=0xc0005ac7e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 38 gp=0xc0005a48c0 m=nil [GC worker (idle), 1 minutes]: runtime.gopark(0xfc730cf9593?, 0x3?, 0xc2?, 0x76?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005acf50 sp=0xc0005acf30 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0005acfe0 sp=0xc0005acf50 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005acfe8 sp=0xc0005acfe0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 9 gp=0xc000007a40 m=nil [GC worker (idle)]: runtime.gopark(0xfd905c56802?, 0x3?, 0x89?, 0xe3?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005a6750 sp=0xc0005a6730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0005a67e0 sp=0xc0005a6750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005a67e8 sp=0xc0005a67e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 39 gp=0xc0005a4a80 m=nil [GC worker (idle)]: runtime.gopark(0xfd905c3cfc9?, 0x3?, 0x92?, 0xe2?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005ad750 sp=0xc0005ad730 pc=0x440e2e runtime.gcBgMarkWorker() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1310 +0xe5 fp=0xc0005ad7e0 sp=0xc0005ad750 pc=0x4210e5 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005ad7e8 sp=0xc0005ad7e0 pc=0x478c21 created by runtime.gcBgMarkStartWorkers in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/mgc.go:1234 +0x1c

goroutine 22 gp=0xc0006836c0 m=nil [select]: runtime.gopark(0xc0005adf78?, 0x3?, 0x68?, 0xca?, 0xc0005adf72?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005ade18 sp=0xc0005addf8 pc=0x440e2e runtime.selectgo(0xc0005adf78, 0xc0005adf6c, 0xc000b00000?, 0x0, 0x0?, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/select.go:327 +0x725 fp=0xc0005adf38 sp=0xc0005ade18 pc=0x452c05 go.opencensus.io/stats/view.(*worker).start(0xc000b00000) /home/runner/go/pkg/mod/go.opencensus.io@v0.24.0/stats/view/worker.go:292 +0x9f fp=0xc0005adfc8 sp=0xc0005adf38 pc=0x10dc71f go.opencensus.io/stats/view.init.0.gowrap1() /home/runner/go/pkg/mod/go.opencensus.io@v0.24.0/stats/view/worker.go:34 +0x25 fp=0xc0005adfe0 sp=0xc0005adfc8 pc=0x10dba85 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005adfe8 sp=0xc0005adfe0 pc=0x478c21 created by go.opencensus.io/stats/view.init.0 in goroutine 1 /home/runner/go/pkg/mod/go.opencensus.io@v0.24.0/stats/view/worker.go:34 +0x8d

goroutine 42 gp=0xc000e9a380 m=4 mp=0xc000100008 [syscall, 1 minutes]: runtime.notetsleepg(0x67cd120, 0xffffffffffffffff) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/lock_futex.go:246 +0x29 fp=0xc0005a6fa0 sp=0xc0005a6f78 pc=0x4107c9 os/signal.signal_recv() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/sigqueue.go:152 +0x29 fp=0xc0005a6fc0 sp=0xc0005a6fa0 pc=0x4751a9 os/signal.loop() /opt/hostedtoolcache/go/1.22.8/x64/src/os/signal/signal_unix.go:23 +0x13 fp=0xc0005a6fe0 sp=0xc0005a6fc0 pc=0x2abccb3 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005a6fe8 sp=0xc0005a6fe0 pc=0x478c21 created by os/signal.Notify.func1.1 in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/os/signal/signal.go:151 +0x1f

goroutine 15 gp=0xc000703180 m=nil [select, 1 minutes]: runtime.gopark(0xc000dca788?, 0x2?, 0x60?, 0x0?, 0xc000dca784?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000dca630 sp=0xc000dca610 pc=0x440e2e runtime.selectgo(0xc000dca788, 0xc000dca780, 0x0?, 0x0, 0x0?, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/select.go:327 +0x725 fp=0xc000dca750 sp=0xc000dca630 pc=0x452c05 database/sql.(*DB).connectionOpener(0xc001088270, {0x3d930f0, 0xc000f60ff0}) /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:1246 +0x87 fp=0xc000dca7b8 sp=0xc000dca750 pc=0xa5bf87 database/sql.OpenDB.gowrap1() /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:824 +0x28 fp=0xc000dca7e0 sp=0xc000dca7b8 pc=0xa5a2a8 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc000dca7e8 sp=0xc000dca7e0 pc=0x478c21 created by database/sql.OpenDB in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:824 +0x14c

goroutine 16 gp=0xc0010ae1c0 m=nil [select, 1 minutes, locked to thread]: runtime.gopark(0xc000dcafa8?, 0x2?, 0x6d?, 0x22?, 0xc000dcaf94?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000dcae38 sp=0xc000dcae18 pc=0x440e2e runtime.selectgo(0xc000dcafa8, 0xc000dcaf90, 0x0?, 0x0, 0x0?, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/select.go:327 +0x725 fp=0xc000dcaf58 sp=0xc000dcae38 pc=0x452c05 runtime.ensureSigM.func1() /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/signal_unix.go:1034 +0x19f fp=0xc000dcafe0 sp=0xc000dcaf58 pc=0x46f91f runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc000dcafe8 sp=0xc000dcafe0 pc=0x478c21 created by runtime.ensureSigM in goroutine 1 /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/signal_unix.go:1017 +0xc8

goroutine 26 gp=0xc000e9a540 m=nil [select, 1 minutes]: runtime.gopark(0xc0005a7798?, 0x3?, 0x0?, 0x0?, 0xc0005a7762?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005a7600 sp=0xc0005a75e0 pc=0x440e2e runtime.selectgo(0xc0005a7798, 0xc0005a775c, 0x0?, 0x0, 0x0?, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/select.go:327 +0x725 fp=0xc0005a7720 sp=0xc0005a7600 pc=0x452c05 main.main.func2() /home/runner/work/sling-cli/sling-cli/cmd/sling/sling_cli.go:450 +0x8b fp=0xc0005a77e0 sp=0xc0005a7720 pc=0x2b2fb2b runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005a77e8 sp=0xc0005a77e0 pc=0x478c21 created by main.main in goroutine 1 /home/runner/work/sling-cli/sling-cli/cmd/sling/sling_cli.go:449 +0x1f2

goroutine 51 gp=0xc000e9ac40 m=nil [select, 1 minutes]: runtime.gopark(0xc0005a8f88?, 0x2?, 0x60?, 0x0?, 0xc0005a8f84?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0005a8e30 sp=0xc0005a8e10 pc=0x440e2e runtime.selectgo(0xc0005a8f88, 0xc0005a8f80, 0x0?, 0x0, 0x0?, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/select.go:327 +0x725 fp=0xc0005a8f50 sp=0xc0005a8e30 pc=0x452c05 database/sql.(*DB).connectionOpener(0xc001196dd0, {0x3d930f0, 0xc0000c7d10}) /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:1246 +0x87 fp=0xc0005a8fb8 sp=0xc0005a8f50 pc=0xa5bf87 database/sql.OpenDB.gowrap1() /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:824 +0x28 fp=0xc0005a8fe0 sp=0xc0005a8fb8 pc=0xa5a2a8 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0005a8fe8 sp=0xc0005a8fe0 pc=0x478c21 created by database/sql.OpenDB in goroutine 50 /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:824 +0x14c

goroutine 771 gp=0xc000e9ae00 m=nil [chan receive]: runtime.gopark(0x2dde020?, 0x0?, 0x98?, 0xdf?, 0x52b879?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc00160df08 sp=0xc00160dee8 pc=0x440e2e runtime.chanrecv(0xc000b6c000, 0x0, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/chan.go:583 +0x3bf fp=0xc00160df80 sp=0xc00160df08 pc=0x40a73f runtime.chanrecv1(0xc01a44c820?, 0x448edd?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/chan.go:442 +0x12 fp=0xc00160dfa8 sp=0xc00160df80 pc=0x40a352 database/sql.(Tx).awaitDone(0xc00118a080) /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:2202 +0x2b fp=0xc00160dfc8 sp=0xc00160dfa8 pc=0xa616ab database/sql.(DB).beginDC.gowrap1() /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:1915 +0x25 fp=0xc00160dfe0 sp=0xc00160dfc8 pc=0xa60665 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc00160dfe8 sp=0xc00160dfe0 pc=0x478c21 created by database/sql.(*DB).beginDC in goroutine 786 /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:1915 +0x20d

goroutine 819 gp=0xc0015028c0 m=nil [runnable]: strings.ToLower({0xc0032f61ab, 0x5}) /opt/hostedtoolcache/go/1.22.8/x64/src/strings/strings.go:636 +0x426 fp=0xc003607b78 sp=0xc003607b70 pc=0x51c026 github.com/slingdata-io/sling-cli/core/dbio/iop.(StreamProcessor).CastVal(0xc002a3ac40, 0xb, {0x2d138c0, 0xc00b37af10}, 0xc002a7be20) /home/runner/work/sling-cli/sling-cli/core/dbio/iop/stream_processor.go:568 +0x5a5 fp=0xc003607d68 sp=0xc003607b78 pc=0x11d4e45 github.com/slingdata-io/sling-cli/core/dbio/iop.(StreamProcessor).CastRow(0xc002a3ac40, {0xc00b37c5a0, 0x11, 0x11}, {0xc002a7b008, 0x11, 0x11?}) /home/runner/work/sling-cli/sling-cli/core/dbio/iop/stream_processor.go:1191 +0x126 fp=0xc003607df0 sp=0xc003607d68 pc=0x11d8746 github.com/slingdata-io/sling-cli/core/dbio/iop.(Datastream).Start.func9() /home/runner/work/sling-cli/sling-cli/core/dbio/iop/datastream.go:868 +0x5b7 fp=0xc003607fe0 sp=0xc003607df0 pc=0x11977d7 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc003607fe8 sp=0xc003607fe0 pc=0x478c21 created by github.com/slingdata-io/sling-cli/core/dbio/iop.(Datastream).Start in goroutine 797 /home/runner/work/sling-cli/sling-cli/core/dbio/iop/datastream.go:827 +0x1577

goroutine 800 gp=0xc001502fc0 m=nil [select]: runtime.gopark(0xc012ac2f48?, 0x3?, 0x60?, 0x0?, 0xc012ac2f32?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc012ac2dd8 sp=0xc012ac2db8 pc=0x440e2e runtime.selectgo(0xc012ac2f48, 0xc012ac2f2c, 0xc000d575c0?, 0x0, 0xc012ac2f98?, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/select.go:327 +0x725 fp=0xc012ac2ef8 sp=0xc012ac2dd8 pc=0x452c05 database/sql.(Rows).awaitDone(0xc0025c54d0, {0x3d930f0, 0xc01b213d10}, {0x0, 0x0}, {0x3d930f0, 0xc01b213db0}) /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:2990 +0xeb fp=0xc012ac2f98 sp=0xc012ac2ef8 pc=0xa652ab database/sql.(Rows).initContextClose.gowrap1() /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:2977 +0x38 fp=0xc012ac2fe0 sp=0xc012ac2f98 pc=0xa65198 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc012ac2fe8 sp=0xc012ac2fe0 pc=0x478c21 created by database/sql.(*Rows).initContextClose in goroutine 797 /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:2977 +0x150

goroutine 785 gp=0xc001603a40 m=nil [sleep]: runtime.gopark(0xfd9181edaaf?, 0x0?, 0x0?, 0x0?, 0xc0032fdba0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000693e40 sp=0xc000693e20 pc=0x440e2e time.Sleep(0x5f5e100) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/time.go:195 +0x115 fp=0xc000693e80 sp=0xc000693e40 pc=0x4759f5 github.com/slingdata-io/sling-cli/core/sling.NewTask.func1() /home/runner/work/sling-cli/sling-cli/core/sling/task.go:134 +0x17a fp=0xc000693fe0 sp=0xc000693e80 pc=0x2b12c5a runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc000693fe8 sp=0xc000693fe0 pc=0x478c21 created by github.com/slingdata-io/sling-cli/core/sling.NewTask in goroutine 1 /home/runner/work/sling-cli/sling-cli/core/sling/task.go:113 +0x485

goroutine 786 gp=0xc002248c40 m=nil [chan receive]: runtime.gopark(0xc00a074f20?, 0x100?, 0x4?, 0x56?, 0x10002d13a80?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc002bce520 sp=0xc002bce500 pc=0x440e2e runtime.chanrecv(0xc002c92420, 0xc002bce930, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/chan.go:583 +0x3bf fp=0xc002bce598 sp=0xc002bce520 pc=0x40a73f runtime.chanrecv2(0xc000f159a0?, 0xc00b37c480?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/chan.go:447 +0x12 fp=0xc002bce5c0 sp=0xc002bce598 pc=0x40a372 github.com/slingdata-io/sling-cli/core/dbio/database.(ProtonConn).processBatch(0xc0001e2180, {0xc000bdef00, 0x1a}, {{0xc00b7f0f50, 0xe}, {0xc00b7f0ed0, 0x7}, {0x0, 0x0}, 0x0, ...}, ...) /home/runner/work/sling-cli/sling-cli/core/dbio/database/database_proton.go:273 +0xaa6 fp=0xc002bce9f0 sp=0xc002bce5c0 pc=0x2a4c146 github.com/slingdata-io/sling-cli/core/dbio/database.(ProtonConn).BulkImportStream.func2() /home/runner/work/sling-cli/sling-cli/core/dbio/database/database_proton.go:209 +0x8f fp=0xc002bceaf8 sp=0xc002bce9f0 pc=0x2a4b3cf github.com/slingdata-io/sling-cli/core/dbio/database.retry(0x3, 0x12a05f200, 0xc002bced80) /home/runner/work/sling-cli/sling-cli/core/dbio/database/database_proton.go:148 +0x65 fp=0xc002bceb68 sp=0xc002bceaf8 pc=0x2a4a8a5 github.com/slingdata-io/sling-cli/core/dbio/database.(ProtonConn).BulkImportStream(0xc0001e2180, {0xc000bdef00, 0x1a}, 0xc0032fdba0) /home/runner/work/sling-cli/sling-cli/core/dbio/database/database_proton.go:208 +0x5b7 fp=0xc002bceeb0 sp=0xc002bceb68 pc=0x2a4af97 github.com/slingdata-io/sling-cli/core/dbio/database.(BaseConn).BulkImportFlow.func1({0xc000bdef00, 0x1a}, 0xc0032fdba0) /home/runner/work/sling-cli/sling-cli/core/dbio/database/database.go:2300 +0x173 fp=0xc002bcef60 sp=0xc002bceeb0 pc=0x2a0b473 github.com/slingdata-io/sling-cli/core/dbio/database.(BaseConn).BulkImportFlow(0xc0001e2180, {0xc000bdef00, 0x1a}, 0xc0032835f0) /home/runner/work/sling-cli/sling-cli/core/dbio/database/database.go:2313 +0x31e fp=0xc002bcf048 sp=0xc002bcef60 pc=0x2a0b23e github.com/slingdata-io/sling-cli/core/dbio/database.(ProtonConn).BulkImportFlow(0xc001082420?, {0xc000bdef00?, 0x0?}, 0x0?)

:1 +0x25 fp=0xc002bcf078 sp=0xc002bcf048 pc=0x2aa4825 github.com/slingdata-io/sling-cli/core/sling.(*TaskExecution).WriteToDb(0xc002a74480, 0xc00139fb08, 0xc0032835f0, {0x3e12238, 0xc0001e2180}) /home/runner/work/sling-cli/sling-cli/core/sling/task_run_write.go:336 +0x1ac4 fp=0xc002bcfa20 sp=0xc002bcf078 pc=0x2b25f04 github.com/slingdata-io/sling-cli/core/sling.(*TaskExecution).runDbToDb(0xc002a74480) /home/runner/work/sling-cli/sling-cli/core/sling/task_run.go:543 +0xed1 fp=0xc002bcfe90 sp=0xc002bcfa20 pc=0x2b1f691 github.com/slingdata-io/sling-cli/core/sling.(*TaskExecution).Execute.func1() /home/runner/work/sling-cli/sling-cli/core/sling/task_run.go:99 +0x579 fp=0xc002bcffe0 sp=0xc002bcfe90 pc=0x2b1a8b9 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc002bcffe8 sp=0xc002bcffe0 pc=0x478c21 created by github.com/slingdata-io/sling-cli/core/sling.(*TaskExecution).Execute in goroutine 1 /home/runner/work/sling-cli/sling-cli/core/sling/task_run.go:67 +0x3b3 goroutine 787 gp=0xc0022496c0 m=nil [select]: runtime.gopark(0xc000691f88?, 0x2?, 0x60?, 0x0?, 0xc000691f84?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc000691e30 sp=0xc000691e10 pc=0x440e2e runtime.selectgo(0xc000691f88, 0xc000691f80, 0xc005391eb8?, 0x0, 0x1928a6ba984?, 0x1) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/select.go:327 +0x725 fp=0xc000691f50 sp=0xc000691e30 pc=0x452c05 database/sql.(*DB).connectionOpener(0xc003283110, {0x3d930f0, 0xc01b213450}) /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:1246 +0x87 fp=0xc000691fb8 sp=0xc000691f50 pc=0xa5bf87 database/sql.OpenDB.gowrap1() /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:824 +0x28 fp=0xc000691fe0 sp=0xc000691fb8 pc=0xa5a2a8 runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc000691fe8 sp=0xc000691fe0 pc=0x478c21 created by database/sql.OpenDB in goroutine 786 /opt/hostedtoolcache/go/1.22.8/x64/src/database/sql/sql.go:824 +0x14c goroutine 799 gp=0xc002249a40 m=nil [chan send]: runtime.gopark(0x40f33b?, 0x8?, 0x0?, 0x40?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/proc.go:402 +0xce fp=0xc0048c2dd0 sp=0xc0048c2db0 pc=0x440e2e runtime.chansend(0xc0030dbe60, 0xc0048c2e90, 0x1, 0xc0032ee280?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/chan.go:259 +0x38d fp=0xc0048c2e40 sp=0xc0048c2dd0 pc=0x4099cd runtime.chansend1(0xc00151bcf0?, 0x0?) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/chan.go:145 +0x17 fp=0xc0048c2e70 sp=0xc0048c2e40 pc=0x409637 github.com/timeplus-io/proton-go-driver/v2.(*connect).query.func1.1(0xc0032ee280) /home/runner/go/pkg/mod/github.com/timeplus-io/proton-go-driver/v2@v2.0.17/conn_query.go:63 +0x25 fp=0xc0048c2e90 sp=0xc0048c2e70 pc=0x299f065 github.com/timeplus-io/proton-go-driver/v2.(*connect).handle(0xc000d2c000, 0xa5?, 0xc0032e3e90) /home/runner/go/pkg/mod/github.com/timeplus-io/proton-go-driver/v2@v2.0.17/conn_process.go:94 +0x202 fp=0xc0048c2f20 sp=0xc0048c2e90 pc=0x299dc02 github.com/timeplus-io/proton-go-driver/v2.(*connect).process(0xc000d2c000, {0x3d930f0, 0xc01b213d10}, 0xc0032e3e90) /home/runner/go/pkg/mod/github.com/timeplus-io/proton-go-driver/v2@v2.0.17/conn_process.go:80 +0x75 fp=0xc0048c2f58 sp=0xc0048c2f20 pc=0x299d955 github.com/timeplus-io/proton-go-driver/v2.(*connect).query.func1() /home/runner/go/pkg/mod/github.com/timeplus-io/proton-go-driver/v2@v2.0.17/conn_query.go:65 +0xbe fp=0xc0048c2fe0 sp=0xc0048c2f58 pc=0x299efbe runtime.goexit({}) /opt/hostedtoolcache/go/1.22.8/x64/src/runtime/asm_amd64.s:1695 +0x1 fp=0xc0048c2fe8 sp=0xc0048c2fe0 pc=0x478c21 created by github.com/timeplus-io/proton-go-driver/v2.(*connect).query in goroutine 797 /home/runner/go/pkg/mod/github.com/timeplus-io/proton-go-driver/v2@v2.0.17/conn_query.go:61 +0x645 ```

timeplus-io / sling-cli

panic when import data from database to database #11

Issue Description