Niivii commented on issue #43596:
URL: https://github.com/apache/arrow/issues/43596#issuecomment-2310125893

   Hello, another stacktrace of the issue happening again if that can help:
   
   ```
   runtime: bad pointer in frame 
github.com/apache/arrow/go/v17/parquet/pqarrow.writeDenseArrow at 0xc0007175e0: 
0x1
   fatal error: invalid pointer found on stack
   
   runtime stack:
   runtime.throw({0x7fc9c53fc82f?, 0x7fc9c6976908?})
        /usr/local/go/src/runtime/panic.go:1077 +0x5e fp=0x7fc976afc568 
sp=0x7fc976afc538 pc=0x7fc9c398169e
   runtime.adjustpointers(0x7fc976afc7e0?, 0x7fc976afc628, 0x7fc9c39a4d65?, 
{0x7fc976afc7e0?, 0x0?})
        /usr/local/go/src/runtime/stack.go:627 +0x1ad fp=0x7fc976afc5c8 
sp=0x7fc976afc568 pc=0x7fc9c399a06d
   runtime.adjustframe(0x7fc976afc7e0, 0x7fc976afc6c0)
        /usr/local/go/src/runtime/stack.go:684 +0xdb fp=0x7fc976afc658 
sp=0x7fc976afc5c8 pc=0x7fc9c399a19b
   runtime.copystack(0xc0008ee1a0, 0x7fc976afcaf8?)
        /usr/local/go/src/runtime/stack.go:935 +0x2c5 fp=0x7fc976afc950 
sp=0x7fc976afc658 pc=0x7fc9c399a945
   runtime.shrinkstack(0xc0008ee1a0)
        /usr/local/go/src/runtime/stack.go:1218 +0x113 fp=0x7fc976afc970 
sp=0x7fc976afc950 pc=0x7fc9c399b833
   runtime.scanstack(0xc0008ee1a0, 0x4?)
        /usr/local/go/src/runtime/mgcmark.go:776 +0xdb fp=0x7fc976afcca8 
sp=0x7fc976afc970 pc=0x7fc9c3969e9b
   runtime.markroot.func1()
        /usr/local/go/src/runtime/mgcmark.go:240 +0xb5 fp=0x7fc976afccf8 
sp=0x7fc976afcca8 pc=0x7fc9c3968eb5
   runtime.markroot(0xc000053740, 0x3a, 0x1)
        /usr/local/go/src/runtime/mgcmark.go:214 +0x1a8 fp=0x7fc976afcda0 
sp=0x7fc976afccf8 pc=0x7fc9c3968b48
   runtime.gcDrain(0xc000053740, 0x7)
        /usr/local/go/src/runtime/mgcmark.go:1069 +0x379 fp=0x7fc976afce00 
sp=0x7fc976afcda0 pc=0x7fc9c396aa99
   runtime.gcBgMarkWorker.func2()
        /usr/local/go/src/runtime/mgc.go:1387 +0x6f fp=0x7fc976afce50 
sp=0x7fc976afce00 pc=0x7fc9c39671cf
   runtime.systemstack()
        /usr/local/go/src/runtime/asm_amd64.s:509 +0x47 fp=0x7fc976afce60 
sp=0x7fc976afce50 pc=0x7fc9c39b1ca7
   
   goroutine 6 [GC worker (active)]:
   runtime.systemstack_switch()
        /usr/local/go/src/runtime/asm_amd64.s:474 +0x8 fp=0xc000064750 
sp=0xc000064740 pc=0x7fc9c39b1c48
   runtime.gcBgMarkWorker()
        /usr/local/go/src/runtime/mgc.go:1355 +0x1f6 fp=0xc0000647e0 
sp=0xc000064750 pc=0x7fc9c3966e96
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc0000647e8 
sp=0xc0000647e0 pc=0x7fc9c39b3c41
   created by runtime.gcBgMarkStartWorkers in goroutine 1
        /usr/local/go/src/runtime/mgc.go:1219 +0x1c
   
   goroutine 17 [select, locked to thread]:
   runtime.gopark(0xc00061bbf8?, 0x6?, 0xb8?, 0xb8?, 0xc00061ba0c?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc00061b890 
sp=0xc00061b870 pc=0x7fc9c398458e
   runtime.selectgo(0xc00061bbf8, 0xc00061ba00, 0x7fc9c53e7ce1?, 0x0, 
0x7fc9c3ed3405?, 0x1)
        /usr/local/go/src/runtime/select.go:327 +0x725 fp=0xc00061b9b0 
sp=0xc00061b890 pc=0x7fc9c3994065
   net/http.(*persistConn).roundTrip(0xc000b52240, 0xc00017eb00)
        /usr/local/go/src/net/http/transport.go:2652 +0x979 fp=0xc00061bc68 
sp=0xc00061b9b0 pc=0x7fc9c3edc099
   net/http.(*Transport).roundTrip(0x7fc9c6bb88a0, 0xc0000bb600)
        /usr/local/go/src/net/http/transport.go:604 +0x79a fp=0xc00061be90 
sp=0xc00061bc68 pc=0x7fc9c3ed041a
   net/http.(*Transport).RoundTrip(0xc0000bb600?, 0x7fc9c5a9a3c0?)
        /usr/local/go/src/net/http/roundtrip.go:17 +0x13 fp=0xc00061beb0 
sp=0xc00061be90 pc=0x7fc9c3ec51b3
   net/http.send(0xc0000bb500, {0x7fc9c5a9a3c0, 0x7fc9c6bb88a0}, {0x1?, 
0x7fc9c39d7334?, 0x7fc9c6c82f00?})
        /usr/local/go/src/net/http/client.go:260 +0x606 fp=0xc00061c0e0 
sp=0xc00061beb0 pc=0x7fc9c3e9ab66
   net/http.(*Client).send(0xc0006d1170, 0xc0000bb500, {0x7fc9c3e0fd29?, 
0xc00061c1d8?, 0x7fc9c6c82f00?})
        /usr/local/go/src/net/http/client.go:181 +0x98 fp=0xc00061c158 
sp=0xc00061c0e0 pc=0x7fc9c3e9a3f8
   net/http.(*Client).do(0xc0006d1170, 0xc0000bb500)
        /usr/local/go/src/net/http/client.go:724 +0x912 fp=0xc00061c368 
sp=0xc00061c158 pc=0x7fc9c3e9c6d2
   net/http.(*Client).Do(0xc00061c620?, 0xc000a231a0?)
        /usr/local/go/src/net/http/client.go:590 +0x13 fp=0xc00061c388 
sp=0xc00061c368 pc=0x7fc9c3e9bd93
   github.com/snowflakedb/gosnowflake.(*retryHTTP).execute(0xc00061c6a0)
        
/root/go/pkg/mod/github.com/snowflakedb/gosnowflake@v1.10.1/retry.go:325 +0x44a 
fp=0xc00061c690 sp=0xc00061c388 pc=0x7fc9c5358a6a
   github.com/snowflakedb/gosnowflake.postRestful({0x7fc9c5ab7480?, 
0xc000a22cf0?}, 0x12?, 0xc00061c808?, 0x7fc9c3a67e4e?, {0xc0006de6c0, 0x11b, 
0x120}, 0xc00061c7a8?, {0x7fc9c5a9a4a0, ...}, ...)
        
/root/go/pkg/mod/github.com/snowflakedb/gosnowflake@v1.10.1/restful.go:174 
+0x174 fp=0xc00061c728 sp=0xc00061c690 pc=0x7fc9c5352814
   github.com/snowflakedb/gosnowflake.postRestfulQueryHelper({0x7fc9c5ab7480, 
0xc000a22cf0}, 0xc0006ccf70, 0xc000066438, 0xc00061c9e0?, {0xc0006de6c0, 0x11b, 
0x120}, 0xc00061ca01?, {0xbe, ...}, ...)
        
/root/go/pkg/mod/github.com/snowflakedb/gosnowflake@v1.10.1/restful.go:246 
+0x45e fp=0xc00061c980 sp=0xc00061c728 pc=0x7fc9c535317e
   github.com/snowflakedb/gosnowflake.postRestfulQuery({0x7fc9c5ab7480, 
0xc000a22cf0}, 0xc0006ccf70, 0x7fc9ca7355b8?, 0xc00061cb00?, {0xc0006de6c0?, 
0xc0001568c0?, 0x70?}, 0x70?, {0xbe, ...}, ...)
        
/root/go/pkg/mod/github.com/snowflakedb/gosnowflake@v1.10.1/restful.go:213 
+0x5f fp=0xc00061ca10 sp=0xc00061c980 pc=0x7fc9c5352bbf
   github.com/snowflakedb/gosnowflake.(*snowflakeConn).exec(0xc00070e060, 
{0x7fc9c5ab7480, 0xc000a22cf0}, {0x7fc9c5429c59, 0x79}, 0x0, 0x0, 0x0, {0x0, 
0x0, ...})
        
/root/go/pkg/mod/github.com/snowflakedb/gosnowflake@v1.10.1/connection.go:145 
+0x85c fp=0xc00061cc80 sp=0xc00061ca10 pc=0x7fc9c53148dc
   
github.com/snowflakedb/gosnowflake.(*snowflakeConn).ExecContext(0xc00070e060, 
{0x7fc9c5ab74b8, 0xc000cf64b0}, {0x7fc9c5429c59, 0x79}, {0x0, 0x0, 0x0})
        
/root/go/pkg/mod/github.com/snowflakedb/gosnowflake@v1.10.1/connection.go:309 
+0x225 fp=0xc00061da40 sp=0xc00061cc80 pc=0x7fc9c5315b05
   
github.com/apache/arrow-adbc/go/adbc/driver/snowflake.(*statement).ingestStream(0xc000504000,
 {0x7fc9c5ab74b8, 0xc000cf64b0})
        /adbc/go/adbc/driver/snowflake/bulk_ingestion.go:271 +0x5e3 
fp=0xc00061dc00 sp=0xc00061da40 pc=0x7fc9c5393b23
   
github.com/apache/arrow-adbc/go/adbc/driver/snowflake.(*statement).executeIngest(0xc000504000,
 {0x7fc9c5ab74b8, 0xc000cf64b0})
        /adbc/go/adbc/driver/snowflake/statement.go:443 +0x7a fp=0xc00061dc60 
sp=0xc00061dc00 pc=0x7fc9c53b02da
   
github.com/apache/arrow-adbc/go/adbc/driver/snowflake.(*statement).ExecuteUpdate(0xc00050b200?,
 {0x7fc9c5ab74b8?, 0xc000cf64b0?})
        /adbc/go/adbc/driver/snowflake/statement.go:504 +0x2b6 fp=0xc00061dd80 
sp=0xc00061dc60 pc=0x7fc9c53b0b36
   main.SnowflakeStatementExecuteQuery(0x7fc9c3950e12?, 0x0, 0x7fff06a61ab8, 
0x7fff06a61af0)
        /adbc/go/adbc/pkg/snowflake/driver.go:1525 +0x18a fp=0xc00061de00 
sp=0xc00061dd80 pc=0x7fc9c53d250a
   _cgoexp_af66e644f38c_SnowflakeStatementExecuteQuery(0x7fff06a61a50)
        _cgo_gotypes.go:1090 +0x2a fp=0xc00061de30 sp=0xc00061de00 
pc=0x7fc9c53d608a
   runtime.cgocallbackg1(0x7fc9c53d6060, 0xc000605fe0?, 0x0)
        /usr/local/go/src/runtime/cgocall.go:399 +0x2c2 fp=0xc00061df00 
sp=0xc00061de30 pc=0x7fc9c394f2a2
   runtime.cgocallbackg(0x0?, 0x0?, 0x0?)
        /usr/local/go/src/runtime/cgocall.go:315 +0x125 fp=0xc00061df90 
sp=0xc00061df00 pc=0x7fc9c394ef45
   runtime.cgocallbackg(0x7fc9c53d6060, 0x7fff06a61a50, 0x0)
        <autogenerated>:1 +0x2b fp=0xc00061dfb8 sp=0xc00061df90 
pc=0x7fc9c39b61cb
   runtime.cgocallback(0x0, 0x0, 0x0)
        /usr/local/go/src/runtime/asm_amd64.s:1035 +0xcd fp=0xc00061dfe0 
sp=0xc00061dfb8 pc=0x7fc9c39b39ed
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc00061dfe8 
sp=0xc00061dfe0 pc=0x7fc9c39b3c41
   
   goroutine 2 [force gc (idle), 1 minutes]:
   runtime.gopark(0x0?, 0x0?, 0x0?, 0x0?, 0x0?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000062fa8 
sp=0xc000062f88 pc=0x7fc9c398458e
   runtime.goparkunlock(...)
        /usr/local/go/src/runtime/proc.go:404
   runtime.forcegchelper()
        /usr/local/go/src/runtime/proc.go:322 +0xb8 fp=0xc000062fe0 
sp=0xc000062fa8 pc=0x7fc9c3984418
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000062fe8 
sp=0xc000062fe0 pc=0x7fc9c39b3c41
   created by runtime.init.6 in goroutine 1
        /usr/local/go/src/runtime/proc.go:310 +0x1a
   
   goroutine 3 [GC sweep wait]:
   runtime.gopark(0x1?, 0x0?, 0x0?, 0x0?, 0x0?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000063778 
sp=0xc000063758 pc=0x7fc9c398458e
   runtime.goparkunlock(...)
        /usr/local/go/src/runtime/proc.go:404
   runtime.bgsweep(0x0?)
        /usr/local/go/src/runtime/mgcsweep.go:321 +0xdf fp=0xc0000637c8 
sp=0xc000063778 pc=0x7fc9c39700bf
   runtime.gcenable.func1()
        /usr/local/go/src/runtime/mgc.go:200 +0x25 fp=0xc0000637e0 
sp=0xc0000637c8 pc=0x7fc9c39651c5
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc0000637e8 
sp=0xc0000637e0 pc=0x7fc9c39b3c41
   created by runtime.gcenable in goroutine 1
        /usr/local/go/src/runtime/mgc.go:200 +0x66
   
   goroutine 4 [GC scavenge wait]:
   runtime.gopark(0x3b9bcff7?, 0x3b9aca00?, 0x0?, 0x0?, 0x0?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000063f70 
sp=0xc000063f50 pc=0x7fc9c398458e
   runtime.goparkunlock(...)
        /usr/local/go/src/runtime/proc.go:404
   runtime.(*scavengerState).park(0x7fc9c6c83000)
        /usr/local/go/src/runtime/mgcscavenge.go:425 +0x49 fp=0xc000063fa0 
sp=0xc000063f70 pc=0x7fc9c396d929
   runtime.bgscavenge(0x0?)
        /usr/local/go/src/runtime/mgcscavenge.go:658 +0x59 fp=0xc000063fc8 
sp=0xc000063fa0 pc=0x7fc9c396ded9
   runtime.gcenable.func2()
        /usr/local/go/src/runtime/mgc.go:201 +0x25 fp=0xc000063fe0 
sp=0xc000063fc8 pc=0x7fc9c3965165
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000063fe8 
sp=0xc000063fe0 pc=0x7fc9c39b3c41
   created by runtime.gcenable in goroutine 1
        /usr/local/go/src/runtime/mgc.go:201 +0xa5
   
   goroutine 5 [finalizer wait]:
   runtime.gopark(0x0?, 0xc00072f050?, 0xa0?, 0xa0?, 0x1000000010?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc00076ee20 
sp=0xc00076ee00 pc=0x7fc9c398458e
   runtime.runfinq()
        /usr/local/go/src/runtime/mfinal.go:193 +0x107 fp=0xc00076efe0 
sp=0xc00076ee20 pc=0x7fc9c39641e7
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc00076efe8 
sp=0xc00076efe0 pc=0x7fc9c39b3c41
   created by runtime.createfing in goroutine 1
        /usr/local/go/src/runtime/mfinal.go:163 +0x3d
   
   goroutine 7 [GC worker (idle)]:
   runtime.gopark(0x7fc9c6cb5e80?, 0x2?, 0x9e?, 0x1e?, 0x0?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000064f50 
sp=0xc000064f30 pc=0x7fc9c398458e
   runtime.gcBgMarkWorker()
        /usr/local/go/src/runtime/mgc.go:1295 +0xe5 fp=0xc000064fe0 
sp=0xc000064f50 pc=0x7fc9c3966d85
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000064fe8 
sp=0xc000064fe0 pc=0x7fc9c39b3c41
   created by runtime.gcBgMarkStartWorkers in goroutine 1
        /usr/local/go/src/runtime/mgc.go:1219 +0x1c
   
   goroutine 61 [select]:
   runtime.gopark(0xc000079f90?, 0x2?, 0xe0?, 0x9d?, 0xc000079f1c?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000079db8 
sp=0xc000079d98 pc=0x7fc9c398458e
   runtime.selectgo(0xc000079f90, 0xc000079f18, 0xc000130640?, 0x0, 
0xc000a23290?, 0x1)
        /usr/local/go/src/runtime/select.go:327 +0x725 fp=0xc000079ed8 
sp=0xc000079db8 pc=0x7fc9c3994065
   net/http.(*persistConn).writeLoop(0xc000b52240)
        /usr/local/go/src/net/http/transport.go:2421 +0xe5 fp=0xc000079fc8 
sp=0xc000079ed8 pc=0x7fc9c3edb065
   net/http.(*Transport).dialConn.func6()
        /usr/local/go/src/net/http/transport.go:1777 +0x25 fp=0xc000079fe0 
sp=0xc000079fc8 pc=0x7fc9c3ed7e65
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000079fe8 
sp=0xc000079fe0 pc=0x7fc9c39b3c41
   created by net/http.(*Transport).dialConn in goroutine 54
        /usr/local/go/src/net/http/transport.go:1777 +0x16f1
   
   goroutine 1073 [semacquire]:
   runtime.gopark(0x7fc9c398458e?, 0x7fc9744e9290?, 0xc0?, 0x7b?, 0xc000077db0?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000077d28 
sp=0xc000077d08 pc=0x7fc9c398458e
   runtime.goparkunlock(...)
        /usr/local/go/src/runtime/proc.go:404
   runtime.semacquire1(0xc00017eb50, 0x18?, 0x1, 0x0, 0x8b?)
        /usr/local/go/src/runtime/sema.go:160 +0x21c fp=0xc000077d90 
sp=0xc000077d28 pc=0x7fc9c399509c
   sync.runtime_Semacquire(0xc000b040a8?)
        /usr/local/go/src/runtime/sema.go:62 +0x25 fp=0xc000077dc8 
sp=0xc000077d90 pc=0x7fc9c39afe45
   sync.(*WaitGroup).Wait(0x7fc9c5a214a0?)
        /usr/local/go/src/sync/waitgroup.go:116 +0x48 fp=0xc000077df0 
sp=0xc000077dc8 pc=0x7fc9c39bb888
   golang.org/x/sync/errgroup.(*Group).Wait(0xc00017eb40)
        /root/go/pkg/mod/golang.org/x/sync@v0.7.0/errgroup/errgroup.go:56 +0x25 
fp=0xc000077e10 sp=0xc000077df0 pc=0x7fc9c4041085
   
github.com/apache/arrow-adbc/go/adbc/driver/snowflake.runParallelParquetWriters({0x7fc9c5ab74b8,
 0xc000cf6be0}, 0xc00095a000, 0xa00000, 0xc0009b2200?, 0xc0004f0210, 
{{0x7fc9c5aad3e0, 0xc0006ba9f8}, 0x0, 0x0, ...}, ...)
        /adbc/go/adbc/driver/snowflake/bulk_ingestion.go:392 +0x345 
fp=0xc000077eb0 sp=0xc000077e10 pc=0x7fc9c5395065
   
github.com/apache/arrow-adbc/go/adbc/driver/snowflake.(*statement).ingestStream.func4()
        /adbc/go/adbc/driver/snowflake/bulk_ingestion.go:257 +0x125 
fp=0xc000077f78 sp=0xc000077eb0 pc=0x7fc9c5393fe5
   golang.org/x/sync/errgroup.(*Group).Go.func1()
        /root/go/pkg/mod/golang.org/x/sync@v0.7.0/errgroup/errgroup.go:78 +0x56 
fp=0xc000077fe0 sp=0xc000077f78 pc=0x7fc9c40411f6
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000077fe8 
sp=0xc000077fe0 pc=0x7fc9c39b3c41
   created by golang.org/x/sync/errgroup.(*Group).Go in goroutine 17
        /root/go/pkg/mod/golang.org/x/sync@v0.7.0/errgroup/errgroup.go:75 +0x96
   
   goroutine 60 [IO wait]:
   runtime.gopark(0xecee7dc0e3e227f4?, 0xb?, 0x0?, 0x0?, 0x3?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc0000785c8 
sp=0xc0000785a8 pc=0x7fc9c398458e
   runtime.netpollblock(0x7fc9c39c9818?, 0xc394e2c6?, 0xc9?)
        /usr/local/go/src/runtime/netpoll.go:564 +0xf7 fp=0xc000078600 
sp=0xc0000785c8 pc=0x7fc9c397cbf7
   internal/poll.runtime_pollWait(0x7fc9c00636d0, 0x72)
        /usr/local/go/src/runtime/netpoll.go:343 +0x85 fp=0xc000078620 
sp=0xc000078600 pc=0x7fc9c39ae445
   internal/poll.(*pollDesc).wait(0xc00044ae80?, 0xc00084c000?, 0x0)
        /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0x27 
fp=0xc000078648 sp=0xc000078620 pc=0x7fc9c3a258c7
   internal/poll.(*pollDesc).waitRead(...)
        /usr/local/go/src/internal/poll/fd_poll_runtime.go:89
   internal/poll.(*FD).Read(0xc00044ae80, {0xc00084c000, 0x8000, 0x8000})
        /usr/local/go/src/internal/poll/fd_unix.go:164 +0x27a fp=0xc0000786e0 
sp=0xc000078648 pc=0x7fc9c3a26bba
   net.(*netFD).Read(0xc00044ae80, {0xc00084c000?, 0xc00084c00d?, 0x4cf?})
        /usr/local/go/src/net/fd_posix.go:55 +0x25 fp=0xc000078728 
sp=0xc0000786e0 pc=0x7fc9c3de8945
   net.(*conn).Read(0xc000160790, {0xc00084c000?, 0x7ff3?, 0xc00084c005?})
        /usr/local/go/src/net/net.go:179 +0x45 fp=0xc000078770 sp=0xc000078728 
pc=0x7fc9c3df9065
   net.(*TCPConn).Read(0xc000078808?, {0xc00084c000?, 0xc0007ec390?, 0x18?})
        <autogenerated>:1 +0x25 fp=0xc0000787a0 sp=0xc000078770 
pc=0x7fc9c3e0bca5
   crypto/tls.(*atLeastReader).Read(0xc0007ec390, {0xc00084c000?, 
0xc0007ec390?, 0x0?})
        /usr/local/go/src/crypto/tls/conn.go:805 +0x3b fp=0xc0000787e8 
sp=0xc0000787a0 pc=0x7fc9c3e4abbb
   bytes.(*Buffer).ReadFrom(0xc0001290a8, {0x7fc9c5a9c840, 0xc0007ec390})
        /usr/local/go/src/bytes/buffer.go:211 +0x98 fp=0xc000078840 
sp=0xc0000787e8 pc=0x7fc9c3a499b8
   crypto/tls.(*Conn).readFromUntil(0xc000128e00, {0x7fc9c5a9ba20?, 
0xc000160790}, 0x8000?)
        /usr/local/go/src/crypto/tls/conn.go:827 +0xde fp=0xc000078880 
sp=0xc000078840 pc=0x7fc9c3e4ad9e
   crypto/tls.(*Conn).readRecordOrCCS(0xc000128e00, 0x0)
        /usr/local/go/src/crypto/tls/conn.go:625 +0x250 fp=0xc000078c20 
sp=0xc000078880 pc=0x7fc9c3e48370
   crypto/tls.(*Conn).readRecord(...)
        /usr/local/go/src/crypto/tls/conn.go:587
   crypto/tls.(*Conn).Read(0xc000128e00, {0xc000729000, 0x1000, 0x2c?})
        /usr/local/go/src/crypto/tls/conn.go:1369 +0x158 fp=0xc000078c90 
sp=0xc000078c20 pc=0x7fc9c3e4e638
   net/http.(*persistConn).Read(0xc000b52240, {0xc000729000?, 0xc0004f2e40?, 
0xc000078d38?})
        /usr/local/go/src/net/http/transport.go:1954 +0x4a fp=0xc000078cf0 
sp=0xc000078c90 pc=0x7fc9c3ed88aa
   bufio.(*Reader).fill(0xc0009796e0)
        /usr/local/go/src/bufio/bufio.go:113 +0x103 fp=0xc000078d28 
sp=0xc000078cf0 pc=0x7fc9c3ba5b83
   bufio.(*Reader).Peek(0xc0009796e0, 0x1)
        /usr/local/go/src/bufio/bufio.go:151 +0x53 fp=0xc000078d48 
sp=0xc000078d28 pc=0x7fc9c3ba5cb3
   net/http.(*persistConn).readLoop(0xc000b52240)
        /usr/local/go/src/net/http/transport.go:2118 +0x1b9 fp=0xc000078fc8 
sp=0xc000078d48 pc=0x7fc9c3ed9699
   net/http.(*Transport).dialConn.func5()
        /usr/local/go/src/net/http/transport.go:1776 +0x25 fp=0xc000078fe0 
sp=0xc000078fc8 pc=0x7fc9c3ed7ec5
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000078fe8 
sp=0xc000078fe0 pc=0x7fc9c39b3c41
   created by net/http.(*Transport).dialConn in goroutine 54
        /usr/local/go/src/net/http/transport.go:1776 +0x169f
   
   goroutine 39 [IO wait, 1 minutes]:
   runtime.gopark(0x1?, 0xb?, 0x0?, 0x0?, 0x5?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000a32ab8 
sp=0xc000a32a98 pc=0x7fc9c398458e
   runtime.netpollblock(0x7fc9c39c9818?, 0xc394e2c6?, 0xc9?)
        /usr/local/go/src/runtime/netpoll.go:564 +0xf7 fp=0xc000a32af0 
sp=0xc000a32ab8 pc=0x7fc9c397cbf7
   internal/poll.runtime_pollWait(0x7fc9c00634e0, 0x72)
        /usr/local/go/src/runtime/netpoll.go:343 +0x85 fp=0xc000a32b10 
sp=0xc000a32af0 pc=0x7fc9c39ae445
   internal/poll.(*pollDesc).wait(0xc00044a700?, 0xc0009ed000?, 0x0)
        /usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0x27 
fp=0xc000a32b38 sp=0xc000a32b10 pc=0x7fc9c3a258c7
   internal/poll.(*pollDesc).waitRead(...)
        /usr/local/go/src/internal/poll/fd_poll_runtime.go:89
   internal/poll.(*FD).Read(0xc00044a700, {0xc0009ed000, 0x1000, 0x1000})
        /usr/local/go/src/internal/poll/fd_unix.go:164 +0x27a fp=0xc000a32bd0 
sp=0xc000a32b38 pc=0x7fc9c3a26bba
   net.(*netFD).Read(0xc00044a700, {0xc0009ed000?, 0x7fc9c3ed25e0?, 
0x7fc9c6bb8760?})
        /usr/local/go/src/net/fd_posix.go:55 +0x25 fp=0xc000a32c18 
sp=0xc000a32bd0 pc=0x7fc9c3de8945
   net.(*conn).Read(0xc000160120, {0xc0009ed000?, 0x0?, 0xc00044d860?})
        /usr/local/go/src/net/net.go:179 +0x45 fp=0xc000a32c60 sp=0xc000a32c18 
pc=0x7fc9c3df9065
   net.(*TCPConn).Read(0x4?, {0xc0009ed000?, 0x7fc9c39505fa?, 0x0?})
        <autogenerated>:1 +0x25 fp=0xc000a32c90 sp=0xc000a32c60 
pc=0x7fc9c3e0bca5
   net/http.(*persistConn).Read(0xc0004c4240, {0xc0009ed000?, 0xc000103860?, 
0xc000a32d38?})
        /usr/local/go/src/net/http/transport.go:1954 +0x4a fp=0xc000a32cf0 
sp=0xc000a32c90 pc=0x7fc9c3ed88aa
   bufio.(*Reader).fill(0xc000978b40)
        /usr/local/go/src/bufio/bufio.go:113 +0x103 fp=0xc000a32d28 
sp=0xc000a32cf0 pc=0x7fc9c3ba5b83
   bufio.(*Reader).Peek(0xc000978b40, 0x1)
        /usr/local/go/src/bufio/bufio.go:151 +0x53 fp=0xc000a32d48 
sp=0xc000a32d28 pc=0x7fc9c3ba5cb3
   net/http.(*persistConn).readLoop(0xc0004c4240)
        /usr/local/go/src/net/http/transport.go:2118 +0x1b9 fp=0xc000a32fc8 
sp=0xc000a32d48 pc=0x7fc9c3ed9699
   net/http.(*Transport).dialConn.func5()
        /usr/local/go/src/net/http/transport.go:1776 +0x25 fp=0xc000a32fe0 
sp=0xc000a32fc8 pc=0x7fc9c3ed7ec5
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000a32fe8 
sp=0xc000a32fe0 pc=0x7fc9c39b3c41
   created by net/http.(*Transport).dialConn in goroutine 35
        /usr/local/go/src/net/http/transport.go:1776 +0x169f
   
   goroutine 40 [select, 1 minutes]:
   runtime.gopark(0xc000076f90?, 0x2?, 0xe0?, 0x6d?, 0xc000076f1c?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000076db8 
sp=0xc000076d98 pc=0x7fc9c398458e
   runtime.selectgo(0xc000076f90, 0xc000076f18, 0xc0004cd9c0?, 0x0, 
0xc00043c090?, 0x1)
        /usr/local/go/src/runtime/select.go:327 +0x725 fp=0xc000076ed8 
sp=0xc000076db8 pc=0x7fc9c3994065
   net/http.(*persistConn).writeLoop(0xc0004c4240)
        /usr/local/go/src/net/http/transport.go:2421 +0xe5 fp=0xc000076fc8 
sp=0xc000076ed8 pc=0x7fc9c3edb065
   net/http.(*Transport).dialConn.func6()
        /usr/local/go/src/net/http/transport.go:1777 +0x25 fp=0xc000076fe0 
sp=0xc000076fc8 pc=0x7fc9c3ed7e65
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000076fe8 
sp=0xc000076fe0 pc=0x7fc9c39b3c41
   created by net/http.(*Transport).dialConn in goroutine 35
        /usr/local/go/src/net/http/transport.go:1777 +0x16f1
   
   goroutine 53 [select, 1 minutes]:
   runtime.gopark(0xc000a30f88?, 0x2?, 0x0?, 0x0?, 0xc000a30f84?)
        /usr/local/go/src/runtime/proc.go:398 +0xce fp=0xc000a30e30 
sp=0xc000a30e10 pc=0x7fc9c398458e
   runtime.selectgo(0xc000a30f88, 0xc000a30f80, 0x0?, 0x0, 0x0?, 0x1)
        /usr/local/go/src/runtime/select.go:327 +0x725 fp=0xc000a30f50 
sp=0xc000a30e30 pc=0x7fc9c3994065
   database/sql.(*DB).connectionOpener(0xc0006cde10, {0x7fc9c5ab74b8, 
0xc000a180a0})
        /usr/local/go/src/database/sql/sql.go:1218 +0x87 fp=0xc000a30fb8 
sp=0xc000a30f50 pc=0x7fc9c3d31d67
   database/sql.OpenDB.func1()
        /usr/local/go/src/database/sql/sql.go:791 +0x28 fp=0xc000a30fe0 
sp=0xc000a30fb8 pc=0x7fc9c3d303a8
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000a30fe8 
sp=0xc000a30fe0 pc=0x7fc9c39b3c41
   created by database/sql.OpenDB in goroutine 17
        /usr/local/go/src/database/sql/sql.go:791 +0x165
   
   goroutine 1074 [preempted (scan)]:
   runtime.semrelease1(0x7fc9c6c844d8?, 0x0, 0x0)
        /usr/local/go/src/runtime/sema.go:175 +0x1e9 fp=0xc0007170c8 
sp=0xc0007170c0 pc=0x7fc9c39953c9
   runtime.semrelease(...)
        /usr/local/go/src/runtime/sema.go:172
   runtime.gcStart({0xc006584000?, 0xb18000?, 0xb178c0?})
        /usr/local/go/src/runtime/mgc.go:775 +0x48d fp=0xc000717160 
sp=0xc0007170c8 pc=0x7fc9c3965a4d
   runtime.mallocgc(0xb178c0, 0x7fc9c5890880, 0x1)
        /usr/local/go/src/runtime/malloc.go:1246 +0x76f fp=0xc0007171c8 
sp=0xc000717160 pc=0x7fc9c3957e2f
   runtime.makeslice(0x0?, 0x0?, 0x0?)
        /usr/local/go/src/runtime/slice.go:103 +0x49 fp=0xc0007171f0 
sp=0xc0007171c8 pc=0x7fc9c3998a09
   github.com/apache/arrow/go/v17/parquet/pqarrow.writeDenseArrow(0xc00056eaa0, 
{0x7fc9c5ae0d30?, 0xc000002600}, {0x7fc9c5ada2f8, 0xc000a9e870?}, 
{0xc005212000, 0x76508, 0x100000}, {0x0, 0x0, ...}, ...)
        
/root/go/pkg/mod/github.com/apache/arrow/go/v17@v17.0.0-20240626234237-6680dcfbef42/parquet/pqarrow/encode_arrow.go:486
 +0x2225 fp=0xc0007177d0 sp=0xc0007171f0 pc=0x7fc9c47c1c05
   
github.com/apache/arrow/go/v17/parquet/pqarrow.WriteArrowToColumn({0x7fc9c5ab7480,
 0xc000a221e0}, {0x7fc9c5ae0d30, 0xc000002600}, {0x7fc9c5ada2f8?, 
0xc000a9e870?}, {0xc005212000, 0x76508, 0x100000}, {0x0, ...}, ...)
        
/root/go/pkg/mod/github.com/apache/arrow/go/v17@v17.0.0-20240626234237-6680dcfbef42/parquet/pqarrow/encode_arrow.go:232
 +0x32f fp=0xc0007178a0 sp=0xc0007177d0 pc=0x7fc9c47bf8af
   
github.com/apache/arrow/go/v17/parquet/pqarrow.(*arrowColumnWriter).Write(0xc0008e3b08,
 {0x7fc9c5ab7480, 0xc000a221e0})
        
/root/go/pkg/mod/github.com/apache/arrow/go/v17@v17.0.0-20240626234237-6680dcfbef42/parquet/pqarrow/encode_arrow.go:193
 +0x4f3 fp=0xc000717ad0 sp=0xc0007178a0 pc=0x7fc9c47bf313
   
github.com/apache/arrow/go/v17/parquet/pqarrow.(*FileWriter).WriteColumnChunked(0xc000156000,
 0x7fc9c6cb4020?, 0xc0008e3bd8?, 0x1?)
        
/root/go/pkg/mod/github.com/apache/arrow/go/v17@v17.0.0-20240626234237-6680dcfbef42/parquet/pqarrow/file_writer.go:330
 +0xe5 fp=0xc000717b88 sp=0xc000717ad0 pc=0x7fc9c47c6a05
   
github.com/apache/arrow/go/v17/parquet/pqarrow.(*FileWriter).WriteColumnData(0xc000156000?,
 {0x7fc9c5ada2f8, 0xc000cf7db0})
        
/root/go/pkg/mod/github.com/apache/arrow/go/v17@v17.0.0-20240626234237-6680dcfbef42/parquet/pqarrow/file_writer.go:339
 +0xc9 fp=0xc000717c10 sp=0xc000717b88 pc=0x7fc9c47c6b29
   
github.com/apache/arrow/go/v17/parquet/pqarrow.(*FileWriter).WriteBuffered(0xc000156000,
 {0x7fc9c5ad7ee0, 0xc000a232f0})
        
/root/go/pkg/mod/github.com/apache/arrow/go/v17@v17.0.0-20240626234237-6680dcfbef42/parquet/pqarrow/file_writer.go:203
 +0x3e5 fp=0xc000717d90 sp=0xc000717c10 pc=0x7fc9c47c6545
   
github.com/apache/arrow-adbc/go/adbc/driver/snowflake.writeParquet(0xc000060f00?,
 {0x7fc9c5a99a88?, 0xc000a22000}, 0xc0006ba9f8?, 0xa00000, 0x0?, 
{{0x7fc9c5aad3e0, 0xc0006ba9f8}, 0x0, 0x0, ...})
        /adbc/go/adbc/driver/snowflake/bulk_ingestion.go:345 +0x1cb 
fp=0xc000717e78 sp=0xc000717d90 pc=0x7fc9c5394b4b
   
github.com/apache/arrow-adbc/go/adbc/driver/snowflake.runParallelParquetWriters.func3()
        /adbc/go/adbc/driver/snowflake/bulk_ingestion.go:409 +0x185 
fp=0xc000717f78 sp=0xc000717e78 pc=0x7fc9c53952a5
   golang.org/x/sync/errgroup.(*Group).Go.func1()
        /root/go/pkg/mod/golang.org/x/sync@v0.7.0/errgroup/errgroup.go:78 +0x56 
fp=0xc000717fe0 sp=0xc000717f78 pc=0x7fc9c40411f6
   runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1650 +0x1 fp=0xc000717fe8 
sp=0xc000717fe0 pc=0x7fc9c39b3c41
   created by golang.org/x/sync/errgroup.(*Group).Go in goroutine 1073
        /root/go/pkg/mod/golang.org/x/sync@v0.7.0/errgroup/errgroup.go:75 +0x96
   Fatal Python error: Aborted
   
   Thread 0x00007fc9e58d3b80 (most recent call first):
     File "/.venv/lib/python3.12/site-packages/adbc_driver_manager/dbapi.py", 
line 937 in adbc_ingest
     File "/.venv/lib/python3.12/site-packages/polars/dataframe/frame.py", line 
3817 in write_database
     File "/home/appuser/app/db.py", line 76 in push_inserts_to_snowflake
     File "/home/appuser/app/main.py", line 103 in job
     File "/.venv/lib/python3.12/site-packages/tenacity/__init__.py", line 478 
in __call__
     File "/.venv/lib/python3.12/site-packages/tenacity/__init__.py", line 336 
in wrapped_f
     File "/home/appuser/app/main.py", line 38 in job_monthly
     File "/home/appuser/app/main.py", line 231 in job_monthly_once
     File "/.venv/lib/python3.12/site-packages/schedule/__init__.py", line 691 
in run
     File "/.venv/lib/python3.12/site-packages/schedule/__init__.py", line 173 
in _run_job
     File "/.venv/lib/python3.12/site-packages/schedule/__init__.py", line 101 
in run_pending
     File "/.venv/lib/python3.12/site-packages/schedule/__init__.py", line 854 
in run_pending
     File "/home/appuser/app/main.py", line 264 in main
     File "/home/appuser/app/main.py", line 285 in <module>
   
   Extension modules: yaml._yaml, adbc_driver_manager._lib, 
numpy._core._multiarray_umath, numpy.linalg._umath_linalg, pyarrow.lib, 
pyarrow._compute, pyarrow._acero, pyarrow._fs, pyarrow._csv, pyarrow._json, 
numpy.random._common, numpy.random.bit_generator, 
numpy.random._bounded_integers, numpy.random._mt19937, numpy.random.mtrand, 
numpy.random._philox, numpy.random._pcg64, numpy.random._sfc64, 
numpy.random._generator, pandas._libs.tslibs.ccalendar, 
pandas._libs.tslibs.np_datetime, pandas._libs.tslibs.dtypes, 
pandas._libs.tslibs.base, pandas._libs.tslibs.nattype, 
pandas._libs.tslibs.timezones, pandas._libs.tslibs.fields, 
pandas._libs.tslibs.timedeltas, pandas._libs.tslibs.tzconversion, 
pandas._libs.tslibs.timestamps, pandas._libs.properties, 
pandas._libs.tslibs.offsets, pandas._libs.tslibs.strptime, 
pandas._libs.tslibs.parsing, pandas._libs.tslibs.conversion, 
pandas._libs.tslibs.period, pandas._libs.tslibs.vectorized, 
pandas._libs.ops_dispatch, pandas._libs.missing, pandas._libs.hash
 table, pandas._libs.algos, pandas._libs.interval, pandas._libs.lib, 
pandas._libs.ops, pandas._libs.hashing, pandas._libs.arrays, 
pandas._libs.tslib, pandas._libs.sparse, pandas._libs.internals, 
pandas._libs.indexing, pandas._libs.index, pandas._libs.writers, 
pandas._libs.join, pandas._libs.window.aggregations, 
pandas._libs.window.indexers, pandas._libs.reshape, pandas._libs.groupby, 
pandas._libs.json, pandas._libs.parsers, pandas._libs.testing, 
pyarrow._dataset, pyarrow._dataset_orc, pyarrow._parquet, 
pyarrow._parquet_encryption, pyarrow._dataset_parquet_encryption, 
pyarrow._dataset_parquet, adbc_driver_manager._reader, 
sqlalchemy.cyextension.collections, sqlalchemy.cyextension.immutabledict, 
sqlalchemy.cyextension.processors, sqlalchemy.cyextension.resultproxy, 
sqlalchemy.cyextension.util, greenlet._greenlet, pyodbc (total: 73)
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@arrow.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to