oozie -4.3.0 .tar for linux.64

【实例简介】
linux.64 下的 oozie-4.3.0.tar.gz 源码包 解压后编译即可 注意对应的版本 cd bin ./mkdistro.sh -Phadoop-2 -Dhadoop.auth.version=2.8.2 -Ddistcp.version=2.8.2 -Dhadoop.version=2.8.2 -Dsqoop.version=1.4.6 -DskipTests
【实例截图】
【核心代码】
apache_oozie-4.3.0
├── oozie-4.3.0
│   ├── bin
│   │   ├── create-release-artifact
│   │   ├── mkdistro.sh
│   │   ├── test-patch
│   │   ├── test-patch-00-clean
│   │   ├── test-patch-05-patch-raw-analysis
│   │   ├── test-patch-08-rat
│   │   ├── test-patch-09-javadoc
│   │   ├── test-patch-10-compile
│   │   ├── test-patch-15-backwards-compatibility
│   │   ├── test-patch-20-tests
│   │   ├── test-patch-30-distro
│   │   ├── test-patch-find-new-patch-available-jiras
│   │   └── test-patch-XX-template
│   ├── builds
│   │   └── runHudsonCIBuild.sh
│   ├── client
│   │   ├── pom.xml
│   │   └── src
│   │   ├── main
│   │   │   ├── bin
│   │   │   │   └── oozie
│   │   │   ├── conf
│   │   │   │   └── oozie-client-env.sh
│   │   │   ├── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   ├── AppType.java
│   │   │   │   ├── BuildInfo.java
│   │   │   │   ├── cli
│   │   │   │   │   ├── CLIParser.java
│   │   │   │   │   ├── OozieCLIException.java
│   │   │   │   │   └── OozieCLI.java
│   │   │   │   └── client
│   │   │   │   ├── AuthOozieClient.java
│   │   │   │   ├── BulkResponse.java
│   │   │   │   ├── BundleJob.java
│   │   │   │   ├── CoordinatorAction.java
│   │   │   │   ├── CoordinatorJob.java
│   │   │   │   ├── event
│   │   │   │   │   ├── Event.java
│   │   │   │   │   ├── jms
│   │   │   │   │   │   ├── JMSHeaderConstants.java
│   │   │   │   │   │   ├── JMSMessagingUtils.java
│   │   │   │   │   │   ├── JSONMessageDeserializer.java
│   │   │   │   │   │   └── MessageDeserializer.java
│   │   │   │   │   ├── JobEvent.java
│   │   │   │   │   ├── message
│   │   │   │   │   │   ├── CoordinatorActionMessage.java
│   │   │   │   │   │   ├── EventMessage.java
│   │   │   │   │   │   ├── JobMessage.java
│   │   │   │   │   │   ├── SLAMessage.java
│   │   │   │   │   │   └── WorkflowJobMessage.java
│   │   │   │   │   └── SLAEvent.java
│   │   │   │   ├── JMSConnectionInfo.java
│   │   │   │   ├── JMSConnectionInfoWrapper.java
│   │   │   │   ├── Job.java
│   │   │   │   ├── OozieClientException.java
│   │   │   │   ├── OozieClient.java
│   │   │   │   ├── rest
│   │   │   │   │   ├── JsonTags.java
│   │   │   │   │   ├── JsonToBean.java
│   │   │   │   │   ├── JsonUtils.java
│   │   │   │   │   └── RestConstants.java
│   │   │   │   ├── retry
│   │   │   │   │   └── ConnectionRetriableClient.java
│   │   │   │   ├── SLAEvent.java
│   │   │   │   ├── WorkflowAction.java
│   │   │   │   ├── WorkflowJob.java
│   │   │   │   └── XOozieClient.java
│   │   │   └── resources
│   │   │   ├── distcp-action-0.1.xsd
│   │   │   ├── distcp-action-0.2.xsd
│   │   │   ├── email-action-0.1.xsd
│   │   │   ├── email-action-0.2.xsd
│   │   │   ├── gms-oozie-sla-0.1.xsd
│   │   │   ├── hive2-action-0.1.xsd
│   │   │   ├── hive2-action-0.2.xsd
│   │   │   ├── hive-action-0.2.xsd
│   │   │   ├── hive-action-0.3.xsd
│   │   │   ├── hive-action-0.4.xsd
│   │   │   ├── hive-action-0.5.xsd
│   │   │   ├── hive-action-0.6.xsd
│   │   │   ├── oozie-buildinfo.properties
│   │   │   ├── oozie-bundle-0.1.xsd
│   │   │   ├── oozie-bundle-0.2.xsd
│   │   │   ├── oozie-coordinator-0.1.xsd
│   │   │   ├── oozie-coordinator-0.2.xsd
│   │   │   ├── oozie-coordinator-0.3.xsd
│   │   │   ├── oozie-coordinator-0.4.xsd
│   │   │   ├── oozie-coordinator-0.5.xsd
│   │   │   ├── oozie-sla-0.1.xsd
│   │   │   ├── oozie-sla-0.2.xsd
│   │   │   ├── oozie-workflow-0.1.xsd
│   │   │   ├── oozie-workflow-0.2.5.xsd
│   │   │   ├── oozie-workflow-0.2.xsd
│   │   │   ├── oozie-workflow-0.3.xsd
│   │   │   ├── oozie-workflow-0.4.5.xsd
│   │   │   ├── oozie-workflow-0.4.xsd
│   │   │   ├── oozie-workflow-0.5.xsd
│   │   │   ├── shell-action-0.1.xsd
│   │   │   ├── shell-action-0.2.xsd
│   │   │   ├── shell-action-0.3.xsd
│   │   │   ├── spark-action-0.1.xsd
│   │   │   ├── spark-action-0.2.xsd
│   │   │   ├── sqoop-action-0.2.xsd
│   │   │   ├── sqoop-action-0.3.xsd
│   │   │   ├── sqoop-action-0.4.xsd
│   │   │   ├── ssh-action-0.1.xsd
│   │   │   └── ssh-action-0.2.xsd
│   │   └── test
│   │   ├── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   ├── cli
│   │   │   │   ├── TestCLIParser.java
│   │   │   │   ├── TestOozieCLIMethods.java
│   │   │   │   └── TestValidation.java
│   │   │   └── client
│   │   │   └── rest
│   │   │   ├── TestJsonToBean.java
│   │   │   └── TestJsonUtils.java
│   │   └── resources
│   │   ├── invalid.xml
│   │   └── valid.xml
│   ├── core
│   │   ├── pom.xml
│   │   └── src
│   │   ├── main
│   │   │   ├── conf
│   │   │   │   ├── action-conf
│   │   │   │   │   └── hive.xml
│   │   │   │   ├── adminusers.txt
│   │   │   │   ├── hadoop-conf
│   │   │   │   │   └── core-site.xml
│   │   │   │   ├── hadoop-config.xml
│   │   │   │   ├── oozie-env.cmd
│   │   │   │   ├── oozie-env.sh
│   │   │   │   ├── oozie-log4j.properties
│   │   │   │   └── oozie-site.xml
│   │   │   ├── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   ├── action
│   │   │   │   │   ├── ActionExecutorException.java
│   │   │   │   │   ├── ActionExecutor.java
│   │   │   │   │   ├── control
│   │   │   │   │   │   ├── ControlNodeActionExecutor.java
│   │   │   │   │   │   ├── EndActionExecutor.java
│   │   │   │   │   │   ├── ForkActionExecutor.java
│   │   │   │   │   │   ├── JoinActionExecutor.java
│   │   │   │   │   │   ├── KillActionExecutor.java
│   │   │   │   │   │   └── StartActionExecutor.java
│   │   │   │   │   ├── decision
│   │   │   │   │   │   └── DecisionActionExecutor.java
│   │   │   │   │   ├── email
│   │   │   │   │   │   └── EmailActionExecutor.java
│   │   │   │   │   ├── hadoop
│   │   │   │   │   │   ├── CredentialException.java
│   │   │   │   │   │   ├── Credentials.java
│   │   │   │   │   │   ├── CredentialsProperties.java
│   │   │   │   │   │   ├── CredentialsProvider.java
│   │   │   │   │   │   ├── DistcpActionExecutor.java
│   │   │   │   │   │   ├── FsActionExecutor.java
│   │   │   │   │   │   ├── FsELFunctions.java
│   │   │   │   │   │   ├── HadoopELFunctions.java
│   │   │   │   │   │   ├── HbaseCredentials.java
│   │   │   │   │   │   ├── HCatCredentialHelper.java
│   │   │   │   │   │   ├── HCatCredentials.java
│   │   │   │   │   │   ├── Hive2ActionExecutor.java
│   │   │   │   │   │   ├── Hive2Credentials.java
│   │   │   │   │   │   ├── HiveActionExecutor.java
│   │   │   │   │   │   ├── JavaActionExecutor.java
│   │   │   │   │   │   ├── LauncherMapperHelper.java
│   │   │   │   │   │   ├── MapReduceActionExecutor.java
│   │   │   │   │   │   ├── OozieJobInfo.java
│   │   │   │   │   │   ├── PigActionExecutor.java
│   │   │   │   │   │   ├── ScriptLanguageActionExecutor.java
│   │   │   │   │   │   ├── ShellActionExecutor.java
│   │   │   │   │   │   ├── SparkActionExecutor.java
│   │   │   │   │   │   └── SqoopActionExecutor.java
│   │   │   │   │   ├── oozie
│   │   │   │   │   │   └── SubWorkflowActionExecutor.java
│   │   │   │   │   └── ssh
│   │   │   │   │   └── SshActionExecutor.java
│   │   │   │   ├── BaseEngineException.java
│   │   │   │   ├── BaseEngine.java
│   │   │   │   ├── BinaryBlob.java
│   │   │   │   ├── BulkResponseInfo.java
│   │   │   │   ├── bundle
│   │   │   │   │   └── BundleELFunctions.java
│   │   │   │   ├── BundleActionBean.java
│   │   │   │   ├── BundleEngineException.java
│   │   │   │   ├── BundleEngine.java
│   │   │   │   ├── BundleJobBean.java
│   │   │   │   ├── BundleJobInfo.java
│   │   │   │   ├── client
│   │   │   │   │   └── rest
│   │   │   │   │   ├── BulkResponseImpl.java
│   │   │   │   │   ├── JMSConnectionInfoBean.java
│   │   │   │   │   ├── JsonBean.java
│   │   │   │   │   └── JsonSLAEvent.java
│   │   │   │   ├── command
│   │   │   │   │   ├── BulkJobsXCommand.java
│   │   │   │   │   ├── bundle
│   │   │   │   │   │   ├── BulkBundleXCommand.java
│   │   │   │   │   │   ├── BundleCoordSubmitXCommand.java
│   │   │   │   │   │   ├── BundleJobChangeXCommand.java
│   │   │   │   │   │   ├── BundleJobException.java
│   │   │   │   │   │   ├── BundleJobResumeXCommand.java
│   │   │   │   │   │   ├── BundleJobSuspendXCommand.java
│   │   │   │   │   │   ├── BundleJobsXCommand.java
│   │   │   │   │   │   ├── BundleJobXCommand.java
│   │   │   │   │   │   ├── BundleKillXCommand.java
│   │   │   │   │   │   ├── BundlePauseXCommand.java
│   │   │   │   │   │   ├── BundleRerunXCommand.java
│   │   │   │   │   │   ├── BundleSLAAlertsDisableXCommand.java
│   │   │   │   │   │   ├── BundleSLAAlertsEnableXCommand.java
│   │   │   │   │   │   ├── BundleSLAAlertsXCommand.java
│   │   │   │   │   │   ├── BundleSLAChangeXCommand.java
│   │   │   │   │   │   ├── BundleStartXCommand.java
│   │   │   │   │   │   ├── BundleStatusTransitXCommand.java
│   │   │   │   │   │   ├── BundleStatusUpdateXCommand.java
│   │   │   │   │   │   ├── BundleSubmitXCommand.java
│   │   │   │   │   │   └── BundleUnpauseXCommand.java
│   │   │   │   │   ├── CommandException.java
│   │   │   │   │   ├── coord
│   │   │   │   │   │   ├── BulkCoordXCommand.java
│   │   │   │   │   │   ├── CoordActionCheckXCommand.java
│   │   │   │   │   │   ├── CoordActionInfoXCommand.java
│   │   │   │   │   │   ├── CoordActionInputCheckXCommand.java
│   │   │   │   │   │   ├── CoordActionNotificationXCommand.java
│   │   │   │   │   │   ├── CoordActionReadyXCommand.java
│   │   │   │   │   │   ├── CoordActionsIgnoreXCommand.java
│   │   │   │   │   │   ├── CoordActionsKillXCommand.java
│   │   │   │   │   │   ├── CoordActionSkipXCommand.java
│   │   │   │   │   │   ├── CoordActionStartXCommand.java
│   │   │   │   │   │   ├── CoordActionTimeOutXCommand.java
│   │   │   │   │   │   ├── CoordActionUpdatePushMissingDependency.java
│   │   │   │   │   │   ├── CoordActionUpdateXCommand.java
│   │   │   │   │   │   ├── CoordChangeXCommand.java
│   │   │   │   │   │   ├── CoordCommandUtils.java
│   │   │   │   │   │   ├── CoordinatorXCommand.java
│   │   │   │   │   │   ├── CoordJobsXCommand.java
│   │   │   │   │   │   ├── CoordJobXCommand.java
│   │   │   │   │   │   ├── CoordKillXCommand.java
│   │   │   │   │   │   ├── CoordMaterializeTransitionXCommand.java
│   │   │   │   │   │   ├── CoordPauseXCommand.java
│   │   │   │   │   │   ├── CoordPushDependencyCheckXCommand.java
│   │   │   │   │   │   ├── CoordRerunXCommand.java
│   │   │   │   │   │   ├── CoordResumeXCommand.java
│   │   │   │   │   │   ├── CoordSLAAlertsDisableXCommand.java
│   │   │   │   │   │   ├── CoordSLAAlertsEnableXCommand.java
│   │   │   │   │   │   ├── CoordSLAAlertsXCommand.java
│   │   │   │   │   │   ├── CoordSLAChangeXCommand.java
│   │   │   │   │   │   ├── CoordStatusTransitXCommand.java
│   │   │   │   │   │   ├── CoordSubmitXCommand.java
│   │   │   │   │   │   ├── CoordSuspendXCommand.java
│   │   │   │   │   │   ├── CoordUnpauseXCommand.java
│   │   │   │   │   │   ├── CoordUpdateXCommand.java
│   │   │   │   │   │   └── SLAEventsXCommand.java
│   │   │   │   │   ├── IgnoreTransitionXCommand.java
│   │   │   │   │   ├── KillTransitionXCommand.java
│   │   │   │   │   ├── MaterializeTransitionXCommand.java
│   │   │   │   │   ├── NotificationXCommand.java
│   │   │   │   │   ├── OperationType.java
│   │   │   │   │   ├── PauseTransitionXCommand.java
│   │   │   │   │   ├── PreconditionException.java
│   │   │   │   │   ├── PurgeXCommand.java
│   │   │   │   │   ├── RerunTransitionXCommand.java
│   │   │   │   │   ├── ResumeTransitionXCommand.java
│   │   │   │   │   ├── sla
│   │   │   │   │   │   ├── SLACoordActionJobEventXCommand.java
│   │   │   │   │   │   ├── SLACoordActionJobHistoryXCommand.java
│   │   │   │   │   │   ├── SLAJobEventXCommand.java
│   │   │   │   │   │   ├── SLAJobHistoryXCommand.java
│   │   │   │   │   │   ├── SLAWorkflowActionJobEventXCommand.java
│   │   │   │   │   │   ├── SLAWorkflowActionJobHistoryXCommand.java
│   │   │   │   │   │   ├── SLAWorkflowJobEventXCommand.java
│   │   │   │   │   │   └── SLAWorkflowJobHistoryXCommand.java
│   │   │   │   │   ├── SLAAlertsXCommand.java
│   │   │   │   │   ├── StartTransitionXCommand.java
│   │   │   │   │   ├── StatusTransitXCommand.java
│   │   │   │   │   ├── StatusUpdateXCommand.java
│   │   │   │   │   ├── SubmitTransitionXCommand.java
│   │   │   │   │   ├── SuspendTransitionXCommand.java
│   │   │   │   │   ├── TransitionXCommand.java
│   │   │   │   │   ├── UnpauseTransitionXCommand.java
│   │   │   │   │   ├── wf
│   │   │   │   │   │   ├── ActionCheckXCommand.java
│   │   │   │   │   │   ├── ActionEndXCommand.java
│   │   │   │   │   │   ├── ActionKillXCommand.java
│   │   │   │   │   │   ├── ActionStartXCommand.java
│   │   │   │   │   │   ├── ActionXCommand.java
│   │   │   │   │   │   ├── BulkWorkflowXCommand.java
│   │   │   │   │   │   ├── CompletedActionXCommand.java
│   │   │   │   │   │   ├── DefinitionXCommand.java
│   │   │   │   │   │   ├── ExternalIdXCommand.java
│   │   │   │   │   │   ├── ForkedActionStartXCommand.java
│   │   │   │   │   │   ├── JobsXCommand.java
│   │   │   │   │   │   ├── JobXCommand.java
│   │   │   │   │   │   ├── KillXCommand.java
│   │   │   │   │   │   ├── ReRunXCommand.java
│   │   │   │   │   │   ├── ResumeXCommand.java
│   │   │   │   │   │   ├── SignalXCommand.java
│   │   │   │   │   │   ├── StartXCommand.java
│   │   │   │   │   │   ├── SubmitHiveXCommand.java
│   │   │   │   │   │   ├── SubmitHttpXCommand.java
│   │   │   │   │   │   ├── SubmitMRXCommand.java
│   │   │   │   │   │   ├── SubmitPigXCommand.java
│   │   │   │   │   │   ├── SubmitScriptLanguageXCommand.java
│   │   │   │   │   │   ├── SubmitSqoopXCommand.java
│   │   │   │   │   │   ├── SubmitXCommand.java
│   │   │   │   │   │   ├── SuspendXCommand.java
│   │   │   │   │   │   ├── WfEndXCommand.java
│   │   │   │   │   │   ├── WorkflowActionInfoXCommand.java
│   │   │   │   │   │   ├── WorkflowNotificationXCommand.java
│   │   │   │   │   │   └── WorkflowXCommand.java
│   │   │   │   │   └── XCommand.java
│   │   │   │   ├── compression
│   │   │   │   │   ├── CodecFactory.java
│   │   │   │   │   ├── CompressionCodec.java
│   │   │   │   │   └── GzipCompressionCodec.java
│   │   │   │   ├── coord
│   │   │   │   │   ├── CoordELConstants.java
│   │   │   │   │   ├── CoordELEvaluator.java
│   │   │   │   │   ├── CoordELFunctions.java
│   │   │   │   │   ├── CoordinatorJobException.java
│   │   │   │   │   ├── CoordUtils.java
│   │   │   │   │   ├── HCatELFunctions.java
│   │   │   │   │   ├── input
│   │   │   │   │   │   ├── dependency
│   │   │   │   │   │   │   ├── AbstractCoordInputDependency.java
│   │   │   │   │   │   │   ├── CoordInputDependencyFactory.java
│   │   │   │   │   │   │   ├── CoordInputDependency.java
│   │   │   │   │   │   │   ├── CoordInputInstance.java
│   │   │   │   │   │   │   ├── CoordOldInputDependency.java
│   │   │   │   │   │   │   ├── CoordPullInputDependency.java
│   │   │   │   │   │   │   ├── CoordPushInputDependency.java
│   │   │   │   │   │   │   └── CoordUnResolvedInputDependency.java
│   │   │   │   │   │   └── logic
│   │   │   │   │   │   ├── CoordInputLogicBuilder.java
│   │   │   │   │   │   ├── CoordInputLogicEvaluator.java
│   │   │   │   │   │   ├── CoordInputLogicEvaluatorPhaseOne.java
│   │   │   │   │   │   ├── CoordInputLogicEvaluatorPhaseThree.java
│   │   │   │   │   │   ├── CoordInputLogicEvaluatorPhaseTwo.java
│   │   │   │   │   │   ├── CoordInputLogicEvaluatorPhaseValidate.java
│   │   │   │   │   │   ├── CoordInputLogicEvaluatorResult.java
│   │   │   │   │   │   ├── CoordInputLogicEvaluatorUtil.java
│   │   │   │   │   │   ├── InputLogicParser.java
│   │   │   │   │   │   ├── OozieJexlEngine.java
│   │   │   │   │   │   └── OozieJexlInterpreter.java
│   │   │   │   │   ├── SyncCoordAction.java
│   │   │   │   │   ├── SyncCoordDataset.java
│   │   │   │   │   └── TimeUnit.java
│   │   │   │   ├── CoordinatorActionBean.java
│   │   │   │   ├── CoordinatorActionInfo.java
│   │   │   │   ├── CoordinatorEngineException.java
│   │   │   │   ├── CoordinatorEngine.java
│   │   │   │   ├── CoordinatorJobBean.java
│   │   │   │   ├── CoordinatorJobInfo.java
│   │   │   │   ├── DagELFunctions.java
│   │   │   │   ├── DagEngineException.java
│   │   │   │   ├── DagEngine.java
│   │   │   │   ├── dependency
│   │   │   │   │   ├── ActionDependency.java
│   │   │   │   │   ├── DependencyChecker.java
│   │   │   │   │   ├── FSURIHandler.java
│   │   │   │   │   ├── hcat
│   │   │   │   │   │   ├── EhcacheHCatDependencyCache.java
│   │   │   │   │   │   ├── HCatDependencyCache.java
│   │   │   │   │   │   ├── HCatMessageHandler.java
│   │   │   │   │   │   ├── SimpleHCatDependencyCache.java
│   │   │   │   │   │   ├── WaitingAction.java
│   │   │   │   │   │   └── WaitingActions.java
│   │   │   │   │   ├── HCatURIHandler.java
│   │   │   │   │   ├── URIHandlerException.java
│   │   │   │   │   └── URIHandler.java
│   │   │   │   ├── ErrorCode.java
│   │   │   │   ├── event
│   │   │   │   │   ├── BundleJobEvent.java
│   │   │   │   │   ├── CoordinatorActionEvent.java
│   │   │   │   │   ├── CoordinatorJobEvent.java
│   │   │   │   │   ├── EventQueue.java
│   │   │   │   │   ├── listener
│   │   │   │   │   │   ├── JobEventListener.java
│   │   │   │   │   │   └── ZKConnectionListener.java
│   │   │   │   │   ├── MemoryEventQueue.java
│   │   │   │   │   ├── messaging
│   │   │   │   │   │   ├── JSONMessageSerializer.java
│   │   │   │   │   │   ├── MessageFactory.java
│   │   │   │   │   │   └── MessageSerializer.java
│   │   │   │   │   ├── WorkflowActionEvent.java
│   │   │   │   │   └── WorkflowJobEvent.java
│   │   │   │   ├── executor
│   │   │   │   │   └── jpa
│   │   │   │   │   ├── BatchQueryExecutor.java
│   │   │   │   │   ├── BinaryBlobValueHandler.java
│   │   │   │   │   ├── BulkJPAExecutor.java
│   │   │   │   │   ├── BundleActionGetJPAExecutor.java
│   │   │   │   │   ├── BundleActionInsertJPAExecutor.java
│   │   │   │   │   ├── BundleActionQueryExecutor.java
│   │   │   │   │   ├── BundleActionsCountForJobGetJPAExecutor.java
│   │   │   │   │   ├── BundleJobGetCoordinatorsJPAExecutor.java
│   │   │   │   │   ├── BundleJobGetForUserJPAExecutor.java
│   │   │   │   │   ├── BundleJobGetJPAExecutor.java
│   │   │   │   │   ├── BundleJobInfoGetJPAExecutor.java
│   │   │   │   │   ├── BundleJobInsertJPAExecutor.java
│   │   │   │   │   ├── BundleJobQueryExecutor.java
│   │   │   │   │   ├── BundleJobsDeleteJPAExecutor.java
│   │   │   │   │   ├── BundleJobsGetForPurgeJPAExecutor.java
│   │   │   │   │   ├── BundleJobsGetNeedStartJPAExecutor.java
│   │   │   │   │   ├── BundleJobsGetPausedJPAExecutor.java
│   │   │   │   │   ├── BundleJobsGetRunningOrPendingJPAExecutor.java
│   │   │   │   │   ├── BundleJobsGetUnpausedJPAExecutor.java
│   │   │   │   │   ├── CoordActionGetForCheckJPAExecutor.java
│   │   │   │   │   ├── CoordActionGetForExternalIdJPAExecutor.java
│   │   │   │   │   ├── CoordActionGetForInfoJPAExecutor.java
│   │   │   │   │   ├── CoordActionGetForInputCheckJPAExecutor.java
│   │   │   │   │   ├── CoordActionGetForStartJPAExecutor.java
│   │   │   │   │   ├── CoordActionGetForTimeoutJPAExecutor.java
│   │   │   │   │   ├── CoordActionGetJPAExecutor.java
│   │   │   │   │   ├── CoordActionInsertJPAExecutor.java
│   │   │   │   │   ├── CoordActionQueryExecutor.java
│   │   │   │   │   ├── CoordActionRemoveJPAExecutor.java
│   │   │   │   │   ├── CoordActionsActiveCountJPAExecutor.java
│   │   │   │   │   ├── CoordActionsCountForJobIdJPAExecutor.java
│   │   │   │   │   ├── CoordActionsDeleteJPAExecutor.java
│   │   │   │   │   ├── CoordActionsGetFromCoordJobIdJPAExecutor.java
│   │   │   │   │   ├── CoordActionsPendingFalseCountGetJPAExecutor.java
│   │   │   │   │   ├── CoordActionsPendingFalseStatusCountGetJPAExecutor.java
│   │   │   │   │   ├── CoordActionsRunningGetJPAExecutor.java
│   │   │   │   │   ├── CoordinatorJobGetForUserAppnameJPAExecutor.java
│   │   │   │   │   ├── CoordinatorJobGetForUserJPAExecutor.java
│   │   │   │   │   ├── CoordJobDeleteJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionByActionNumberJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionForNominalTimeJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionModifiedDateForRangeJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionRunningCountForRangeJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionsJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionsNotCompletedJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionsRunningJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionsStatusJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionsSubsetJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetActionsSuspendedJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetReadyActionsJPAExecutor.java
│   │   │   │   │   ├── CoordJobGetRunningActionsCountJPAExecutor.java
│   │   │   │   │   ├── CoordJobInfoGetJPAExecutor.java
│   │   │   │   │   ├── CoordJobInsertJPAExecutor.java
│   │   │   │   │   ├── CoordJobQueryExecutor.java
│   │   │   │   │   ├── CoordJobsCountNotForPurgeFromParentIdJPAExecutor.java
│   │   │   │   │   ├── CoordJobsDeleteJPAExecutor.java
│   │   │   │   │   ├── CoordJobsGetForPurgeJPAExecutor.java
│   │   │   │   │   ├── CoordJobsGetFromParentIdJPAExecutor.java
│   │   │   │   │   ├── CoordJobsGetPausedJPAExecutor.java
│   │   │   │   │   ├── CoordJobsGetPendingJPAExecutor.java
│   │   │   │   │   ├── CoordJobsGetUnpausedJPAExecutor.java
│   │   │   │   │   ├── CoordJobsToBeMaterializedJPAExecutor.java
│   │   │   │   │   ├── JPAExecutorException.java
│   │   │   │   │   ├── JPAExecutor.java
│   │   │   │   │   ├── QueryExecutor.java
│   │   │   │   │   ├── sla
│   │   │   │   │   │   ├── SLASummaryGetForFilterJPAExecutor.java
│   │   │   │   │   │   └── SLASummaryGetRecordsOnRestartJPAExecutor.java
│   │   │   │   │   ├── SLAEventInsertJPAExecutor.java
│   │   │   │   │   ├── SLAEventsGetForFilterJPAExecutor.java
│   │   │   │   │   ├── SLAEventsGetForSeqIdJPAExecutor.java
│   │   │   │   │   ├── SLAEventsGetJPAExecutor.java
│   │   │   │   │   ├── SLARegistrationQueryExecutor.java
│   │   │   │   │   ├── SLASummaryQueryExecutor.java
│   │   │   │   │   ├── StringBlobValueHandler.java
│   │   │   │   │   ├── WorkflowActionDeleteJPAExecutor.java
│   │   │   │   │   ├── WorkflowActionGetJPAExecutor.java
│   │   │   │   │   ├── WorkflowActionInsertJPAExecutor.java
│   │   │   │   │   ├── WorkflowActionQueryExecutor.java
│   │   │   │   │   ├── WorkflowActionRetryManualGetJPAExecutor.java
│   │   │   │   │   ├── WorkflowActionsGetForJobJPAExecutor.java
│   │   │   │   │   ├── WorkflowActionSubsetGetJPAExecutor.java
│   │   │   │   │   ├── WorkflowIdGetForExternalIdJPAExecutor.java
│   │   │   │   │   ├── WorkflowInfoWithActionsSubsetGetJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobDeleteJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobGetActionsJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobGetForUserJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobGetJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobInsertJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobQueryExecutor.java
│   │   │   │   │   ├── WorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobsBasicInfoFromWorkflowParentIdJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobsDeleteJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobsGetForPurgeJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobsGetFromCoordParentIdJPAExecutor.java
│   │   │   │   │   ├── WorkflowJobsGetFromWorkflowParentIdJPAExecutor.java
│   │   │   │   │   └── WorkflowsJobGetJPAExecutor.java
│   │   │   │   ├── FaultInjection.java
│   │   │   │   ├── jms
│   │   │   │   │   ├── ConnectionContext.java
│   │   │   │   │   ├── DefaultConnectionContext.java
│   │   │   │   │   ├── JMSConnectionInfo.java
│   │   │   │   │   ├── JMSExceptionListener.java
│   │   │   │   │   ├── JMSJobEventListener.java
│   │   │   │   │   ├── JMSSLAEventListener.java
│   │   │   │   │   ├── MessageHandler.java
│   │   │   │   │   └── MessageReceiver.java
│   │   │   │   ├── local
│   │   │   │   │   └── LocalOozie.java
│   │   │   │   ├── LocalOozieClientCoord.java
│   │   │   │   ├── LocalOozieClient.java
│   │   │   │   ├── lock
│   │   │   │   │   ├── LockToken.java
│   │   │   │   │   └── MemoryLocks.java
│   │   │   │   ├── service
│   │   │   │   │   ├── AbandonedCoordCheckerService.java
│   │   │   │   │   ├── ActionCheckerService.java
│   │   │   │   │   ├── ActionConfFileType.java
│   │   │   │   │   ├── ActionService.java
│   │   │   │   │   ├── AuthorizationException.java
│   │   │   │   │   ├── AuthorizationService.java
│   │   │   │   │   ├── BundleEngineService.java
│   │   │   │   │   ├── CallableQueueService.java
│   │   │   │   │   ├── CallbackService.java
│   │   │   │   │   ├── ConfigurationService.java
│   │   │   │   │   ├── CoordinatorEngineService.java
│   │   │   │   │   ├── CoordMaterializeTriggerService.java
│   │   │   │   │   ├── DagEngineService.java
│   │   │   │   │   ├── DagXLogInfoService.java
│   │   │   │   │   ├── DBLiteWorkflowStoreService.java
│   │   │   │   │   ├── ELService.java
│   │   │   │   │   ├── EventHandlerService.java
│   │   │   │   │   ├── GroupsService.java
│   │   │   │   │   ├── HadoopAccessorException.java
│   │   │   │   │   ├── HadoopAccessorService.java
│   │   │   │   │   ├── HCatAccessorException.java
│   │   │   │   │   ├── HCatAccessorService.java
│   │   │   │   │   ├── InstrumentationService.java
│   │   │   │   │   ├── JMSAccessorService.java
│   │   │   │   │   ├── JMSTopicService.java
│   │   │   │   │   ├── JobsConcurrencyService.java
│   │   │   │   │   ├── JPAService.java
│   │   │   │   │   ├── JvmPauseMonitorService.java
│   │   │   │   │   ├── LiteWorkflowAppService.java
│   │   │   │   │   ├── LiteWorkflowStoreService.java
│   │   │   │   │   ├── MemoryLocksService.java
│   │   │   │   │   ├── MetricsInstrumentationService.java
│   │   │   │   │   ├── PartitionDependencyManagerService.java
│   │   │   │   │   ├── PauseTransitService.java
│   │   │   │   │   ├── ProxyUserService.java
│   │   │   │   │   ├── PurgeService.java
│   │   │   │   │   ├── RecoveryService.java
│   │   │   │   │   ├── SchedulerService.java
│   │   │   │   │   ├── SchemaService.java
│   │   │   │   │   ├── ServiceException.java
│   │   │   │   │   ├── Service.java
│   │   │   │   │   ├── Services.java
│   │   │   │   │   ├── ShareLibService.java
│   │   │   │   │   ├── SLAStoreService.java
│   │   │   │   │   ├── SparkConfigurationService.java
│   │   │   │   │   ├── StatusTransitService.java
│   │   │   │   │   ├── StoreService.java
│   │   │   │   │   ├── URIHandlerService.java
│   │   │   │   │   ├── UserGroupInformationService.java
│   │   │   │   │   ├── UUIDService.java
│   │   │   │   │   ├── WorkflowAppService.java
│   │   │   │   │   ├── WorkflowSchemaService.java
│   │   │   │   │   ├── WorkflowStoreService.java
│   │   │   │   │   ├── XLogService.java
│   │   │   │   │   ├── XLogStreamingService.java
│   │   │   │   │   ├── XLogUtil.java
│   │   │   │   │   ├── ZKJobsConcurrencyService.java
│   │   │   │   │   ├── ZKLocksService.java
│   │   │   │   │   ├── ZKUUIDService.java
│   │   │   │   │   └── ZKXLogStreamingService.java
│   │   │   │   ├── servlet
│   │   │   │   │   ├── AuthFilter.java
│   │   │   │   │   ├── BaseAdminServlet.java
│   │   │   │   │   ├── BaseJobServlet.java
│   │   │   │   │   ├── BaseJobsServlet.java
│   │   │   │   │   ├── CallbackServlet.java
│   │   │   │   │   ├── HostnameFilter.java
│   │   │   │   │   ├── JsonRestServlet.java
│   │   │   │   │   ├── JVMInfo.java
│   │   │   │   │   ├── ServicesLoader.java
│   │   │   │   │   ├── ServletUtilities.java
│   │   │   │   │   ├── SLAServlet.java
│   │   │   │   │   ├── V0AdminServlet.java
│   │   │   │   │   ├── V0JobServlet.java
│   │   │   │   │   ├── V0JobsServlet.java
│   │   │   │   │   ├── V1AdminServlet.java
│   │   │   │   │   ├── V1JobServlet.java
│   │   │   │   │   ├── V1JobsServlet.java
│   │   │   │   │   ├── V2AdminServlet.java
│   │   │   │   │   ├── V2JobServlet.java
│   │   │   │   │   ├── V2SLAServlet.java
│   │   │   │   │   ├── V2ValidateServlet.java
│   │   │   │   │   ├── VersionServlet.java
│   │   │   │   │   └── XServletException.java
│   │   │   │   ├── sla
│   │   │   │   │   ├── listener
│   │   │   │   │   │   ├── SLAEmailEventListener.java
│   │   │   │   │   │   ├── SLAEventListener.java
│   │   │   │   │   │   └── SLAJobEventListener.java
│   │   │   │   │   ├── service
│   │   │   │   │   │   └── SLAService.java
│   │   │   │   │   ├── SLACalcStatus.java
│   │   │   │   │   ├── SLACalculator.java
│   │   │   │   │   ├── SLACalculatorMemory.java
│   │   │   │   │   ├── SLAOperations.java
│   │   │   │   │   ├── SLARegistrationBean.java
│   │   │   │   │   ├── SLASummaryBean.java
│   │   │   │   │   └── SLAXCommandFactory.java
│   │   │   │   ├── SLAEventBean.java
│   │   │   │   ├── store
│   │   │   │   │   ├── OozieSchema.java
│   │   │   │   │   ├── SLAStore.java
│   │   │   │   │   ├── StoreException.java
│   │   │   │   │   ├── Store.java
│   │   │   │   │   ├── StoreStatusFilter.java
│   │   │   │   │   └── WorkflowStore.java
│   │   │   │   ├── StringBlob.java
│   │   │   │   ├── test
│   │   │   │   │   └── EmbeddedServletContainer.java
│   │   │   │   ├── util
│   │   │   │   │   ├── AuthUrlClient.java
│   │   │   │   │   ├── ClassUtils.java
│   │   │   │   │   ├── ConfigUtils.java
│   │   │   │   │   ├── CoordActionsInDateRange.java
│   │   │   │   │   ├── DateUtils.java
│   │   │   │   │   ├── db
│   │   │   │   │   │   ├── Schema.java
│   │   │   │   │   │   ├── SLADbOperations.java
│   │   │   │   │   │   ├── SLADbXOperations.java
│   │   │   │   │   │   ├── SqlStatement.java
│   │   │   │   │   │   └── ValidateConnectionBean.java
│   │   │   │   │   ├── ELConstantsFunctions.java
│   │   │   │   │   ├── ELEvaluationException.java
│   │   │   │   │   ├── ELEvaluator.java
│   │   │   │   │   ├── ELUtils.java
│   │   │   │   │   ├── FixedJsonInstanceSerializer.java
│   │   │   │   │   ├── GraphGenerator.java
│   │   │   │   │   ├── Instrumentable.java
│   │   │   │   │   ├── Instrumentation.java
│   │   │   │   │   ├── InstrumentUtils.java
│   │   │   │   │   ├── IOUtils.java
│   │   │   │   │   ├── JaasConfiguration.java
│   │   │   │   │   ├── JobsFilterUtils.java
│   │   │   │   │   ├── JobUtils.java
│   │   │   │   │   ├── LogUtils.java
│   │   │   │   │   ├── MappingRule.java
│   │   │   │   │   ├── MetricsInstrumentation.java
│   │   │   │   │   ├── MultiFileReader.java
│   │   │   │   │   ├── NamedThreadFactory.java
│   │   │   │   │   ├── OozieRollingPolicy.java
│   │   │   │   │   ├── Pair.java
│   │   │   │   │   ├── ParamChecker.java
│   │   │   │   │   ├── ParameterVerifierException.java
│   │   │   │   │   ├── ParameterVerifier.java
│   │   │   │   │   ├── PasswordMasker.java
│   │   │   │   │   ├── PollablePriorityDelayQueue.java
│   │   │   │   │   ├── PriorityDelayQueue.java
│   │   │   │   │   ├── PropertiesUtils.java
│   │   │   │   │   ├── SimpleTimestampedMessageParser.java
│   │   │   │   │   ├── StatusUtils.java
│   │   │   │   │   ├── TimestampedMessageParser.java
│   │   │   │   │   ├── WritableUtils.java
│   │   │   │   │   ├── XCallable.java
│   │   │   │   │   ├── XConfiguration.java
│   │   │   │   │   ├── XLogAuditFilter.java
│   │   │   │   │   ├── XLogFilter.java
│   │   │   │   │   ├── XLog.java
│   │   │   │   │   ├── XLogStreamer.java
│   │   │   │   │   ├── XLogUserFilterParam.java
│   │   │   │   │   ├── XmlUtils.java
│   │   │   │   │   └── ZKUtils.java
│   │   │   │   ├── workflow
│   │   │   │   │   ├── lite
│   │   │   │   │   │   ├── ActionNodeDef.java
│   │   │   │   │   │   ├── ActionNodeHandler.java
│   │   │   │   │   │   ├── ControlNodeDef.java
│   │   │   │   │   │   ├── ControlNodeHandler.java
│   │   │   │   │   │   ├── DBLiteWorkflowLib.java
│   │   │   │   │   │   ├── DecisionNodeDef.java
│   │   │   │   │   │   ├── DecisionNodeHandler.java
│   │   │   │   │   │   ├── EndNodeDef.java
│   │   │   │   │   │   ├── ForkNodeDef.java
│   │   │   │   │   │   ├── JoinNodeDef.java
│   │   │   │   │   │   ├── KillNodeDef.java
│   │   │   │   │   │   ├── LiteWorkflowApp.java
│   │   │   │   │   │   ├── LiteWorkflowAppParser.java
│   │   │   │   │   │   ├── LiteWorkflowInstance.java
│   │   │   │   │   │   ├── LiteWorkflowLib.java
│   │   │   │   │   │   ├── LiteWorkflowValidator.java
│   │   │   │   │   │   ├── NodeDef.java
│   │   │   │   │   │   ├── NodeHandler.java
│   │   │   │   │   │   └── StartNodeDef.java
│   │   │   │   │   ├── WorkflowApp.java
│   │   │   │   │   ├── WorkflowException.java
│   │   │   │   │   ├── WorkflowInstance.java
│   │   │   │   │   └── WorkflowLib.java
│   │   │   │   ├── WorkflowActionBean.java
│   │   │   │   ├── WorkflowJobBean.java
│   │   │   │   ├── WorkflowsInfo.java
│   │   │   │   └── XException.java
│   │   │   └── resources
│   │   │   ├── ehcache-default.xml
│   │   │   ├── hadoop-streaming.xml
│   │   │   ├── localoozie-log4j.properties
│   │   │   ├── META-INF
│   │   │   │   ├── oozie-derby-orm.xml
│   │   │   │   ├── oozie-hsqldb-orm.xml
│   │   │   │   ├── oozie-mysql-orm.xml
│   │   │   │   ├── oozie-oracle-orm.xml
│   │   │   │   ├── oozie-postgresql-orm.xml
│   │   │   │   ├── oozie-sqlserver-orm.xml
│   │   │   │   └── persistence.xml
│   │   │   ├── oozie-default.xml
│   │   │   ├── oozie-log4j.properties
│   │   │   ├── ssh-base.sh
│   │   │   └── ssh-wrapper.sh
│   │   └── test
│   │   ├── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   ├── hadoop
│   │   │   │   └── examples
│   │   │   │   └── SleepJob.java
│   │   │   └── oozie
│   │   │   ├── action
│   │   │   │   ├── decision
│   │   │   │   │   └── TestDecisionActionExecutor.java
│   │   │   │   ├── email
│   │   │   │   │   └── TestEmailActionExecutor.java
│   │   │   │   ├── hadoop
│   │   │   │   │   ├── ActionExecutorTestCase.java
│   │   │   │   │   ├── CredentialForTest.java
│   │   │   │   │   ├── InsertTestToken.java
│   │   │   │   │   ├── LauncherMainTester2.java
│   │   │   │   │   ├── LauncherMainTester.java
│   │   │   │   │   ├── MainTestCase.java
│   │   │   │   │   ├── MapperReducerCredentialsForTest.java
│   │   │   │   │   ├── MapperReducerForTest.java
│   │   │   │   │   ├── MapperReducerUberJarForTest.java
│   │   │   │   │   ├── SharelibUtils.java
│   │   │   │   │   ├── ShellTestCase.java
│   │   │   │   │   ├── TestCredentials.java
│   │   │   │   │   ├── TestDistCpActionExecutor.java
│   │   │   │   │   ├── TestDistcpMain.java
│   │   │   │   │   ├── TestFsActionExecutor.java
│   │   │   │   │   ├── TestFsELFunctions.java
│   │   │   │   │   ├── TestFSPrepareActions.java
│   │   │   │   │   ├── TestHadoopELFunctions.java
│   │   │   │   │   ├── TestHCatCredentials.java
│   │   │   │   │   ├── TestHCatPrepareActions.java
│   │   │   │   │   ├── TestJavaActionExecutor.java
│   │   │   │   │   ├── TestJavaMain.java
│   │   │   │   │   ├── TestLauncherFSURIHandler.java
│   │   │   │   │   ├── TestLauncherHCatURIHandler.java
│   │   │   │   │   ├── TestLauncher.java
│   │   │   │   │   ├── TestMapReduceActionError.java
│   │   │   │   │   ├── TestMapReduceMain.java
│   │   │   │   │   ├── TestOozieJobInfo.java
│   │   │   │   │   ├── TestPipesMain.java
│   │   │   │   │   ├── TestPrepareActionsDriver.java
│   │   │   │   │   ├── TestRerun.java
│   │   │   │   │   ├── TestShellActionExecutor.java
│   │   │   │   │   └── TestShellMain.java
│   │   │   │   ├── oozie
│   │   │   │   │   ├── JavaSleepAction.java
│   │   │   │   │   └── TestSubWorkflowActionExecutor.java
│   │   │   │   ├── ssh
│   │   │   │   │   ├── TestSshActionExecutorAsExtension.java
│   │   │   │   │   └── TestSshActionExecutor.java
│   │   │   │   ├── TestActionExecutor.java
│   │   │   │   └── TestActionFailover.java
│   │   │   ├── client
│   │   │   │   ├── HeaderTestingVersionServlet.java
│   │   │   │   ├── rest
│   │   │   │   │   ├── TestJsonCoordinatorAction.java
│   │   │   │   │   ├── TestJsonCoordinatorJob.java
│   │   │   │   │   ├── TestJsonWorkflowAction.java
│   │   │   │   │   └── TestJsonWorkflowJob.java
│   │   │   │   ├── TestLocalOozie.java
│   │   │   │   ├── TestOozieClientWithFakeServlet.java
│   │   │   │   ├── TestOozieCLI.java
│   │   │   │   ├── TestWorkflowClientException.java
│   │   │   │   ├── TestWorkflowClient.java
│   │   │   │   └── TestWorkflowXClient.java
│   │   │   ├── command
│   │   │   │   ├── bundle
│   │   │   │   │   ├── TestBulkBundleXCommand.java
│   │   │   │   │   ├── TestBundleChangeXCommand.java
│   │   │   │   │   ├── TestBundleJobSuspendXCommand.java
│   │   │   │   │   ├── TestBundleJobsXCommand.java
│   │   │   │   │   ├── TestBundleJobXCommand.java
│   │   │   │   │   ├── TestBundleKillXCommand.java
│   │   │   │   │   ├── TestBundlePauseUnpauseXCommand.java
│   │   │   │   │   ├── TestBundleRerunXCommand.java
│   │   │   │   │   ├── TestBundleStartXCommand.java
│   │   │   │   │   └── TestBundleSubmitXCommand.java
│   │   │   │   ├── coord
│   │   │   │   │   ├── CoordELExtensions.java
│   │   │   │   │   ├── CoordXTestCase.java
│   │   │   │   │   ├── TestAbandonedCoordChecker.java
│   │   │   │   │   ├── TestBulkCoordXCommand.java
│   │   │   │   │   ├── TestCoordActionInputCheckXCommand.java
│   │   │   │   │   ├── TestCoordActionInputCheckXCommandNonUTC.java
│   │   │   │   │   ├── TestCoordActionNotificationXCommand.java
│   │   │   │   │   ├── TestCoordActionReadyXCommand.java
│   │   │   │   │   ├── TestCoordActionsIgnoreXCommand.java
│   │   │   │   │   ├── TestCoordActionsKillXCommand.java
│   │   │   │   │   ├── TestCoordActionSkipXCommand.java
│   │   │   │   │   ├── TestCoordActionStartXCommand.java
│   │   │   │   │   ├── TestCoordActionUpdatePushMissingDependency.java
│   │   │   │   │   ├── TestCoordChangeXCommand.java
│   │   │   │   │   ├── TestCoordCommandUtils.java
│   │   │   │   │   ├── TestCoordELExtensions.java
│   │   │   │   │   ├── TestCoordJobsXCommand.java
│   │   │   │   │   ├── TestCoordKillXCommand.java
│   │   │   │   │   ├── TestCoordMaterializeTransitionXCommand.java
│   │   │   │   │   ├── TestCoordPushDependencyCheckXCommand.java
│   │   │   │   │   ├── TestCoordRerunXCommand.java
│   │   │   │   │   ├── TestCoordResumeXCommand.java
│   │   │   │   │   ├── TestCoordSubmitXCommand.java
│   │   │   │   │   ├── TestCoordSuspendXCommand.java
│   │   │   │   │   ├── TestCoordUpdateXCommand.java
│   │   │   │   │   ├── TestFutureActionsTimeOut.java
│   │   │   │   │   └── TestPastActionsTimeOut.java
│   │   │   │   ├── SkipCommitFaultInjection.java
│   │   │   │   ├── TestPurgeXCommand.java
│   │   │   │   ├── TestSLAAlertXCommand.java
│   │   │   │   ├── TestXCommand.java
│   │   │   │   └── wf
│   │   │   │   ├── HangServlet.java
│   │   │   │   ├── TestActionCheckXCommand.java
│   │   │   │   ├── TestActionErrors.java
│   │   │   │   ├── TestActionStartXCommand.java
│   │   │   │   ├── TestActionUserRetry.java
│   │   │   │   ├── TestBulkWorkflowXCommand.java
│   │   │   │   ├── TestCompletedActionXCommand.java
│   │   │   │   ├── TestForkedActionStartXCommand.java
│   │   │   │   ├── TestLastModified.java
│   │   │   │   ├── TestReRunXCommand.java
│   │   │   │   ├── TestSignalXCommand.java
│   │   │   │   ├── TestSubmitHiveXCommand.java
│   │   │   │   ├── TestSubmitMRXCommand.java
│   │   │   │   ├── TestSubmitPigXCommand.java
│   │   │   │   ├── TestSubmitSqoopXCommand.java
│   │   │   │   ├── TestSubmitXCommand.java
│   │   │   │   ├── TestWorkflowActionKillXCommand.java
│   │   │   │   ├── TestWorkflowKillXCommand.java
│   │   │   │   └── TestWorkflowNotificationXCommand.java
│   │   │   ├── compression
│   │   │   │   └── TestCodecFactory.java
│   │   │   ├── coord
│   │   │   │   ├── input
│   │   │   │   │   └── logic
│   │   │   │   │   ├── TestCoordinatorInputLogic.java
│   │   │   │   │   ├── TestCoordInputLogicPush.java
│   │   │   │   │   └── TestInputLogicParser.java
│   │   │   │   ├── TestCoordELEvaluator.java
│   │   │   │   ├── TestCoordELFunctions.java
│   │   │   │   ├── TestCoordUtils.java
│   │   │   │   └── TestHCatELFunctions.java
│   │   │   ├── dependency
│   │   │   │   ├── TestFSURIHandler.java
│   │   │   │   ├── TestHCatURIHandler.java
│   │   │   │   └── TestURIHandlerService.java
│   │   │   ├── event
│   │   │   │   ├── TestEventGeneration.java
│   │   │   │   └── TestEventQueue.java
│   │   │   ├── executor
│   │   │   │   └── jpa
│   │   │   │   ├── TestBatchQueryExecutor.java
│   │   │   │   ├── TestBulkMonitorJPAExecutor.java
│   │   │   │   ├── TestBundleActionQueryExecutor.java
│   │   │   │   ├── TestBundleActionsCountForJobGetJPAExecutor.java
│   │   │   │   ├── TestBundleJobInfoGetJPAExecutor.java
│   │   │   │   ├── TestBundleJobQueryExecutor.java
│   │   │   │   ├── TestBundleJobsDeleteJPAExecutor.java
│   │   │   │   ├── TestBundleJobsGetForPurgeJPAExecutor.java
│   │   │   │   ├── TestCoordActionGetForCheckJPAExecutor.java
│   │   │   │   ├── TestCoordActionGetForExternalIdJPAExecutor.java
│   │   │   │   ├── TestCoordActionGetForInfoJPAExecutor.java
│   │   │   │   ├── TestCoordActionGetForInputCheckJPAExecutor.java
│   │   │   │   ├── TestCoordActionGetForStartJPAExecutor.java
│   │   │   │   ├── TestCoordActionGetForTimeoutJPAExecutor.java
│   │   │   │   ├── TestCoordActionGetJPAExecutor.java
│   │   │   │   ├── TestCoordActionQueryExecutor.java
│   │   │   │   ├── TestCoordActionRemoveJPAExecutor.java
│   │   │   │   ├── TestCoordActionsActiveCountJPAExecutor.java
│   │   │   │   ├── TestCoordActionsCountForJobIdJPAExecutor.java
│   │   │   │   ├── TestCoordActionsDeleteJPAExecutor.java
│   │   │   │   ├── TestCoordActionsPendingFalseCountGetJPAExecutor.java
│   │   │   │   ├── TestCoordActionsPendingFalseStatusCountGetJPAExecutor.java
│   │   │   │   ├── TestCoordActionsRunningGetJPAExecutor.java
│   │   │   │   ├── TestCoordJobDeleteJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetActionByActionNumberJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetActionForNominalTimeJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetActionsJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetActionsNotCompletedJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetActionsRunningJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetActionsSubsetJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetActionsSuspendedJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetReadyActionsJPAExecutor.java
│   │   │   │   ├── TestCoordJobGetRunningActionsCountJPAExecutor.java
│   │   │   │   ├── TestCoordJobInfoGetJPAExecutor.java
│   │   │   │   ├── TestCoordJobQueryExecutor.java
│   │   │   │   ├── TestCoordJobsCountNotForPurgeFromParentIdJPAExecutor.java
│   │   │   │   ├── TestCoordJobsDeleteJPAExecutor.java
│   │   │   │   ├── TestCoordJobsGetForPurgeJPAExecutor.java
│   │   │   │   ├── TestCoordJobsGetFromParentIdJPAExecutor.java
│   │   │   │   ├── TestCoordJobsToBeMaterializedJPAExecutor.java
│   │   │   │   ├── TestSLAEventsGetForFilterJPAExecutor.java
│   │   │   │   ├── TestSLAEventsGetForSeqIdJPAExecutor.java
│   │   │   │   ├── TestSLAEventsGetJPAExecutor.java
│   │   │   │   ├── TestSLARegistrationQueryExecutor.java
│   │   │   │   ├── TestSLASummaryQueryExecutor.java
│   │   │   │   ├── TestWorkflowActionDeleteJPAExecutor.java
│   │   │   │   ├── TestWorkflowActionGetJPAExecutor.java
│   │   │   │   ├── TestWorkflowActionQueryExecutor.java
│   │   │   │   ├── TestWorkflowActionRetryManualGetJPAExecutor.java
│   │   │   │   ├── TestWorkflowActionsGetForJobJPAExecutor.java
│   │   │   │   ├── TestWorkflowActionSubsetGetJPAExecutor.java
│   │   │   │   ├── TestWorkflowIdGetForExternalIdJPAExecutor.java
│   │   │   │   ├── TestWorkflowInfoWithActionsSubsetGetJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobDeleteJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobGetActionsJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobGetJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobQueryExecutor.java
│   │   │   │   ├── TestWorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobsBasicInfoFromWorkflowParentIdJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobsDeleteJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobsGetForPurgeJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobsGetFromCoordParentIdJPAExecutor.java
│   │   │   │   ├── TestWorkflowJobsGetFromWorkflowParentIdJPAExecutor.java
│   │   │   │   └── TestWorkflowsJobGetJPAExecutor.java
│   │   │   ├── ForTestingActionExecutor.java
│   │   │   ├── jms
│   │   │   │   ├── TestDefaultConnectionContext.java
│   │   │   │   ├── TestHCatMessageHandler.java
│   │   │   │   ├── TestJMSJobEventListener.java
│   │   │   │   └── TestJMSSLAEventListener.java
│   │   │   ├── lock
│   │   │   │   └── TestMemoryLocks.java
│   │   │   ├── service
│   │   │   │   ├── DummyExecutor1.java
│   │   │   │   ├── DummyExecutor2.java
│   │   │   │   ├── DummyLogStreamingServlet.java
│   │   │   │   ├── DummyV2AdminServlet.java
│   │   │   │   ├── ExtendedCallableQueueService.java
│   │   │   │   ├── ForTestAuthorizationService.java
│   │   │   │   ├── ForTestWorkflowStoreService.java
│   │   │   │   ├── TestActionCheckerService.java
│   │   │   │   ├── TestActionConfFileType.java
│   │   │   │   ├── TestActionService.java
│   │   │   │   ├── TestAuthorizationService.java
│   │   │   │   ├── TestCallableQueueService.java
│   │   │   │   ├── TestCallbackService.java
│   │   │   │   ├── TestConfigurationService.java
│   │   │   │   ├── TestCoordMaterializeTriggerService.java
│   │   │   │   ├── TestDagXLogInfoService.java
│   │   │   │   ├── TestELService.java
│   │   │   │   ├── TestEventHandlerService.java
│   │   │   │   ├── TestGroupsService.java
│   │   │   │   ├── TestHadoopAccessorService.java
│   │   │   │   ├── TestHAPartitionDependencyManagerEhCache.java
│   │   │   │   ├── TestHAPartitionDependencyManagerService.java
│   │   │   │   ├── TestHAShareLibService.java
│   │   │   │   ├── TestHASLAService.java
│   │   │   │   ├── TestHCatAccessorService.java
│   │   │   │   ├── TestInstrumentationService.java
│   │   │   │   ├── TestJMSAccessorService.java
│   │   │   │   ├── TestJMSTopicService.java
│   │   │   │   ├── TestJobsConcurrencyService.java
│   │   │   │   ├── TestJPAService.java
│   │   │   │   ├── TestLiteWorkflowAppService.java
│   │   │   │   ├── TestLiteWorkflowStoreService.java
│   │   │   │   ├── TestMemoryLocksService.java
│   │   │   │   ├── TestMetricsInstrumentationService.java
│   │   │   │   ├── TestPartitionDependencyManagerEhcache.java
│   │   │   │   ├── TestPartitionDependencyManagerService.java
│   │   │   │   ├── TestPauseTransitService.java
│   │   │   │   ├── TestProxyUserService.java
│   │   │   │   ├── TestPurgeService.java
│   │   │   │   ├── TestRecoveryService.java
│   │   │   │   ├── TestSchedulerService.java
│   │   │   │   ├── TestSchemaService.java
│   │   │   │   ├── TestServices.java
│   │   │   │   ├── TestShareLibService.java
│   │   │   │   ├── TestSparkConfigurationService.java
│   │   │   │   ├── TestStatusTransitService.java
│   │   │   │   ├── TestStoreService.java
│   │   │   │   ├── TestUUIDService.java
│   │   │   │   ├── TestXLogService.java
│   │   │   │   ├── TestXLogStreamingService.java
│   │   │   │   ├── TestZKJobsConcurrencyService.java
│   │   │   │   ├── TestZKLocksService.java
│   │   │   │   ├── TestZKUUIDService.java
│   │   │   │   └── TestZKXLogStreamingService.java
│   │   │   ├── servlet
│   │   │   │   ├── DagServletTestCase.java
│   │   │   │   ├── MockCoordinatorEngineService.java
│   │   │   │   ├── MockDagEngineService.java
│   │   │   │   ├── MyJsonRestServlet.java
│   │   │   │   ├── TestAdminServlet.java
│   │   │   │   ├── TestAuthFilterAuthOozieClient.java
│   │   │   │   ├── TestBulkMonitorWebServiceAPI.java
│   │   │   │   ├── TestCallbackServlet.java
│   │   │   │   ├── TestHostnameFilter.java
│   │   │   │   ├── TestJobsServlet.java
│   │   │   │   ├── TestJsonRestServlet.java
│   │   │   │   ├── TestV0JobServlet.java
│   │   │   │   ├── TestV1AdminServlet.java
│   │   │   │   ├── TestV1JobServletBundleEngine.java
│   │   │   │   ├── TestV1JobServlet.java
│   │   │   │   ├── TestV1JobsServlet.java
│   │   │   │   ├── TestV2JobServlet.java
│   │   │   │   ├── TestV2SLAServlet.java
│   │   │   │   ├── TestV2ValidateServlet.java
│   │   │   │   └── TestVersionServlet.java
│   │   │   ├── sla
│   │   │   │   ├── TestSLACalculationJPAExecutor.java
│   │   │   │   ├── TestSLACalculatorMemory.java
│   │   │   │   ├── TestSLAEmailEventListener.java
│   │   │   │   ├── TestSLAEventGeneration.java
│   │   │   │   ├── TestSLAJobEventListener.java
│   │   │   │   ├── TestSLARegistrationGetJPAExecutor.java
│   │   │   │   ├── TestSLAService.java
│   │   │   │   └── TestSLASummaryGetOnRestartJPAExecutor.java
│   │   │   ├── store
│   │   │   │   ├── TestDBWorkflowStore.java
│   │   │   │   └── TestSLAStore.java
│   │   │   ├── test
│   │   │   │   ├── hive
│   │   │   │   │   ├── AbstractHiveService.java
│   │   │   │   │   └── MiniHS2.java
│   │   │   │   ├── MiniHCatServer.java
│   │   │   │   ├── MiniOozieTestCase.java
│   │   │   │   ├── PingServlet.java
│   │   │   │   ├── TestEmbeddedServletContainer.java
│   │   │   │   ├── TestXFsTestCase.java
│   │   │   │   ├── TestXTestCase.java
│   │   │   │   ├── XDataTestCase.java
│   │   │   │   ├── XFsTestCase.java
│   │   │   │   ├── XHCatTestCase.java
│   │   │   │   ├── XTestCase.java
│   │   │   │   └── ZKXTestCase.java
│   │   │   ├── TestActionBean.java
│   │   │   ├── TestBundleEngineSimple.java
│   │   │   ├── TestBundleJobBean.java
│   │   │   ├── TestCoordinatorEngine.java
│   │   │   ├── TestCoordinatorEngineSimple.java
│   │   │   ├── TestCoordinatorEngineStreamLog.java
│   │   │   ├── TestCoordinatorJobBean.java
│   │   │   ├── TestDagELFunctions.java
│   │   │   ├── TestDagEngine.java
│   │   │   ├── TestErrorCode.java
│   │   │   ├── TestLocalOozieClientCoord.java
│   │   │   ├── TestSLAEventBean.java
│   │   │   ├── TestV1JobsServletBundleEngine.java
│   │   │   ├── TestWorkflowBean.java
│   │   │   ├── util
│   │   │   │   ├── db
│   │   │   │   │   ├── TestSchema.java
│   │   │   │   │   ├── TestSLADbOperations.java
│   │   │   │   │   ├── TestSLADbXOperations.java
│   │   │   │   │   └── TestSqlStatement.java
│   │   │   │   ├── TestClassUtils.java
│   │   │   │   ├── TestConfigUtils.java
│   │   │   │   ├── TestCoordActionsInDateRange.java
│   │   │   │   ├── TestDateUtils.java
│   │   │   │   ├── TestELConstantsFunctions.java
│   │   │   │   ├── TestELEvaluator.java
│   │   │   │   ├── TestGraphGenerator.java
│   │   │   │   ├── TestInstrumentation.java
│   │   │   │   ├── TestIOUtils.java
│   │   │   │   ├── TestJaasConfiguration.java
│   │   │   │   ├── TestLogStreamer.java
│   │   │   │   ├── TestMetricsInstrumentation.java
│   │   │   │   ├── TestMultiFileReader.java
│   │   │   │   ├── TestOozieRollingPolicy.java
│   │   │   │   ├── TestParamChecker.java
│   │   │   │   ├── TestParameterVerifier.java
│   │   │   │   ├── TestPasswordMasker.java
│   │   │   │   ├── TestPriorityDelayQueue.java
│   │   │   │   ├── TestSimplifiedTimestampedMessageParser.java
│   │   │   │   ├── TestTimestampedMessageParser.java
│   │   │   │   ├── TestWritableUtils.java
│   │   │   │   ├── TestXConfiguration.java
│   │   │   │   ├── TestXLogFilter.java
│   │   │   │   ├── TestXLog.java
│   │   │   │   ├── TestXLogUserFilterParam.java
│   │   │   │   ├── TestXmlUtils.java
│   │   │   │   └── TestZKUtils.java
│   │   │   └── workflow
│   │   │   └── lite
│   │   │   ├── TestLiteWorkflowAppParser.java
│   │   │   └── TestLiteWorkflowLib.java
│   │   └── resources
│   │   ├── adminusers.txt
│   │   ├── auth-disabled-oozie-site.xml
│   │   ├── bundle-submit-job-with-functions.xml
│   │   ├── bundle-submit-job.xml
│   │   ├── coord-action-for-action-input-check.xml
│   │   ├── coord-action-for-action-push-check.xml
│   │   ├── coord-action-get.xml
│   │   ├── coord-action-sla1.xml
│   │   ├── coord-action-sla.xml
│   │   ├── coord-action-start-escape-strings.xml
│   │   ├── coord-dataset-absolute.xml
│   │   ├── coord-dataset-initial-instance.xml
│   │   ├── coord-dataset-offset.xml
│   │   ├── coord-el-dataset-4.xml
│   │   ├── coord-inputlogic-combine.xml
│   │   ├── coord-inputlogic-hcat.xml
│   │   ├── coord-inputlogic-latest.xml
│   │   ├── coord-inputlogic-range-latest.xml
│   │   ├── coord-inputlogic-range.xml
│   │   ├── coord-inputlogic.xml
│   │   ├── coord-job-bundle-negative.xml
│   │   ├── coord-job-bundle.xml
│   │   ├── coord-job-for-action-input-check.xml
│   │   ├── coord-job-for-elext.xml
│   │   ├── coord-job-for-matd-hcat.xml
│   │   ├── coord-job-for-matd-neg-hcat.xml
│   │   ├── coord-job-for-matd-relative.xml
│   │   ├── coord-job-get.xml
│   │   ├── coord-matd-job.xml
│   │   ├── coord-matLookup-trigger.xml
│   │   ├── coord-multiple-input-end-instance1.xml
│   │   ├── coord-multiple-input-end-instance2.xml
│   │   ├── coord-multiple-input-instance1.xml
│   │   ├── coord-multiple-input-instance2.xml
│   │   ├── coord-multiple-input-instance3.xml
│   │   ├── coord-multiple-input-instance4.xml
│   │   ├── coord-multiple-input-start-instance1.xml
│   │   ├── coord-multiple-input-start-instance2.xml
│   │   ├── coord-multiple-output-instance1.xml
│   │   ├── coord-multiple-output-instance2.xml
│   │   ├── coord-multiple-output-instance3.xml
│   │   ├── coord-multiple-output-instance4.xml
│   │   ├── coord-rerun-action1.xml
│   │   ├── coord-rerun-action2.xml
│   │   ├── coord-rerun-action3.xml
│   │   ├── coord-rerun-action4.xml
│   │   ├── coord-rerun-job.xml
│   │   ├── coord-update-test.xml
│   │   ├── derby-oozie-site.xml
│   │   ├── ehcache.xml
│   │   ├── failover-fs-wf.xml
│   │   ├── graphWF_26_actions.xml
│   │   ├── graphWF.xml
│   │   ├── hadoop-config.xml
│   │   ├── hadoop-site.xml
│   │   ├── hsqldb-oozie-site.xml
│   │   ├── instrumentation-os-env.json
│   │   ├── instrumentation-system-properties.json
│   │   ├── invalidGraphWF.xml
│   │   ├── mysql-oozie-site.xml
│   │   ├── oozie-site1.xml
│   │   ├── oozie-site2.xml
│   │   ├── oozie-sitealternate.xml
│   │   ├── oozie-site-coordel.xml
│   │   ├── oozie-site-instrumentation.xml
│   │   ├── oozie-site-mask.xml
│   │   ├── oozie-site-with-security.xml
│   │   ├── oracle-oozie-site.xml
│   │   ├── postgres-oozie-site.xml
│   │   ├── recovery-wf.xml
│   │   ├── rerun-elerr-wf.xml
│   │   ├── rerun-el-wf.xml
│   │   ├── rerun-varsub-wf.xml
│   │   ├── rerun-wf-fork.xml
│   │   ├── rerun-wf.xml
│   │   ├── test-action-config-1.xml
│   │   ├── test-action-config-2.xml
│   │   ├── test-action-config-3.xml
│   │   ├── test-action-config.xml
│   │   ├── test-custom-log4j.properties
│   │   ├── test-default-config-1.xml
│   │   ├── test-default-config.xml
│   │   ├── test-hadoop-config.xml
│   │   ├── test-ioutils.txt
│   │   ├── test-no-dash-log4j.properties
│   │   ├── test-oozie-default.xml
│   │   ├── test-oozie-log4j.properties
│   │   ├── test-oozie-with-prefix.xml
│   │   ├── userLogFilterTestlog.log
│   │   ├── wf-action-sla.xml
│   │   ├── wf-credentials.xml
│   │   ├── wf-ext-schema-invalid.xml
│   │   ├── wf-ext-schema-valid-user-retry.xml
│   │   ├── wf-ext-schema-valid.xml
│   │   ├── wf-ext-schema.xsd
│   │   ├── wf-fork.xml
│   │   ├── wf-invalid-fork.xml
│   │   ├── wf-job-sla.xml
│   │   ├── wf-long.xml
│   │   ├── wf-loop1-invalid.xml
│   │   ├── wf-loop2-invalid.xml
│   │   ├── wf-no-op.xml
│   │   ├── wf-race-condition.xml
│   │   ├── wf-schema-action-name-too-long.xml
│   │   ├── wf-schema-fs-no-namenode-global.xml
│   │   ├── wf-schema-fs-no-namenode.xml
│   │   ├── wf-schema-invalid-global-ext-no-global.xml
│   │   ├── wf-schema-invalid.xml
│   │   ├── wf-schema-no-jobtracker-global.xml
│   │   ├── wf-schema-no-jobtracker.xml
│   │   ├── wf-schema-no-namenode-global.xml
│   │   ├── wf-schema-no-namenode.xml
│   │   ├── wf-schema-subworkflow-propagate-no-global.xml
│   │   ├── wf-schema-valid-global-ext-no-global.xml
│   │   ├── wf-schema-valid-global-ext.xml
│   │   ├── wf-schema-valid-global-jobXml.xml
│   │   ├── wf-schema-valid-global.xml
│   │   ├── wf-schema-valid.xml
│   │   ├── wf-suspendpoints.xml
│   │   ├── wf-test-kill-node-message-error2.xml
│   │   ├── wf-test-kill-node-message-error.xml
│   │   ├── wf-test-kill-node-message.xml
│   │   ├── wf-transition-invalid.xml
│   │   ├── wf-unsupported-action.xml
│   │   └── wf-url-template.xml
│   ├── distro
│   │   ├── pom.xml
│   │   └── src
│   │   └── main
│   │   ├── bin
│   │   │   ├── addtowar.sh
│   │   │   ├── oozie.cmd
│   │   │   ├── oozied.cmd
│   │   │   ├── oozied.sh
│   │   │   ├── oozie-run.sh
│   │   │   ├── oozie-setup.cmd
│   │   │   ├── oozie-setup.ps1
│   │   │   ├── oozie-setup.sh
│   │   │   ├── oozie-start.sh
│   │   │   ├── oozie-stop.sh
│   │   │   ├── oozie-sys.cmd
│   │   │   └── oozie-sys.sh
│   │   └── tomcat
│   │   ├── logging.properties
│   │   ├── ROOT
│   │   │   ├── favicon.ico
│   │   │   ├── index.html
│   │   │   └── WEB-INF
│   │   │   └── web.xml
│   │   ├── server.xml
│   │   ├── ssl-server.xml
│   │   └── ssl-web.xml
│   ├── docs
│   │   ├── pom.xml
│   │   └── src
│   │   ├── main
│   │   │   ├── java
│   │   │   │   └── Dummy.java
│   │   │   └── webapp
│   │   │   ├── docs
│   │   │   │   └── configuration.xsl
│   │   │   └── WEB-INF
│   │   │   └── web.xml
│   │   └── site
│   │   ├── resources
│   │   │   └── DG_Overview.png
│   │   ├── site.xml
│   │   ├── twiki
│   │   │   ├── AG_ActionConfiguration.twiki
│   │   │   ├── AG_HadoopConfiguration.twiki
│   │   │   ├── AG_Install.twiki
│   │   │   ├── AG_Monitoring.twiki
│   │   │   ├── AG_OozieLogging.twiki
│   │   │   ├── AG_OozieUpgrade.twiki
│   │   │   ├── BundleFunctionalSpec.twiki
│   │   │   ├── CoordinatorFunctionalSpec.twiki
│   │   │   ├── DG_ActionAuthentication.twiki
│   │   │   ├── DG_CommandLineTool.twiki
│   │   │   ├── DG_CoordinatorRerun.twiki
│   │   │   ├── DG_CustomActionExecutor.twiki
│   │   │   ├── DG_DistCpActionExtension.twiki
│   │   │   ├── DG_EmailActionExtension.twiki
│   │   │   ├── DG_Examples.twiki
│   │   │   ├── DG_HCatalogIntegration.twiki
│   │   │   ├── DG_Hive2ActionExtension.twiki
│   │   │   ├── DG_HiveActionExtension.twiki
│   │   │   ├── DG_JMSNotifications.twiki
│   │   │   ├── DG_Overview.twiki
│   │   │   ├── DG_QuickStart.twiki
│   │   │   ├── DG_ShellActionExtension.twiki
│   │   │   ├── DG_SLAMonitoring.twiki
│   │   │   ├── DG_SparkActionExtension.twiki
│   │   │   ├── DG_SqoopActionExtension.twiki
│   │   │   ├── DG_SshActionExtension.twiki
│   │   │   ├── DG_WorkflowReRun.twiki
│   │   │   ├── ENG_Building.twiki
│   │   │   ├── ENG_Custom_Authentication.twiki
│   │   │   ├── ENG_MiniOozie.twiki
│   │   │   ├── index.twiki
│   │   │   ├── WebServicesAPI.twiki
│   │   │   └── WorkflowFunctionalSpec.twiki
│   │   └── web.xml
│   ├── examples
│   │   ├── pom.xml
│   │   └── src
│   │   ├── main
│   │   │   ├── apps
│   │   │   │   ├── aggregator
│   │   │   │   │   ├── coordinator-with-offset.xml
│   │   │   │   │   ├── coordinator.xml
│   │   │   │   │   ├── job.properties
│   │   │   │   │   ├── job-with-offset.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── bundle
│   │   │   │   │   ├── bundle.xml
│   │   │   │   │   └── job.properties
│   │   │   │   ├── coord-input-logic
│   │   │   │   │   ├── coordinator.xml
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── cron
│   │   │   │   │   ├── coordinator.xml
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── cron-schedule
│   │   │   │   │   ├── coordinator.xml
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── custom-main
│   │   │   │   │   ├── id.pig
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── datelist-java-main
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── demo
│   │   │   │   │   ├── id.pig
│   │   │   │   │   ├── job.properties
│   │   │   │   │   ├── job.windows.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── distcp
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── hadoop-el
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── hcatalog
│   │   │   │   │   ├── coordinator.xml
│   │   │   │   │   ├── id.pig
│   │   │   │   │   ├── job.properties
│   │   │   │   │   ├── job.properties.security
│   │   │   │   │   ├── README
│   │   │   │   │   ├── workflow.xml
│   │   │   │   │   └── workflow.xml.security
│   │   │   │   ├── hive
│   │   │   │   │   ├── job.properties
│   │   │   │   │   ├── README
│   │   │   │   │   ├── script.q
│   │   │   │   │   ├── workflow.xml
│   │   │   │   │   └── workflow.xml.security
│   │   │   │   ├── hive2
│   │   │   │   │   ├── job.properties
│   │   │   │   │   ├── job.properties.security
│   │   │   │   │   ├── README
│   │   │   │   │   ├── script.q
│   │   │   │   │   ├── workflow.xml
│   │   │   │   │   └── workflow.xml.security
│   │   │   │   ├── java-main
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── map-reduce
│   │   │   │   │   ├── job.properties
│   │   │   │   │   ├── job-with-config-class.properties
│   │   │   │   │   ├── workflow-with-config-class.xml
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── no-op
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── pig
│   │   │   │   │   ├── id.pig
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── shell
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── sla
│   │   │   │   │   ├── coordinator.xml
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── spark
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── sqoop
│   │   │   │   │   ├── db.hsqldb.properties
│   │   │   │   │   ├── db.hsqldb.script
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── sqoop-freeform
│   │   │   │   │   ├── db.hsqldb.properties
│   │   │   │   │   ├── db.hsqldb.script
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── ssh
│   │   │   │   │   ├── job.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   ├── streaming
│   │   │   │   │   ├── job.properties
│   │   │   │   │   ├── job.windows.properties
│   │   │   │   │   └── workflow.xml
│   │   │   │   └── subwf
│   │   │   │   ├── job.properties
│   │   │   │   └── workflow.xml
│   │   │   ├── data
│   │   │   │   ├── data.txt
│   │   │   │   ├── log01.txt
│   │   │   │   ├── log02.txt
│   │   │   │   ├── log03.txt
│   │   │   │   ├── log04.txt
│   │   │   │   ├── log05.txt
│   │   │   │   ├── log06.txt
│   │   │   │   └── _SUCCESS
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── example
│   │   │   ├── DateList.java
│   │   │   ├── DemoJavaMain.java
│   │   │   ├── DemoMapper.java
│   │   │   ├── DemoMapReduceMain.java
│   │   │   ├── DemoPigMain.java
│   │   │   ├── DemoReducer.java
│   │   │   ├── LocalOozieExample.java
│   │   │   ├── Repeatable.java
│   │   │   ├── SampleMapper.java
│   │   │   ├── SampleOozieActionConfigurator.java
│   │   │   ├── SampleReducer.java
│   │   │   ├── SparkFileCopy.java
│   │   │   └── TimeUnit.java
│   │   └── test
│   │   ├── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── example
│   │   │   └── TestLocalOozieExample.java
│   │   └── resources
│   │   ├── derby-oozie-site.xml
│   │   ├── hsqldb-oozie-site.xml
│   │   ├── localoozieexample-end.properties
│   │   ├── localoozieexample-kill.properties
│   │   ├── localoozieexample-wf.xml
│   │   ├── mysql-oozie-site.xml
│   │   └── oracle-oozie-site.xml
│   ├── hadooplibs
│   │   ├── hadoop-auth-1
│   │   │   └── pom.xml
│   │   ├── hadoop-auth-2
│   │   │   └── pom.xml
│   │   ├── hadoop-distcp-1
│   │   │   └── pom.xml
│   │   ├── hadoop-distcp-2
│   │   │   └── pom.xml
│   │   ├── hadoop-distcp-3
│   │   │   └── pom.xml
│   │   ├── hadoop-utils-1
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   └── main
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   ├── action
│   │   │   │   └── hadoop
│   │   │   │   └── LauncherMainHadoopUtils.java
│   │   │   └── hadoop
│   │   │   └── utils
│   │   │   └── HadoopShims.java
│   │   ├── hadoop-utils-2
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   └── main
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   ├── action
│   │   │   │   └── hadoop
│   │   │   │   └── LauncherMainHadoopUtils.java
│   │   │   └── hadoop
│   │   │   └── utils
│   │   │   └── HadoopShims.java
│   │   ├── hadoop-utils-3
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   └── main
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   ├── action
│   │   │   │   └── hadoop
│   │   │   │   └── LauncherMainHadoopUtils.java
│   │   │   └── hadoop
│   │   │   └── utils
│   │   │   └── HadoopShims.java
│   │   └── pom.xml
│   ├── LICENSE.txt
│   ├── login
│   │   ├── pom.xml
│   │   ├── README.txt
│   │   └── src
│   │   ├── main
│   │   │   ├── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   ├── authentication
│   │   │   │   │   ├── AltKerberosAuthenticationHandler.java
│   │   │   │   │   └── ExampleAltAuthenticationHandler.java
│   │   │   │   └── servlet
│   │   │   │   └── login
│   │   │   │   ├── LDAPLoginServlet.java
│   │   │   │   └── LoginServlet.java
│   │   │   ├── resources
│   │   │   │   └── login-page-template.html
│   │   │   └── webapp
│   │   │   ├── META-INF
│   │   │   │   └── context.xml
│   │   │   └── WEB-INF
│   │   │   └── web.xml
│   │   └── test
│   │   └── java
│   │   └── org
│   │   └── apache
│   │   └── oozie
│   │   ├── authentication
│   │   │   └── TestExampleAltAuthenticationHandler.java
│   │   └── servlet
│   │   └── login
│   │   ├── TestLDAPLoginServlet.java
│   │   └── TestLoginServlet.java
│   ├── minitest
│   │   ├── pom.xml
│   │   └── src
│   │   └── test
│   │   ├── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── test
│   │   │   └── WorkflowTest.java
│   │   └── resources
│   │   ├── hsqldb-oozie-site.xml
│   │   ├── oozie-log4j.properties
│   │   └── wf-test.xml
│   ├── NOTICE.txt
│   ├── pom.xml
│   ├── README.txt
│   ├── release-log.txt
│   ├── sharelib
│   │   ├── distcp
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   └── main
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── action
│   │   │   └── hadoop
│   │   │   └── DistcpMain.java
│   │   ├── hcatalog
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   ├── main
│   │   │   │   └── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   ├── action
│   │   │   │   │   └── hadoop
│   │   │   │   │   └── HCatLauncherURIHandler.java
│   │   │   │   └── util
│   │   │   │   └── HCatURI.java
│   │   │   └── test
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── util
│   │   │   └── TestHCatURI.java
│   │   ├── hive
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   ├── main
│   │   │   │   └── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   └── action
│   │   │   │   └── hadoop
│   │   │   │   └── HiveMain.java
│   │   │   └── test
│   │   │   ├── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   └── action
│   │   │   │   └── hadoop
│   │   │   │   ├── TestHiveActionExecutor.java
│   │   │   │   └── TestHiveMain.java
│   │   │   └── resources
│   │   │   └── HiveMain.txt
│   │   ├── hive2
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   ├── main
│   │   │   │   └── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   └── action
│   │   │   │   └── hadoop
│   │   │   │   └── Hive2Main.java
│   │   │   └── test
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── action
│   │   │   └── hadoop
│   │   │   └── TestHive2ActionExecutor.java
│   │   ├── oozie
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   └── main
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── action
│   │   │   └── hadoop
│   │   │   ├── ActionStats.java
│   │   │   ├── ActionType.java
│   │   │   ├── FSLauncherURIHandler.java
│   │   │   ├── JavaMain.java
│   │   │   ├── LauncherException.java
│   │   │   ├── LauncherMain.java
│   │   │   ├── LauncherMapper.java
│   │   │   ├── LauncherURIHandlerFactory.java
│   │   │   ├── LauncherURIHandler.java
│   │   │   ├── MapReduceMain.java
│   │   │   ├── MRStats.java
│   │   │   ├── OozieActionConfiguratorException.java
│   │   │   ├── OozieActionConfigurator.java
│   │   │   ├── OozieLauncherInputFormat.java
│   │   │   ├── OozieLauncherOutputCommitter.java
│   │   │   ├── OozieLauncherOutputFormat.java
│   │   │   ├── PipesMain.java
│   │   │   ├── PrepareActionsDriver.java
│   │   │   └── ShellMain.java
│   │   ├── pig
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   ├── main
│   │   │   │   └── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   └── action
│   │   │   │   └── hadoop
│   │   │   │   ├── OoziePigStats.java
│   │   │   │   ├── PigMain.java
│   │   │   │   └── PigMainWithOldAPI.java
│   │   │   └── test
│   │   │   ├── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   └── action
│   │   │   │   └── hadoop
│   │   │   │   ├── PigTestCase.java
│   │   │   │   ├── TestPigActionExecutor.java
│   │   │   │   ├── TestPigMain.java
│   │   │   │   ├── TestPigMainWithOldAPI.java
│   │   │   │   └── UDFTester.java
│   │   │   └── resources
│   │   │   └── PigMain.txt
│   │   ├── pom.xml
│   │   ├── spark
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   ├── main
│   │   │   │   └── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   └── action
│   │   │   │   └── hadoop
│   │   │   │   └── SparkMain.java
│   │   │   └── test
│   │   │   ├── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   └── action
│   │   │   │   └── hadoop
│   │   │   │   ├── TestPyspark.java
│   │   │   │   ├── TestSparkActionExecutor.java
│   │   │   │   ├── TestSparkMain.java
│   │   │   │   └── TestSparkOptionsSplitter.java
│   │   │   └── resources
│   │   │   ├── pi.py
│   │   │   ├── py4j-0.9-src.zip
│   │   │   └── pyspark.zip
│   │   ├── sqoop
│   │   │   ├── pom.xml
│   │   │   └── src
│   │   │   ├── main
│   │   │   │   └── java
│   │   │   │   └── org
│   │   │   │   └── apache
│   │   │   │   └── oozie
│   │   │   │   └── action
│   │   │   │   └── hadoop
│   │   │   │   └── SqoopMain.java
│   │   │   └── test
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── action
│   │   │   └── hadoop
│   │   │   └── TestSqoopActionExecutor.java
│   │   ├── src
│   │   │   └── main
│   │   │   └── resources
│   │   │   └── sharelib.properties
│   │   └── streaming
│   │   ├── pom.xml
│   │   └── src
│   │   ├── main
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── action
│   │   │   └── hadoop
│   │   │   └── StreamingMain.java
│   │   └── test
│   │   └── java
│   │   └── org
│   │   └── apache
│   │   └── oozie
│   │   └── action
│   │   └── hadoop
│   │   ├── OozieActionConfiguratorForTest.java
│   │   ├── TestMapReduceActionExecutor.java
│   │   └── TestStreamingMain.java
│   ├── source-headers.txt
│   ├── src
│   │   └── main
│   │   ├── assemblies
│   │   │   ├── client.xml
│   │   │   ├── distro.xml
│   │   │   ├── docs.xml
│   │   │   ├── empty.xml
│   │   │   ├── examples.xml
│   │   │   ├── partial-sharelib.xml
│   │   │   ├── sharelib.xml
│   │   │   └── tools.xml
│   │   └── resources
│   │   ├── checkstyle-header.txt
│   │   └── checkstyle.xml
│   ├── tools
│   │   ├── pom.xml
│   │   └── src
│   │   ├── main
│   │   │   ├── bin
│   │   │   │   ├── ooziedb.cmd
│   │   │   │   └── ooziedb.sh
│   │   │   └── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── tools
│   │   │   ├── OozieDBCLI.java
│   │   │   ├── OozieDBExportCLI.java
│   │   │   ├── OozieDBImportCLI.java
│   │   │   └── OozieSharelibCLI.java
│   │   └── test
│   │   ├── java
│   │   │   └── org
│   │   │   └── apache
│   │   │   └── oozie
│   │   │   └── tools
│   │   │   ├── FakeConnection.java
│   │   │   ├── FakeDriver.java
│   │   │   ├── LauncherSecurityManager.java
│   │   │   ├── TestDBLoadDump.java
│   │   │   ├── TestOozieDBCLI.java
│   │   │   ├── TestOozieMySqlDBCLI.java
│   │   │   └── TestOozieSharelibCLI.java
│   │   └── resources
│   │   ├── dumpData
│   │   │   ├── ooziedb_ac.json
│   │   │   ├── ooziedb_bna.json
│   │   │   ├── ooziedb_bnj.json
│   │   │   ├── ooziedb_ca.json
│   │   │   ├── ooziedb_cj.json
│   │   │   ├── ooziedb_slareg.json
│   │   │   ├── ooziedb_slasum.json
│   │   │   ├── ooziedb_sysinfo.json
│   │   │   └── ooziedb_wf.json
│   │   ├── fake-oozie-site.xml
│   │   └── hsqldb-oozie-site.xml
│   ├── utils
│   │   └── dbutils
│   │   └── updatescripts
│   │   ├── dbscripts-2.2.5.sql
│   │   ├── dbscripts-3.0.0.sql
│   │   ├── dbscripts-3.0.1.sql
│   │   ├── dbscripts-3.1.0.sql
│   │   ├── readme.txt
│   │   ├── updatescripts-2.x-to-3.0.0.sql
│   │   ├── updatescripts-2.x-to-3.0.1.sql
│   │   ├── updatescripts-3.0.0-to-3.0.1.sql
│   │   ├── updatescripts-3.x-to-3.1.0.sql
│   │   └── upgradescript-2.x-to-3.0.0.sql
│   ├── webapp
│   │   ├── pom.xml
│   │   └── src
│   │   └── main
│   │   ├── resources
│   │   └── webapp
│   │   ├── admin
│   │   │   └── jvminfo.jsp
│   │   ├── console
│   │   │   └── sla
│   │   │   ├── css
│   │   │   │   ├── ColVis.css
│   │   │   │   ├── images
│   │   │   │   │   ├── arrow-down.gif
│   │   │   │   │   ├── arrow-left.gif
│   │   │   │   │   ├── arrow-right.gif
│   │   │   │   │   ├── arrow-up.gif
│   │   │   │   │   ├── ui-bg_flat_100_DEECFD_40x100.png
│   │   │   │   │   ├── ui-bg_glass_100_f6f6f6_1x400.png
│   │   │   │   │   ├── ui-bg_glass_65_ffffff_1x400.png
│   │   │   │   │   ├── ui-bg_highlight-soft_100_eeeeee_1x100.png
│   │   │   │   │   └── ui-icons_222222_256x240.png
│   │   │   │   ├── jquery.dataTables.css
│   │   │   │   ├── jquery-ui-1.10.3.custom.min.css
│   │   │   │   ├── oozie-sla.css
│   │   │   │   ├── oozie-sla-graph.css
│   │   │   │   ├── oozie-sla-table.css
│   │   │   │   └── TableTools.css
│   │   │   ├── js
│   │   │   │   ├── graph
│   │   │   │   │   ├── jquery.flot.min.js
│   │   │   │   │   ├── jquery.flot.navigate.min.js
│   │   │   │   │   ├── jquery.flot.selection.min.js
│   │   │   │   │   └── jquery.flot.time.min.js
│   │   │   │   ├── oozie-sla-graph.js
│   │   │   │   ├── oozie-sla.js
│   │   │   │   ├── oozie-sla-table.js
│   │   │   │   └── table
│   │   │   │   ├── ColVis.min.js
│   │   │   │   ├── copy_csv_xls_pdf.swf
│   │   │   │   ├── jquery-1.8.3.min.js
│   │   │   │   ├── jquery.dataTables.min.js
│   │   │   │   ├── jquery-ui-1.10.3.custom.min.js
│   │   │   │   ├── jquery-ui-timepicker-addon.js
│   │   │   │   └── TableTools.min.js
│   │   │   └── oozie-sla.html
│   │   ├── index.jsp
│   │   ├── META-INF
│   │   │   └── context.xml
│   │   ├── oozie_50x.png
│   │   ├── oozie-console.css
│   │   ├── oozie-console.js
│   │   └── WEB-INF
│   │   └── web.xml
│   ├── work.log
│   └── zookeeper-security-tests
│   ├── pom.xml
│   └── src
│   └── test
│   └── java
│   └── org
│   └── apache
│   └── oozie
│   ├── test
│   │   └── ZKXTestCaseWithSecurity.java
│   └── util
│   └── TestZKUtilsWithSecurity.java
└── readme.txt

437 directories, 1465 files