nmorenor commented on issue #1381:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1381#issuecomment-2816840482
I still see this same issue, with a similar case from the description of
this issue.
panic({0x104fb5780?, 0x1054f4a90?})
/opt/homebrew/Cellar/go/1.24.1/libexec/src/runtime/panic.go:792 +0xf0
github.com/gocql/gocql.(*queryMetrics).attempt(0x0, 0x1, 0x11351d,
0x14000178300, 0x0)
/Users/nacho/go/pkg/mod/github.com/gocql/gocql@v1.7.0/session.go:883
+0x38
github.com/gocql/gocql.(*Query).attempt(0x140004f0a00, {0x140000cb4f0, 0x6},
{0xc1f91c174d5f3f90, 0xdbfb9277, 0x105553ae0}, {0xc1f91c174d4e0950, 0xdbea5d5a,
0x105553ae0}, 0x140000ebc20, ...)
/Users/nacho/go/pkg/mod/github.com/gocql/gocql@v1.7.0/session.go:1116
+0xac
github.com/gocql/gocql.(*queryExecutor).attemptQuery(0x1400048a360,
{0x1050ae040, 0x10557d340}, {0x1050b11d0, 0x140004f0a00}, 0x140004f0000)
/Users/nacho/go/pkg/mod/github.com/gocql/gocql@v1.7.0/query_executor.go:60 +0xfc
github.com/gocql/gocql.(*queryExecutor).do(0x1400048a360, {0x1050ae040,
0x10557d340}, {0x1050b11d0, 0x140004f0a00}, 0x140000cf780)
/Users/nacho/go/pkg/mod/github.com/gocql/gocql@v1.7.0/query_executor.go:154
+0x17c
github.com/gocql/gocql.(*queryExecutor).executeQuery(0x1400048a360,
{0x1050b11d0, 0x140004f0a00})
/Users/nacho/go/pkg/mod/github.com/gocql/gocql@v1.7.0/query_executor.go:92
+0x11c
github.com/gocql/gocql.(*Session).executeQuery(0x140004cc408, 0x140004f0a00)
/Users/nacho/go/pkg/mod/github.com/gocql/gocql@v1.7.0/session.go:546
+0x11c
github.com/gocql/gocql.(*Query).Iter(0x140004f0a00)
/Users/nacho/go/pkg/mod/github.com/gocql/gocql@v1.7.0/session.go:1318
+0x174
github.com/scylladb/gocqlx/v3.(*Queryx).Iter(0x140008602d0)
I have a for look that is inserting a row on a table, after save I call a
function with `go` to start a go routine where inside I query other table,
process some data and then save the same table that called the `go` routine. I
get this on the first read.
my code is like
```
for _, myDto := range myDtos {
handler.save(myDto)
}
```
handler save looks like
```
session := getSession(ctx)
q = myTable.InsertQuery(session).BindStruct(myDto)
defer q.Release()
err = q.ExecRelease()
go saveEventHandler.publish(&myEvent{
dto: myDto
}
```
saveHandler
```
session := getSession(ctx)
query :=
session.Query(repo.myMetaDataTable.SelectAll()).PageSize(200).PageState([]byte{})
defer query.Release()
metadatas := []*venueModels.VenueMetadata{}
iter := query.Iter()
```
iter := query.Iter() triggers the issue, have this behavior all the time.
the handler save method first store the data on the table and start the `go`
routine, if after handler.save(myDto) I add a `time.Sleep(1 * time.Second)`
error goes away.
--
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: commits-unsubscr...@cassandra.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
