dkropachev commented on issue #1884:
URL:
https://github.com/apache/cassandra-gocql-driver/issues/1884#issuecomment-2828307732
It happens because attempts are storred on query struct, if you change your
code from:
```
for i := 0; i <= workers; i++ {
wg.Add(1)
go func() {
defer wg.Done()
query := session.Query("insert into k8stest.test (a, b)
values (?,?)")
for j := i * queries; j < (i+1)*queries; j++ {
query.Bind(j, "Message"+strconv.Itoa(j))
if err := query.Exec(); err != nil {
panic(err)
}
}
query.Release()
}()
}
```
To:
```
for i := 0; i <= workers; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for j := i * queries; j < (i+1)*queries; j++ {
query := session.Query("insert into
k8stest.test (a, b) values (?,?)")
query.Bind(j, "Message"+strconv.Itoa(j))
if err := query.Exec(); err != nil {
panic(err)
}
}
query.Release()
}()
}
```
It should work.
I am not saying it is right, but it just how it is.
--
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
