Source of requeest does not match with source in worker

[GMHDBJD]

Bug Report

Please answer these questions before submitting your issue. Thanks!

1. What did you do? If possible, provide a recipe for reproducing the error.

operate-schema get -s mysql-replica-01,mysql-replica-02 test -d handle_error -t tb1

2. What did you expect to see?

{
    "result": true,
    "msg": "",
    "sources": [
        {
            "result": true,
            "msg": "CREATE TABLE `tb1` ( `id` int(11) DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=latin1 COLLATE=latin1_bin",
            "source": "mysql-replica-01",
            "worker": "worker1"
        },
        {
            "result": true,
            "msg": "CREATE TABLE `tb1` ( `id` int(11) DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=latin1 COLLATE=latin1_bin",
            "source": "mysql-replica-02",
            "worker": "worker2"
        }
    ]
}

3. What did you see instead?
   only one source is true

{
    "result": true,
    "msg": "",
    "sources": [
        {
            "result": false,
            "msg": "[code=40072:class=dm-worker:scope=internal:level=high], Message: source of request does not match with source in worker",
            "source": "mysql-replica-01",
            "worker": ""
        },
        {
            "result": true,
            "msg": "CREATE TABLE `tb1` ( `id` int(11) DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=latin1 COLLATE=latin1_bin",
            "source": "mysql-replica-02",
            "worker": "worker2"
        }
    ]
}

{
    "result": true,
    "msg": "",
    "sources": [
        {
            "result": true,
            "msg": "CREATE TABLE `tb1` ( `id` int(11) DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=latin1 COLLATE=latin1_bin",
            "source": "mysql-replica-01",
            "worker": "worker1"
        },
        {
            "result": false,
            "msg": "[code=40072:class=dm-worker:scope=internal:level=high], Message: source of request does not match with source in worker",
            "source": "mysql-replica-02",
            "worker": ""
        }
    ]
}

4. Versions of the cluster

   • DM version (run dmctl -V or dm-worker -V or dm-master -V):

     master