Constant Field Values

Contents

• azkaban.*

azkaban.*

azkaban.Constants

Modifier and Type	Constant Field	Value
public static final double	AZKABAN_FLOW_VERSION_2_0	2.0
public static final java.lang.String	AZKABAN_PRIVATE_PROPERTIES_FILE	"azkaban.private.properties"
public static final java.lang.String	AZKABAN_PROPERTIES_FILE	"azkaban.properties"
public static final java.lang.String	AZKABAN_SERVLET_CONTEXT_KEY	"azkaban_app"
public static final java.lang.String	AZKABAN_SLA_CHECKER_USERNAME	"azkaban_sla"
public static final double	DEFAULT_AZKABAN_FLOW_VERSION	1.0
public static final int	DEFAULT_AZKABAN_POLLING_CRITERIA_CPU_LOAD_PERIOD_SEC	60
public static final int	DEFAULT_AZKABAN_POLLING_INTERVAL_MS	1000
public static final boolean	DEFAULT_AZKABAN_RAMP_ENABLED	false
public static final int	DEFAULT_AZKABAN_RAMP_STATUS_POLLING_INTERVAL	10
public static final boolean	DEFAULT_AZKABAN_RAMP_STATUS_POOLING_ENABLED	false
public static final int	DEFAULT_AZKABAN_RAMP_STATUS_PULL_INTERVAL_MAX	50
public static final int	DEFAULT_AZKABAN_RAMP_STATUS_PUSH_INTERVAL_MAX	20
public static final java.lang.String	DEFAULT_CONF_PATH	"conf"
public static final java.lang.String	DEFAULT_EXECUTOR_PORT_FILE	"executor.port"
public static final int	DEFAULT_JETTY_MAX_THREAD_COUNT	20
public static final java.lang.String	DEFAULT_LOCKED_FLOW_ERROR_MESSAGE	"Flow %s in project %s is locked. This is either a repeatedly failing flow, or an ineffcient flow. Please refer to the Dr. Elephant report for this flow for more information."
public static final int	DEFAULT_MAX_ONCURRENT_RUNS_ONEFLOW	30
public static final int	DEFAULT_PORT_NUMBER	8081
public static final long	DEFAULT_SCHEDULE_END_EPOCH_TIME	2524608000000L
public static final int	DEFAULT_SSL_PORT_NUMBER	8443
public static final int	FAILED_EXEC_ID	-2
public static final java.lang.String	FLOW_FILE_SUFFIX	".flow"
public static final java.lang.String	FLOW_NODE_TYPE	"flow"
public static final java.lang.String	JOB_OVERRIDE_SUFFIX	".jor"
public static final long	MEMORY_CHECK_INTERVAL_MS	60000L
public static final int	MEMORY_CHECK_RETRY_LIMIT	720
public static final java.lang.String	NODE_TYPE	"type"
public static final java.lang.String	PATH_DELIMITER	":"
public static final java.lang.String	PROJECT_FILE_SUFFIX	".project"
public static final int	UNASSIGNED_EXEC_ID	-1

azkaban.Constants.ConfigurationKeys

Modifier and Type	Constant Field	Value
public static final java.lang.String	ACTIVE_EXECUTOR_REFRESH_IN_MS	"azkaban.activeexecutor.refresh.milisecinterval"
public static final java.lang.String	ACTIVE_EXECUTOR_REFRESH_IN_NUM_FLOW	"azkaban.activeexecutor.refresh.flowinterval"
public static final java.lang.String	AZKABAN_ADMIN_ALERT_EMAIL	"azkaban.admin.alert.email"
public static final java.lang.String	AZKABAN_DEPENDENCY_MAX_DOWNLOAD_TRIES	"azkaban.dependency.max.download.tries"
public static final java.lang.String	AZKABAN_EVENT_REPORTING_CLASS_PARAM	"azkaban.event.reporting.class"
public static final java.lang.String	AZKABAN_EVENT_REPORTING_ENABLED	"azkaban.event.reporting.enabled"
public static final java.lang.String	AZKABAN_EVENT_REPORTING_KAFKA_BROKERS	"azkaban.event.reporting.kafka.brokers"
public static final java.lang.String	AZKABAN_EVENT_REPORTING_KAFKA_SCHEMA_REGISTRY_URL	"azkaban.event.reporting.kafka.schema.registry.url"
public static final java.lang.String	AZKABAN_EVENT_REPORTING_KAFKA_TOPIC	"azkaban.event.reporting.kafka.topic"
public static final java.lang.String	AZKABAN_EVENT_REPORTING_PROPERTIES_TO_PROPAGATE	"azkaban.event.reporting.propagateProperties"
public static final java.lang.String	AZKABAN_EXECUTOR_HEALTHCHECK_INTERVAL_MIN	"azkaban.executor.healthcheck.interval.min"
public static final java.lang.String	AZKABAN_EXECUTOR_MAX_FAILURE_COUNT	"azkaban.executor.max.failurecount"
public static final java.lang.String	AZKABAN_FLOW_VERSION	"azkaban-flow-version"
public static final java.lang.String	AZKABAN_GLOBAL_PROPERTIES_EXT_PATH	"executor.global.properties"
public static final java.lang.String	AZKABAN_KERBEROS_PRINCIPAL	"azkaban.kerberos.principal"
public static final java.lang.String	AZKABAN_KEYTAB_PATH	"azkaban.keytab.path"
public static final java.lang.String	AZKABAN_LOCKED_FLOW_ERROR_MESSAGE	"azkaban.locked.flow.error.message"
public static final java.lang.String	AZKABAN_MAX_FLOW_RUNNING_MINS	"azkaban.server.flow.max.running.minutes"
public static final java.lang.String	AZKABAN_PID_FILENAME	"azkaban.pid.filename"
public static final java.lang.String	AZKABAN_POLL_MODEL	"azkaban.poll.model"
public static final java.lang.String	AZKABAN_POLLING_CRITERIA_CPU_LOAD_PERIOD_SEC	"azkaban.polling_criteria.cpu_load_period_sec"
public static final java.lang.String	AZKABAN_POLLING_CRITERIA_FLOW_THREADS_AVAILABLE	"azkaban.polling_criteria.flow_threads_available"
public static final java.lang.String	AZKABAN_POLLING_CRITERIA_MAX_CPU_UTILIZATION_PCT	"azkaban.polling_criteria.max_cpu_utilization_pct"
public static final java.lang.String	AZKABAN_POLLING_CRITERIA_MIN_FREE_MEMORY_GB	"azkaban.polling_criteria.min_free_memory_gb"
public static final java.lang.String	AZKABAN_POLLING_INTERVAL_MS	"azkaban.polling.interval.ms"
public static final java.lang.String	AZKABAN_POLLING_LOCK_ENABLED	"azkaban.polling.lock.enabled"
public static final java.lang.String	AZKABAN_RAMP_ENABLED	"azkaban.ramp.enabled"
public static final java.lang.String	AZKABAN_RAMP_STATUS_POLLING_CPU_MAX	"azkaban.ramp.status.polling.cpu.max"
public static final java.lang.String	AZKABAN_RAMP_STATUS_POLLING_ENABLED	"azkaban.ramp.status.polling.enabled"
public static final java.lang.String	AZKABAN_RAMP_STATUS_POLLING_INTERVAL	"azkaban.ramp.status.polling.interval"
public static final java.lang.String	AZKABAN_RAMP_STATUS_POLLING_MEMORY_MIN	"azkaban.ramp.status.polling.memory.min"
public static final java.lang.String	AZKABAN_RAMP_STATUS_PULL_INTERVAL_MAX	"azkaban.ramp.status.pull.interval.max"
public static final java.lang.String	AZKABAN_RAMP_STATUS_PUSH_INTERVAL_MAX	"azkaban.ramp.status.push.interval.max"
public static final java.lang.String	AZKABAN_SERVER_EXTERNAL_ANALYZER_LABEL	"azkaban.server.external.analyzer.label"
public static final java.lang.String	AZKABAN_SERVER_EXTERNAL_ANALYZER_TOPIC	"azkaban.server.external.analyzer.topic"
public static final java.lang.String	AZKABAN_SERVER_EXTERNAL_LOGVIEWER_LABEL	"azkaban.server.external.logviewer.label"
public static final java.lang.String	AZKABAN_SERVER_EXTERNAL_LOGVIEWER_TOPIC	"azkaban.server.external.logviewer.topic"
public static final java.lang.String	AZKABAN_SERVER_EXTERNAL_TOPIC_URL	"azkaban.server.external.${topic}.url"
public static final java.lang.String	AZKABAN_SERVER_EXTERNAL_TOPICS	"azkaban.server.external.topics"
public static final java.lang.String	AZKABAN_SERVER_GROUP_NAME	"azkaban.group.name"
public static final java.lang.String	AZKABAN_SERVER_HOST_NAME	"azkaban.server.hostname"
public static final java.lang.String	AZKABAN_SERVER_LOGGING_KAFKA_BROKERLIST	"azkaban.server.logging.kafka.brokerList"
public static final java.lang.String	AZKABAN_SERVER_LOGGING_KAFKA_TOPIC	"azkaban.server.logging.kafka.topic"
public static final java.lang.String	AZKABAN_SERVER_NATIVE_LIB_FOLDER	"azkaban.native.lib"
public static final java.lang.String	AZKABAN_STORAGE_ARTIFACT_MAX_RETENTION	"azkaban.storage.artifact.max.retention"
public static final java.lang.String	AZKABAN_STORAGE_CACHE_DEPENDENCY_ENABLED	"azkaban.storage.cache.dependency.enabled"
public static final java.lang.String	AZKABAN_STORAGE_CACHE_DEPENDENCY_ROOT_URI	"azkaban.storage.cache.dependency_root.uri"
public static final java.lang.String	AZKABAN_STORAGE_HDFS_PROJECT_ROOT_URI	"azkaban.storage.hdfs.root.uri"
public static final java.lang.String	AZKABAN_STORAGE_LOCAL_BASEDIR	"azkaban.storage.local.basedir"
public static final java.lang.String	AZKABAN_STORAGE_ORIGIN_DEPENDENCY_ROOT_URI	"azkaban.storage.origin.dependency_root.uri"
public static final java.lang.String	AZKABAN_STORAGE_TYPE	"azkaban.storage.type"
public static final java.lang.String	AZKABAN_WEBSERVER_EXTERNAL_HOSTNAME	"azkaban.webserver.external_hostname"
public static final java.lang.String	AZKABAN_WEBSERVER_EXTERNAL_PORT	"azkaban.webserver.external_port"
public static final java.lang.String	AZKABAN_WEBSERVER_EXTERNAL_SSL_PORT	"azkaban.webserver.external_ssl_port"
public static final java.lang.String	BLACK_LISTED_USERS	"azkaban.server.blacklist.users"
public static final java.lang.String	CONCURRENT_RUNS_ONEFLOW_WHITELIST	"azkaban.concurrent.runs.oneflow.whitelist"
public static final java.lang.String	CUSTOM_CREDENTIAL_NAME	"azkaban.security.credential"
public static final java.lang.String	CUSTOM_METRICS_REPORTER_CLASS_NAME	"azkaban.metrics.reporter.name"
public static final java.lang.String	DEPENDENCY_PLUGIN_DIR	"azkaban.dependency.plugin.dir"
public static final java.lang.String	DISPLAY_EXECUTION_PAGE_SIZE	"azkaban.display.execution_page_size"
public static final java.lang.String	ENABLE_QUARTZ	"azkaban.server.schedule.enable_quartz"
public static final java.lang.String	EXECUTION_LOGS_CLEANUP_INTERVAL_SECONDS	"execution.logs.cleanup.interval.seconds"
public static final java.lang.String	EXECUTION_LOGS_CLEANUP_RECORD_LIMIT	"execution.logs.cleanup.record.limit"
public static final java.lang.String	EXECUTION_LOGS_RETENTION_MS	"execution.logs.retention.ms"
public static final java.lang.String	EXECUTOR_PORT	"executor.port"
public static final java.lang.String	EXECUTOR_PORT_FILE	"executor.portfile"
public static final java.lang.String	EXECUTOR_SELECTOR_COMPARATOR_PREFIX	"azkaban.executorselector.comparator."
public static final java.lang.String	EXECUTOR_SELECTOR_FILTERS	"azkaban.executorselector.filters"
public static final java.lang.String	EXECUTORINFO_REFRESH_MAX_THREADS	"azkaban.executorinfo.refresh.maxThreads"
public static final java.lang.String	HADOOP_CONF_DIR_PATH	"hadoop.conf.dir.path"
public static final java.lang.String	HISTORY_SERVER_JOB_URL	"azkaban.server.external.history_server_job_url"
public static final java.lang.String	IS_METRICS_ENABLED	"azkaban.is.metrics.enabled"
public static final java.lang.String	MAX_CONCURRENT_RUNS_ONEFLOW	"azkaban.max.concurrent.runs.oneflow"
public static final java.lang.String	MAX_DISPATCHING_ERRORS_PERMITTED	"azkaban.maxDispatchingErrors"
public static final java.lang.String	MAX_SESSION_NUMBER_PER_IP_PER_USER	"azkaban.session.max_number_per_ip_per_user"
public static final java.lang.String	METRICS_SERVER_URL	"azkaban.metrics.server.url"
public static final java.lang.String	OAUTH_CREDENTIAL_NAME	"azkaban.oauth.credential"
public static final java.lang.String	PROJECT_CACHE_SIZE_PERCENTAGE	"azkaban.project_cache_size_percentage_of_disk"
public static final java.lang.String	PROJECT_CACHE_THROTTLE_PERCENTAGE	"azkaban.project_cache_throttle_percentage"
public static final java.lang.String	PROJECT_TEMP_DIR	"project.temp.dir"
public static final java.lang.String	PROJECT_VERSION_RETENTION	"project.version.retention"
public static final java.lang.String	QUEUEPROCESSING_ENABLED	"azkaban.queueprocessing.enabled"
public static final java.lang.String	RESOURCE_MANAGER_JOB_URL	"azkaban.server.external.resource_manager_job_url"
public static final java.lang.String	SECURITY_USER_GROUP	"azkaban.security.user.group"
public static final java.lang.String	SESSION_TIME_TO_LIVE	"session.time.to.live"
public static final java.lang.String	SPARK_HISTORY_SERVER_JOB_URL	"azkaban.server.external.spark_history_server_job_url"
public static final java.lang.String	USE_MULTIPLE_EXECUTORS	"azkaban.use.multiple.executors"
public static final java.lang.String	WEBSERVER_QUEUE_SIZE	"azkaban.webserver.queue.size"

azkaban.Constants.FlowProperties

Modifier and Type	Constant Field	Value
public static final java.lang.String	AZKABAN_FLOW_EXEC_ID	"azkaban.flow.execid"
public static final java.lang.String	AZKABAN_FLOW_FLOW_ID	"azkaban.flow.flowid"
public static final java.lang.String	AZKABAN_FLOW_PROJECT_NAME	"azkaban.flow.projectname"
public static final java.lang.String	AZKABAN_FLOW_PROJECT_VERSION	"azkaban.flow.projectversion"
public static final java.lang.String	AZKABAN_FLOW_SUBMIT_USER	"azkaban.flow.submituser"

azkaban.Constants.FlowTriggerProps

Modifier and Type	Constant Field	Value
public static final java.lang.String	CRON_SCHEDULE_TYPE	"cron"
public static final java.lang.String	DEP_NAME	"name"
public static final java.lang.String	SCHEDULE_TYPE	"type"
public static final java.lang.String	SCHEDULE_VALUE	"value"
public static final java.lang.String	START_TIME	"startTime"
public static final java.lang.String	TRIGGER_INSTANCE_ID	"triggerInstanceId"

azkaban.Constants.JobCallbackProperties

Modifier and Type	Constant Field	Value
public static final java.lang.String	JOBCALLBACK_CONNECTION_REQUEST_TIMEOUT	"jobcallback.connection.request.timeout"
public static final java.lang.String	JOBCALLBACK_CONNECTION_TIMEOUT	"jobcallback.connection.timeout"
public static final java.lang.String	JOBCALLBACK_RESPONSE_WAIT_TIMEOUT	"jobcallback.response.wait.timeout"
public static final java.lang.String	JOBCALLBACK_SOCKET_TIMEOUT	"jobcallback.socket.timeout"
public static final java.lang.String	JOBCALLBACK_THREAD_POOL_SIZE	"jobcallback.thread.pool.size"

azkaban.Constants.JobProperties

Modifier and Type	Constant Field	Value
public static final java.lang.String	AZKABAN_JOB_LOGGING_KAFKA_ENABLE	"azkaban.job.logging.kafka.enable"
public static final java.lang.String	ENABLE_JOB_SSL	"azkaban.job.enable.ssl"
public static final java.lang.String	ENABLE_OAUTH	"azkaban.enable.oauth"
public static final java.lang.String	EXTRA_HCAT_CLUSTERS	"azkaban.job.hive.other_hcat_clusters"
public static final java.lang.String	EXTRA_HCAT_LOCATION	"other_hcat_location"
public static final java.lang.String	JOB_LOG_LAYOUT	"azkaban.job.log.layout"
public static final java.lang.String	JOB_MAX_XMS	"job.max.Xms"
public static final java.lang.String	JOB_MAX_XMX	"job.max.Xmx"
public static final java.lang.String	MAX_XMS_DEFAULT	"1G"
public static final java.lang.String	MAX_XMX_DEFAULT	"2G"
public static final java.lang.String	USER_TO_PROXY	"user.to.proxy"

azkaban.Constants.PluginManager

Modifier and Type	Constant Field	Value
public static final java.lang.String	COMMONCONFFILE	"common.properties"
public static final java.lang.String	COMMONSYSCONFFILE	"commonprivate.properties"
public static final java.lang.String	CONFFILE	"plugin.properties"
public static final java.lang.String	JOBTYPE_DEFAULTDIR	"plugins/jobtypes"
public static final java.lang.String	RAMPPOLICY_DEFAULTDIR	"plugins/ramppolicies"
public static final java.lang.String	SYSCONFFILE	"private.properties"