@Override
    public void init() throws LoadException {
        createEtlJobConf();
    }
@Test(expected = LoadException.class)
    public void testNoDb(@Injectable SparkLoadJob sparkLoadJob,
                         @Injectable SparkResource resource,
                         @Injectable BrokerDesc brokerDesc,
                         @Mocked GlobalStateMgr globalStateMgr) throws LoadException {
        long dbId = 0L;

        new Expectations() {
            {
                globalStateMgr.getDb(dbId);
                result = null;
            }
        };

        SparkLoadPendingTask task = new SparkLoadPendingTask(sparkLoadJob, null, resource, brokerDesc);
        task.init();
    }