Update pkg/cassandra/config/config.go

Co-authored-by: Yuri Shkuro <[email protected]> Signed-off-by: Alok Kumar Singh <[email protected]>
jaegertracing · Nov 26, 2024 · 57349a8 · 57349a8
1 parent 73d276a
commit 57349a8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/cassandra/config/config.go b/pkg/cassandra/config/config.go
@@ -190,7 +190,9 @@ func createSession(c *Configuration) (cassandra.Session, error) {
 }
 
 // newSessionPrerequisites creates tables and types before creating a session
-func newSessionPrerequisites(c Configuration) error {
+func (c *Configuration) newSessionPrerequisites() error {
+  cfg := *c // clone because we need to connect without specifying a keyspace
+  cfg.Schema.Keyspace = ""
 	if !c.Schema.CreateSchema {
 		return nil
 	}