diff --git a/cdc/model/changefeed_test.go b/cdc/model/changefeed_test.go
index c23b9b9609d..db137be82af 100644
--- a/cdc/model/changefeed_test.go
+++ b/cdc/model/changefeed_test.go
@@ -149,8 +149,8 @@ func TestFillV1(t *testing.T) {
 			},
 			Sink: &config.SinkConfig{
 				DispatchRules: []*config.DispatchRule{
-					{Matcher: []string{"test.tbl3"}, PartitionRule: "ts"},
-					{Matcher: []string{"test.tbl4"}, PartitionRule: "rowid"},
+					{Matcher: []string{"test.tbl3"}, DispatcherRule: "ts"},
+					{Matcher: []string{"test.tbl4"}, DispatcherRule: "rowid"},
 				},
 			},
 			Cyclic: &config.CyclicConfig{
diff --git a/cdc/sink/mysql/txn_cache.go b/cdc/sink/mysql/txn_cache.go
index 8fa1a2227b6..e084decaf12 100644
--- a/cdc/sink/mysql/txn_cache.go
+++ b/cdc/sink/mysql/txn_cache.go
@@ -121,7 +121,9 @@ func (c *unresolvedTxnCache) Resolved(
 
 func splitResolvedTxn(
 	resolvedTsMap *sync.Map, unresolvedTxns map[model.TableID][]*txnsWithTheSameCommitTs,
-) (checkpointTsMap map[model.TableID]uint64, resolvedRowsMap map[model.TableID][]*model.SingleTableTxn) {
+) (checkpointTsMap map[model.TableID]uint64,
+	resolvedRowsMap map[model.TableID][]*model.SingleTableTxn,
+) {
 	var (
 		ok                              bool
 		txnsLength                      int
diff --git a/docs/swagger/docs.go b/docs/swagger/docs.go
index b62428fb2f4..b097e17f6f7 100644
--- a/docs/swagger/docs.go
+++ b/docs/swagger/docs.go
@@ -723,6 +723,7 @@ var doc = `{
             "type": "object",
             "properties": {
                 "dispatcher": {
+                    "description": "Deprecated, please use PartitionRule.",
                     "type": "string"
                 },
                 "matcher": {
@@ -731,6 +732,10 @@ var doc = `{
                         "type": "string"
                     }
                 },
+                "partition": {
+                    "description": "PartitionRule is an alias added for DispatcherRule to mitigate confusions.\nIn the future release, the DispatcherRule is expected to be removed .",
+                    "type": "string"
+                },
                 "topic": {
                     "type": "string"
                 }
diff --git a/docs/swagger/swagger.json b/docs/swagger/swagger.json
index 3d6a3e3ab25..9f50eb12882 100644
--- a/docs/swagger/swagger.json
+++ b/docs/swagger/swagger.json
@@ -704,6 +704,7 @@
             "type": "object",
             "properties": {
                 "dispatcher": {
+                    "description": "Deprecated, please use PartitionRule.",
                     "type": "string"
                 },
                 "matcher": {
@@ -712,6 +713,10 @@
                         "type": "string"
                     }
                 },
+                "partition": {
+                    "description": "PartitionRule is an alias added for DispatcherRule to mitigate confusions.\nIn the future release, the DispatcherRule is expected to be removed .",
+                    "type": "string"
+                },
                 "topic": {
                     "type": "string"
                 }
diff --git a/docs/swagger/swagger.yaml b/docs/swagger/swagger.yaml
index e9f59cebcbe..1d0ac4b317b 100644
--- a/docs/swagger/swagger.yaml
+++ b/docs/swagger/swagger.yaml
@@ -13,11 +13,17 @@ definitions:
   config.DispatchRule:
     properties:
       dispatcher:
+        description: Deprecated, please use PartitionRule.
         type: string
       matcher:
         items:
           type: string
         type: array
+      partition:
+        description: |-
+          PartitionRule is an alias added for DispatcherRule to mitigate confusions.
+          In the future release, the DispatcherRule is expected to be removed .
+        type: string
       topic:
         type: string
     type: object
diff --git a/pkg/cmd/util/changefeed.toml b/pkg/cmd/util/changefeed.toml
index 9c305a4bd35..41202b58e04 100644
--- a/pkg/cmd/util/changefeed.toml
+++ b/pkg/cmd/util/changefeed.toml
@@ -27,7 +27,7 @@ worker-num = 16
 # For MQ Sinks, you can configure event distribution rules through dispatchers
 # Dispatchers support default, ts, rowid and table
 dispatchers = [
-    { matcher = ['test1.*', 'test2.*'], dispatcher = "ts", topic = "hello_{schema}" },
+    { matcher = ['test1.*', 'test2.*'], partition = "ts", topic = "hello_{schema}" },
     { matcher = ['test3.*', 'test4.*'], dispatcher = "rowid", topic = "{schema}_world" },
 ]
 # 对于 MQ 类的 Sink，可以通过 column-selectors 配置 column 选择器
diff --git a/pkg/cmd/util/helper_test.go b/pkg/cmd/util/helper_test.go
index f0f1d2571f1..61ae730d1cb 100644
--- a/pkg/cmd/util/helper_test.go
+++ b/pkg/cmd/util/helper_test.go
@@ -16,24 +16,17 @@ package util
 import (
 	"bytes"
 	"fmt"
+	"io/ioutil"
 	"os"
 	"path/filepath"
 	"testing"
 
-	"github.com/pingcap/check"
 	"github.com/pingcap/tiflow/pkg/config"
-	"github.com/pingcap/tiflow/pkg/util/testleak"
 	"github.com/spf13/cobra"
+	"github.com/stretchr/testify/require"
 )
 
-func TestSuite(t *testing.T) { check.TestingT(t) }
-
-type utilsSuite struct{}
-
-var _ = check.Suite(&utilsSuite{})
-
-func (s *utilsSuite) TestProxyFields(c *check.C) {
-	defer testleak.AfterTest(c)()
+func TestProxyFields(t *testing.T) {
 	revIndex := map[string]int{
 		"http_proxy":  0,
 		"https_proxy": 1,
@@ -46,65 +39,74 @@ func (s *utilsSuite) TestProxyFields(c *check.C) {
 	// Each bit of the mask decided whether this index of `envs` would be set.
 	for mask := 0; mask <= 0b111; mask++ {
 		for _, env := range envs {
-			c.Assert(os.Unsetenv(env), check.IsNil)
+			require.Nil(t, os.Unsetenv(env))
 		}
 
 		for i := 0; i < 3; i++ {
 			if (1<<i)&mask != 0 {
-				c.Assert(os.Setenv(envs[i], envPreset[i]), check.IsNil)
+				require.Nil(t, os.Setenv(envs[i], envPreset[i]))
 			}
 		}
 
 		for _, field := range findProxyFields() {
 			idx, ok := revIndex[field.Key]
-			c.Assert(ok, check.IsTrue)
-			c.Assert((1<<idx)&mask, check.Not(check.Equals), 0)
-			c.Assert(field.String, check.Equals, envPreset[idx])
+			require.True(t, ok)
+			require.NotEqual(t, 0, (1<<idx)&mask)
+			require.Equal(t, field.String, envPreset[idx])
 		}
 	}
 }
 
-func (s *utilsSuite) TestVerifyPdEndpoint(c *check.C) {
-	defer testleak.AfterTest(c)()
+func TestVerifyPdEndpoint(t *testing.T) {
 	// empty URL.
 	url := ""
-	c.Assert(VerifyPdEndpoint(url, false), check.ErrorMatches, ".*PD endpoint should be a valid http or https URL.*")
+	require.Regexp(t, ".*PD endpoint should be a valid http or https URL.*",
+		VerifyPdEndpoint(url, false))
 
 	// invalid URL.
 	url = "\n hi"
-	c.Assert(VerifyPdEndpoint(url, false), check.ErrorMatches, ".*invalid control character in URL.*")
+	require.Regexp(t, ".*invalid control character in URL.*",
+		VerifyPdEndpoint(url, false))
 
 	// http URL without host.
 	url = "http://"
-	c.Assert(VerifyPdEndpoint(url, false), check.ErrorMatches, ".*PD endpoint should be a valid http or https URL.*")
+	require.Regexp(t, ".*PD endpoint should be a valid http or https URL.*",
+		VerifyPdEndpoint(url, false))
 
 	// https URL without host.
 	url = "https://"
-	c.Assert(VerifyPdEndpoint(url, false), check.ErrorMatches, ".*PD endpoint should be a valid http or https URL.*")
+	require.Regexp(t, ".*PD endpoint should be a valid http or https URL.*",
+		VerifyPdEndpoint(url, false))
 
 	// postgres scheme.
 	url = "postgres://postgres@localhost/cargo_registry"
-	c.Assert(VerifyPdEndpoint(url, false), check.ErrorMatches, ".*PD endpoint should be a valid http or https URL.*")
+	require.Regexp(t, ".*PD endpoint should be a valid http or https URL.*",
+		VerifyPdEndpoint(url, false))
 
 	// https scheme without TLS.
 	url = "https://aa"
-	c.Assert(VerifyPdEndpoint(url, false), check.ErrorMatches, ".*PD endpoint scheme is https, please provide certificate.*")
+	require.Regexp(t, ".*PD endpoint scheme is https, please provide certificate.*",
+		VerifyPdEndpoint(url, false))
 
 	// http scheme with TLS.
 	url = "http://aa"
-	c.Assert(VerifyPdEndpoint(url, true), check.ErrorMatches, ".*PD endpoint scheme should be https.*")
+	require.Regexp(t, ".*PD endpoint scheme should be https.*", VerifyPdEndpoint(url, true))
 
 	// valid http URL.
-	c.Assert(VerifyPdEndpoint("http://aa", false), check.IsNil)
+	require.Nil(t, VerifyPdEndpoint("http://aa", false))
 
 	// valid https URL with TLS.
-	c.Assert(VerifyPdEndpoint("https://aa", true), check.IsNil)
+	require.Nil(t, VerifyPdEndpoint("https://aa", true))
 }
 
-func (s *utilsSuite) TestStrictDecodeValidFile(c *check.C) {
-	defer testleak.AfterTest(c)()
-	dataDir := c.MkDir()
-	tmpDir := c.MkDir()
+func TestStrictDecodeValidFile(t *testing.T) {
+	dataDir, err := ioutil.TempDir("", "data")
+	require.NoError(t, err)
+	tmpDir, err := ioutil.TempDir("", "tmp")
+	require.NoError(t, err)
+	defer os.RemoveAll(dataDir)
+	defer os.RemoveAll(tmpDir)
+
 	configPath := filepath.Join(tmpDir, "ticdc.toml")
 	configContent := fmt.Sprintf(`
 addr = "128.0.0.1:1234"
@@ -140,18 +142,22 @@ cert-path = "bb"
 key-path = "cc"
 cert-allowed-cn = ["dd","ee"]
 `, dataDir)
-	err := os.WriteFile(configPath, []byte(configContent), 0o644)
-	c.Assert(err, check.IsNil)
+	err = os.WriteFile(configPath, []byte(configContent), 0o644)
+	require.Nil(t, err)
 
 	conf := config.GetDefaultServerConfig()
 	err = StrictDecodeFile(configPath, "test", conf)
-	c.Assert(err, check.IsNil)
+	require.Nil(t, err)
 }
 
-func (s *utilsSuite) TestStrictDecodeInvalidFile(c *check.C) {
-	defer testleak.AfterTest(c)()
-	dataDir := c.MkDir()
-	tmpDir := c.MkDir()
+func TestStrictDecodeInvalidFile(t *testing.T) {
+	dataDir, err := ioutil.TempDir("", "data")
+	require.NoError(t, err)
+	tmpDir, err := ioutil.TempDir("", "tmp")
+	require.NoError(t, err)
+	defer os.RemoveAll(dataDir)
+	defer os.RemoveAll(tmpDir)
+
 	configPath := filepath.Join(tmpDir, "ticdc.toml")
 	configContent := fmt.Sprintf(`
 unknown = "128.0.0.1:1234"
@@ -162,29 +168,30 @@ max-size = 200
 max-days = 1
 max-backups = 1
 `, dataDir)
-	err := os.WriteFile(configPath, []byte(configContent), 0o644)
-	c.Assert(err, check.IsNil)
+	err = os.WriteFile(configPath, []byte(configContent), 0o644)
+	require.Nil(t, err)
 
 	conf := config.GetDefaultServerConfig()
 	err = StrictDecodeFile(configPath, "test", conf)
-	c.Assert(err, check.ErrorMatches, ".*contained unknown configuration options.*")
+	require.Contains(t, err.Error(), "contained unknown configuration options")
 }
 
-func (s *utilsSuite) TestAndWriteExampleReplicaTOML(c *check.C) {
-	defer testleak.AfterTest(c)()
+func TestAndWriteExampleReplicaTOML(t *testing.T) {
 	cfg := config.GetDefaultReplicaConfig()
 	err := StrictDecodeFile("changefeed.toml", "cdc", &cfg)
-	c.Assert(err, check.IsNil)
+	require.Nil(t, err)
 
-	c.Assert(cfg.CaseSensitive, check.IsTrue)
-	c.Assert(cfg.Filter, check.DeepEquals, &config.FilterConfig{
+	require.True(t, cfg.CaseSensitive)
+	require.Equal(t, &config.FilterConfig{
 		IgnoreTxnStartTs: []uint64{1, 2},
 		Rules:            []string{"*.*", "!test.*"},
-	})
-	c.Assert(cfg.Mounter, check.DeepEquals, &config.MounterConfig{
+	}, cfg.Filter)
+	require.Equal(t, &config.MounterConfig{
 		WorkerNum: 16,
-	})
-	c.Assert(cfg.Sink, check.DeepEquals, &config.SinkConfig{
+	}, cfg.Mounter)
+	err = cfg.Validate()
+	require.Nil(t, err)
+	require.Equal(t, &config.SinkConfig{
 		DispatchRules: []*config.DispatchRule{
 			{PartitionRule: "ts", TopicRule: "hello_{schema}", Matcher: []string{"test1.*", "test2.*"}},
 			{PartitionRule: "rowid", TopicRule: "{schema}_world", Matcher: []string{"test3.*", "test4.*"}},
@@ -194,28 +201,26 @@ func (s *utilsSuite) TestAndWriteExampleReplicaTOML(c *check.C) {
 			{Matcher: []string{"test3.*", "test4.*"}, Columns: []string{"!a", "column3"}},
 		},
 		Protocol: "open-protocol",
-	})
-	c.Assert(cfg.Cyclic, check.DeepEquals, &config.CyclicConfig{
+	}, cfg.Sink)
+	require.Equal(t, &config.CyclicConfig{
 		Enable:          false,
 		ReplicaID:       1,
 		FilterReplicaID: []uint64{2, 3},
 		SyncDDL:         true,
-	})
+	}, cfg.Cyclic)
 }
 
-func (s *utilsSuite) TestAndWriteExampleServerTOML(c *check.C) {
-	defer testleak.AfterTest(c)()
+func TestAndWriteExampleServerTOML(t *testing.T) {
 	cfg := config.GetDefaultServerConfig()
 	err := StrictDecodeFile("ticdc.toml", "cdc", &cfg)
-	c.Assert(err, check.IsNil)
+	require.Nil(t, err)
 	defcfg := config.GetDefaultServerConfig()
 	defcfg.AdvertiseAddr = "127.0.0.1:8300"
 	defcfg.LogFile = "/tmp/ticdc/ticdc.log"
-	c.Assert(cfg, check.DeepEquals, defcfg)
+	require.Equal(t, defcfg, cfg)
 }
 
-func (s *utilsSuite) TestJSONPrint(c *check.C) {
-	defer testleak.AfterTest(c)()
+func TestJSONPrint(t *testing.T) {
 	cmd := new(cobra.Command)
 	type testStruct struct {
 		A string `json:"a"`
@@ -229,19 +234,23 @@ func (s *utilsSuite) TestJSONPrint(c *check.C) {
 	cmd.SetOut(&b)
 
 	err := JSONPrint(cmd, &data)
-	c.Assert(err, check.IsNil)
+	require.Nil(t, err)
 
 	output := `{
   "a": "string"
 }
 `
-	c.Assert(b.String(), check.Equals, output)
+	require.Equal(t, output, b.String())
 }
 
-func (s *utilsSuite) TestIgnoreStrictCheckItem(c *check.C) {
-	defer testleak.AfterTest(c)()
-	dataDir := c.MkDir()
-	tmpDir := c.MkDir()
+func TestIgnoreStrictCheckItem(t *testing.T) {
+	dataDir, err := ioutil.TempDir("", "data")
+	require.NoError(t, err)
+	tmpDir, err := ioutil.TempDir("", "tmp")
+	require.NoError(t, err)
+	defer os.RemoveAll(dataDir)
+	defer os.RemoveAll(tmpDir)
+
 	configPath := filepath.Join(tmpDir, "ticdc.toml")
 	configContent := fmt.Sprintf(`
 data-dir = "%+v"
@@ -250,12 +259,12 @@ max-size = 200
 max-days = 1
 max-backups = 1
 `, dataDir)
-	err := os.WriteFile(configPath, []byte(configContent), 0o644)
-	c.Assert(err, check.IsNil)
+	err = os.WriteFile(configPath, []byte(configContent), 0o644)
+	require.Nil(t, err)
 
 	conf := config.GetDefaultServerConfig()
 	err = StrictDecodeFile(configPath, "test", conf, "unknown")
-	c.Assert(err, check.IsNil)
+	require.Nil(t, err)
 
 	configContent = fmt.Sprintf(`
 data-dir = "%+v"
@@ -269,10 +278,10 @@ max-days = 1
 max-backups = 1
 `, dataDir)
 	err = os.WriteFile(configPath, []byte(configContent), 0o644)
-	c.Assert(err, check.IsNil)
+	require.Nil(t, err)
 
 	err = StrictDecodeFile(configPath, "test", conf, "unknown")
-	c.Assert(err, check.ErrorMatches, ".*contained unknown configuration options: unknown2.*")
+	require.Contains(t, err.Error(), "contained unknown configuration options: unknown2")
 
 	configContent = fmt.Sprintf(`
 data-dir = "%+v"
@@ -280,8 +289,8 @@ data-dir = "%+v"
 unknown = 1
 `, dataDir)
 	err = os.WriteFile(configPath, []byte(configContent), 0o644)
-	c.Assert(err, check.IsNil)
+	require.Nil(t, err)
 
 	err = StrictDecodeFile(configPath, "test", conf, "debug")
-	c.Assert(err, check.IsNil)
+	require.Nil(t, err)
 }
diff --git a/pkg/cmd/util/main_test.go b/pkg/cmd/util/main_test.go
new file mode 100644
index 00000000000..63a5c992512
--- /dev/null
+++ b/pkg/cmd/util/main_test.go
@@ -0,0 +1,24 @@
+// Copyright 2022 PingCAP, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package util
+
+import (
+	"testing"
+
+	"github.com/pingcap/tiflow/pkg/leakutil"
+)
+
+func TestMain(m *testing.M) {
+	leakutil.SetUpLeakTest(m)
+}
diff --git a/pkg/config/replica_config.go b/pkg/config/replica_config.go
index 409586c7dbc..2952f216b8a 100644
--- a/pkg/config/replica_config.go
+++ b/pkg/config/replica_config.go
@@ -117,8 +117,8 @@ func (c *replicaConfig) fillFromV1(v1 *outdated.ReplicaConfigV1) {
 	}
 	for _, dispatch := range v1.Sink.DispatchRules {
 		c.Sink.DispatchRules = append(c.Sink.DispatchRules, &DispatchRule{
-			Matcher:       []string{fmt.Sprintf("%s.%s", dispatch.Schema, dispatch.Name)},
-			PartitionRule: dispatch.Rule,
+			Matcher:        []string{fmt.Sprintf("%s.%s", dispatch.Schema, dispatch.Name)},
+			DispatcherRule: dispatch.Rule,
 		})
 	}
 }
diff --git a/pkg/config/replica_config_test.go b/pkg/config/replica_config_test.go
index 75003eb8579..817877379f9 100644
--- a/pkg/config/replica_config_test.go
+++ b/pkg/config/replica_config_test.go
@@ -77,9 +77,9 @@ func TestReplicaConfigOutDated(t *testing.T) {
 	conf.Mounter.WorkerNum = 3
 	conf.Sink.Protocol = "open-protocol"
 	conf.Sink.DispatchRules = []*DispatchRule{
-		{Matcher: []string{"a.b"}, PartitionRule: "r1"},
-		{Matcher: []string{"a.c"}, PartitionRule: "r2"},
-		{Matcher: []string{"a.d"}, PartitionRule: "r2"},
+		{Matcher: []string{"a.b"}, DispatcherRule: "r1"},
+		{Matcher: []string{"a.c"}, DispatcherRule: "r2"},
+		{Matcher: []string{"a.d"}, DispatcherRule: "r2"},
 	}
 	require.Equal(t, conf, conf2)
 }
@@ -93,5 +93,27 @@ func TestReplicaConfigValidate(t *testing.T) {
 	conf = GetDefaultReplicaConfig()
 	conf.Sink.Protocol = "canal"
 	conf.EnableOldValue = false
-	require.Regexp(t, ".*canal protocol requires old value to be enabled.*", conf.Validate())
+	require.Regexp(t, ".*canal protocol requires old value to be enabled.*",
+		conf.Validate())
+
+	conf = GetDefaultReplicaConfig()
+	conf.Sink.DispatchRules = []*DispatchRule{
+		{Matcher: []string{"a.b"}, DispatcherRule: "d1", PartitionRule: "r1"},
+	}
+	require.Regexp(t, ".*dispatcher and partition cannot be configured both.*",
+		conf.Validate())
+
+	// Correct sink configuration.
+	conf = GetDefaultReplicaConfig()
+	conf.Sink.DispatchRules = []*DispatchRule{
+		{Matcher: []string{"a.b"}, DispatcherRule: "d1"},
+		{Matcher: []string{"a.c"}, PartitionRule: "p1"},
+		{Matcher: []string{"a.d"}},
+	}
+	err := conf.Validate()
+	require.Nil(t, err)
+	rules := conf.Sink.DispatchRules
+	require.Equal(t, "d1", rules[0].PartitionRule)
+	require.Equal(t, "p1", rules[1].PartitionRule)
+	require.Equal(t, "", rules[2].PartitionRule)
 }
diff --git a/pkg/config/sink.go b/pkg/config/sink.go
index 36aa9554454..d6e6fc74542 100644
--- a/pkg/config/sink.go
+++ b/pkg/config/sink.go
@@ -19,6 +19,7 @@ import (
 	"github.com/pingcap/errors"
 	"github.com/pingcap/log"
 	cerror "github.com/pingcap/tiflow/pkg/errors"
+	"go.uber.org/zap"
 )
 
 // DefaultMaxMessageBytes sets the default value for max-message-bytes
@@ -40,9 +41,13 @@ type SinkConfig struct {
 
 // DispatchRule represents partition rule for a table
 type DispatchRule struct {
-	Matcher       []string `toml:"matcher" json:"matcher"`
-	PartitionRule string   `toml:"dispatcher" json:"dispatcher"`
-	TopicRule     string   `toml:"topic" json:"topic"`
+	Matcher []string `toml:"matcher" json:"matcher"`
+	// Deprecated, please use PartitionRule.
+	DispatcherRule string `toml:"dispatcher" json:"dispatcher"`
+	// PartitionRule is an alias added for DispatcherRule to mitigate confusions.
+	// In the future release, the DispatcherRule is expected to be removed .
+	PartitionRule string `toml:"partition" json:"partition"`
+	TopicRule     string `toml:"topic" json:"topic"`
 }
 
 // ColumnSelector represents a column selector for a table.
@@ -62,6 +67,21 @@ func (s *SinkConfig) validate(enableOldValue bool) error {
 			}
 		}
 	}
+	for _, rule := range s.DispatchRules {
+		if rule.DispatcherRule != "" && rule.PartitionRule != "" {
+			log.Error("dispatcher and partition cannot be configured both", zap.Any("rule", rule))
+			return cerror.WrapError(cerror.ErrSinkInvalidConfig,
+				errors.New(fmt.Sprintf("dispatcher and partition cannot be "+
+					"configured both for rule:%v", rule)))
+		}
+		// After `validate()` is called, we only use PartitionRule to represent a partition
+		// dispatching rule. So when DispatcherRule is not empty, we assign its
+		// value to PartitionRule and clear itself.
+		if rule.DispatcherRule != "" {
+			rule.PartitionRule = rule.DispatcherRule
+			rule.DispatcherRule = ""
+		}
+	}
 
 	return nil
 }