'Call the SparkSubmitHook to run the provided spark job'

def execute(self, context):

    self._hook = SparkSubmitHook(conf=self._conf, conn_id=self._conn_id, files=self._files, py_files=self._py_files, jars=self._jars, java_class=self._java_class, total_executor_cores=self._total_executor_cores, executor_cores=self._executor_cores, executor_memory=self._executor_memory, driver_memory=self._driver_memory, keytab=self._keytab, principal=self._principal, name=self._name, num_executors=self._num_executors, application_args=self._application_args, verbose=self._verbose)
    self._hook.submit(self._application)
