wip

Signed-off-by: Ping Yu <yuping@pingcap.com>
tikv · Mar 2, 2024 · 3d406b3 · 3d406b3
1 parent e3addb4
commit 3d406b3
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 5 deletions.
diff --git a/cdc/cdc/sink/mq.go b/cdc/cdc/sink/mq.go
@@ -268,7 +268,7 @@ func (k *mqSink) runWorker(ctx context.Context, partition int32) error {
 					return 0, err
 				}
 			}
-			log.Debug("MQSink flushed", zap.Int("thisBatchSize", thisBatchSize))
+			log.Info("MQSink flushed", zap.Int("thisBatchSize", thisBatchSize))
 			return thisBatchSize, nil
 		})
 	}

diff --git a/cdc/tests/integration_tests/_utils/test_prepare b/cdc/tests/integration_tests/_utils/test_prepare
@@ -80,6 +80,7 @@ function on_exit() {
 		return 0
 	else
 		echo "Error $STATUS_CODE occurred on $LINE for sink $SINK_TYPE"
-		tail -n +1 "$WORK_DIR"/cdc*.log
+		# CI env already collect "*.log". Uncomment it for other envs.
+		# tail -n +1 "$WORK_DIR"/cdc*.log
 	fi
 }
diff --git a/cdc/tests/integration_tests/flow_control/config/workload b/cdc/tests/integration_tests/flow_control/config/workload
@@ -22,7 +22,7 @@
 #   Default data size: 1 KB records (10 fields, 100 bytes each, plus key)
 #   Request distribution: zipfian
 
-recordcount=5000000
+recordcount=2000000
 workload=core
 
 readallfields=true
@@ -35,4 +35,4 @@ insertproportion=0
 requestdistribution=uniform
 
 fieldcount=1
-fieldlength=100
+fieldlength=250
diff --git a/cdc/tests/integration_tests/flow_control/run.sh b/cdc/tests/integration_tests/flow_control/run.sh
@@ -19,7 +19,7 @@ function run() {
 	cd $WORK_DIR
 
 	start_ts=$(get_start_ts $UP_PD)
-	go-ycsb load tikv -P $CUR/config/workload -p tikv.pd="$UP_PD" -p tikv.type="raw" -p tikv.apiversion=V2 --threads 100 # About 500MiB
+	go-ycsb load tikv -P $CUR/config/workload -p tikv.pd="$UP_PD" -p tikv.type="raw" -p tikv.apiversion=V2 --threads 200 # About 500MiB
 
 	cat - >"$WORK_DIR/tikv-cdc-config.toml" <<EOF
 per-changefeed-memory-quota=10485760 #10M