public Long getTransactionNumByCoordinateBe(String coordinateHost) {
        Long txnNum = 0L;
        for (DatabaseTransactionMgr databaseTransactionMgr : dbIdToDatabaseTransactionMgrs.values()) {
            txnNum += databaseTransactionMgr.getTransactionNumByCoordinateBe(coordinateHost);
        }
        return txnNum;
    }
@Test
    public void testGetTransactionNumByCoordinateBe() throws LabelAlreadyUsedException, AnalysisException,
            RunningTxnExceedException, DuplicatedRequestException {
        masterTransMgr
                .beginTransaction(GlobalStateMgrTestUtil.testDbId1, Lists.newArrayList(GlobalStateMgrTestUtil.testTableId1),
                        GlobalStateMgrTestUtil.testTxnLable1,
                        transactionSourceBe,
                        LoadJobSourceType.FRONTEND, Config.stream_load_default_timeout_second);
        long res = masterTransMgr.getTransactionNumByCoordinateBe("localbe");
        assertEquals(1, res);
    }