DEBUG: Add more Cassandra log
@@ -34,6 +34,7 @@ import (
persistencespb "go.temporal.io/server/api/persistence/v1"
"go.temporal.io/server/common/log"
+ "go.temporal.io/server/common/log/tag"
p "go.temporal.io/server/common/persistence"
"go.temporal.io/server/common/persistence/serialization"
"go.temporal.io/server/common/primitives"
@@ -84,7 +85,10 @@ func newHistoryPersistence(
logger log.Logger,
) (p.HistoryStore, error) {
return &cassandraHistoryV2Persistence{
- cassandraStore: cassandraStore{session: session, logger: logger},
+ cassandraStore: cassandraStore{
+ session: session,
+ logger: logger,
+ },
}, nil
}
@@ -122,6 +126,7 @@ func (h *cassandraHistoryV2Persistence) AppendHistoryNodes(
batch.Query(v2templateUpsertData,
branchInfo.TreeId, branchInfo.BranchId, request.NodeID, request.TransactionID, request.Events.Data, request.Events.EncodingType.String())
err = h.session.ExecuteBatch(batch)
+ h.logger.Info(fmt.Sprintf("####### BATCH QUERY: %v", prettyPrint(batch.Entries)), tag.Error(err))
} else {
query := h.session.Query(v2templateUpsertData,
branchInfo.TreeId, branchInfo.BranchId, request.NodeID, request.TransactionID, request.Events.Data, request.Events.EncodingType.String())
