From 59d0259067bc7becd7d2cbbba83284f52dc36e51 Mon Sep 17 00:00:00 2001 From: w41ter Date: Tue, 4 Jun 2024 10:52:05 +0800 Subject: [PATCH] Log snapshot meta size --- pkg/ccr/job.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pkg/ccr/job.go b/pkg/ccr/job.go index 8664c922..40662962 100644 --- a/pkg/ccr/job.go +++ b/pkg/ccr/job.go @@ -361,6 +361,9 @@ func (j *Job) fullSync() error { jobInfo := snapshotResp.GetJobInfo() tableCommitSeqMap := inMemoryData.TableCommitSeqMap + log.Infof("snapshot response meta size: %d, job info size: %d", + len(snapshotResp.Meta), len(snapshotResp.JobInfo)) + var jobInfoMap map[string]interface{} err := json.Unmarshal(jobInfo, &jobInfoMap) if err != nil { @@ -379,7 +382,7 @@ func (j *Job) fullSync() error { if err != nil { return xerror.Errorf(xerror.Normal, "marshal jobInfo failed, jobInfo: %v", jobInfoMap) } - log.Debugf("jobInfoBytes: %s", string(jobInfoBytes)) + log.Debugf("job info size: %d, bytes: %s", len(jobInfoBytes), string(jobInfoBytes)) snapshotResp.SetJobInfo(jobInfoBytes) var commitSeq int64 = math.MaxInt64