workload/changefeeds: add more logs

Author: wenyihu6

pkg/workload/changefeeds/BUILD.bazel

@@ -7,6 +7,7 @@ go_library(
     visibility = ["//visibility:public"],
     deps = [
         "//pkg/util/hlc",
+        "//pkg/util/log",
         "//pkg/util/timeutil",
         "//pkg/workload",
         "//pkg/workload/histogram",

pkg/workload/changefeeds/changefeeds.go

@@ -9,10 +9,12 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"strconv"
 	"strings"
 	"time"
 
 	"github.com/cockroachdb/cockroach/pkg/util/hlc"
+	"github.com/cockroachdb/cockroach/pkg/util/log"
 	"github.com/cockroachdb/cockroach/pkg/util/timeutil"
 	"github.com/cockroachdb/cockroach/pkg/workload"
 	"github.com/cockroachdb/cockroach/pkg/workload/histogram"
@@ -84,6 +86,8 @@ func AddChangefeedToQueryLoad(
 		return err
 	}
 
+	log.Dev.Infof(ctx, "cursor: %s", cursorStr)
+
 	tableNames := strings.Builder{}
 	for i, table := range gen.Tables() {
 		if i == 0 {
@@ -127,6 +131,11 @@ func AddChangefeedToQueryLoad(
 		if rows != nil {
 			return false
 		}
+		log.Dev.Infof(ctx, "creating changefeed with stmt: %s with args %v", stmt, args)
+		if epoch, parseErr := strconv.ParseInt(cursorStr, 10, 64); parseErr == nil {
+			t := time.Unix(epoch, 0).UTC()
+			log.Dev.Infof(ctx, "starting a changefeed after %s", time.Since(t))
+		}
 		var err error
 		rows, err = conn.Query(cfCtx, stmt, args...)
 		return maybeMarkDone(err)