address comment

pingcap · Oct 18, 2021 · 700a0b5 · 700a0b5
1 parent c32c4cb
commit 700a0b5
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/relay/relay.go b/relay/relay.go
@@ -128,7 +128,7 @@ func NewRealRelay(cfg *Config) Process {
 }
 
 // Init implements the dm.Unit interface.
-// NOTE these errors will make DM-worker exit when it boots up and assigned relay.
+// NOTE when Init encounters an error, it will make DM-worker exit when it boots up and assigned relay.
 func (r *Relay) Init(ctx context.Context) (err error) {
 	return reportRelayLogSpaceInBackground(ctx, r.cfg.RelayDir)
 }

diff --git a/tests/new_relay/run.sh b/tests/new_relay/run.sh
@@ -34,8 +34,6 @@ function test_cant_dail_upstream() {
 
 	# make sure DM-worker doesn't exit
 	sleep 2
-	check_rpc_alive $cur/../bin/check_worker_online 127.0.0.1:$WORKER1_PORT
-
 	run_dm_ctl_with_retry $WORK_DIR "127.0.0.1:$MASTER_PORT" \
 		"query-status -s $SOURCE_ID1" \
 		"injected error" 1