nmorenor opened a new issue, #1883:
URL: https://github.com/apache/cassandra-gocql-driver/issues/1883

   **What version of Cassandra are you using?**
   
   using Cassandra 5.0.3
   using Scylla 2025.1
   
   **What version of Gocql are you using?**
   
   1.7
   
   **Description**
   
   I have similar setup like #1381 
   
   These are my specifics:
   
   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.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

Reply via email to