@Override
    protected void executeTask() throws Exception {
        executeOnce();
    }
@Test
    public void testExecuteTask(@Mocked CatalogIdGenerator idGenerator) {
        SessionVariable sessionVariable = new SessionVariable();
        sessionVariable.setTimeZone("UTC");
        new Expectations() {
            {
                idGenerator.getNextId();
                result = 1;
                connectContext.getQualifiedUser();
                result = "test_user";
                connectContext.getSessionVariable();
                result = sessionVariable;
            }};

        Database database = new Database(10000L, "test");
        OlapTable olapTable = new OlapTable(10001L, "tbl", null, KeysType.AGG_KEYS, null, null);
        connectContext.setStartTime();
        LoadLoadingTask loadLoadingTask = new LoadLoadingTask.Builder().setLoadId(new TUniqueId(2, 3))
                .setContext(connectContext).setDb(database).setTable(olapTable).setCallback(new BrokerLoadJob()).build();

        boolean exceptionThrown = false;
        GlobalStateMgr.getCurrentState().getLocalMetastore().unprotectCreateDb(database);
        database.registerTableUnlocked(olapTable);
        try {
            loadLoadingTask.prepare();
        } catch (Exception e) {
        }

        try {
            loadLoadingTask.executeTask();
        } catch (Exception e) {
            exceptionThrown = true;
        }
        Assert.assertTrue(exceptionThrown);
    }