Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CLEANUP_HELP_MESSAGE |
"JOB DIRECTORY CLEANUP:\nThe default cleanup behavior is to delete downloaded dependencies after job execution completed\n(whether or not it was successful). A different strategy (no cleanup, full cleanup, ...) can be\nselected via command-line flags" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
APPLICATION_URL_SUFFIX |
"/api/v3/applications" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CLUSTER_URL_SUFFIX |
"/api/v3/clusters" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COMMAND_URL_SUFFIX |
"/api/v3/commands" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
JOBS_URL_SUFFIX |
"/api/v3/jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_NUM_RETRIES |
5 |
public static final long |
DEFAULT_TIMEOUT |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_CHECK_DELAY |
10000L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KILLED_EXIT_CODE |
999 |
public static final int |
LOST_EXIT_CODE |
666 |
public static final int |
SUCCESS_EXIT_CODE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_TIMEOUT_DURATION |
604800 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COULD_NOT_LOAD_DONE_FILE |
"Failed to load done file." |
public static final java.lang.String |
JOB_EXCEEDED_STDERR_LENGTH |
"Std err length exceeded." |
public static final java.lang.String |
JOB_EXCEEDED_STDOUT_LENGTH |
"Std out length exceeded." |
public static final java.lang.String |
JOB_EXCEEDED_TIMEOUT |
"Job exceeded timeout." |
public static final java.lang.String |
JOB_FAILED |
"Job failed." |
public static final java.lang.String |
JOB_FINISHED_SUCCESSFULLY |
"Job finished successfully." |
public static final java.lang.String |
JOB_KILLED_BY_USER |
"Job was killed by user." |
public static final java.lang.String |
JOB_PROCESS_NOT_FOUND |
"Couldn\'t check job process status." |
public static final java.lang.String |
PROCESS_DETECTED_TO_BE_COMPLETE |
"Process detected to be complete" |
public static final java.lang.String |
SUBMIT_INIT_FAILURE |
"Job initialization failed, further details available in the job output directory" |
public static final java.lang.String |
SUBMIT_PRECONDITION_FAILURE |
"Job validation failed, further details available in the job output directory" |
public static final java.lang.String |
SYSTEM_CRASHED_WHILE_JOB_STARTING |
"System crashed while job starting" |
public static final java.lang.String |
UNABLE_TO_RE_ATTACH_ON_STARTUP |
"Unable to re-attach on startup" |
public static final java.lang.String |
USER_REQUESTED_JOB_BE_KILLED_DURING_INITIALIZATION |
"User requested job be killed during initialization" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
APPLICATION_PATH_VAR |
"applications" |
public static final java.lang.String |
CHILDREN_PID_ENV_VAR |
"CHILDREN_PID" |
public static final java.lang.String |
CLUSTER_PATH_VAR |
"cluster" |
public static final java.lang.String |
COMMAND_PATH_VAR |
"command" |
public static final java.lang.String |
CONFIG_FILE_PATH_PREFIX |
"config" |
public static final java.lang.String |
DEPENDENCY_FILE_PATH_PREFIX |
"dependencies" |
public static final java.lang.String |
DOUBLE_QUOTE_SYMBOL |
"\"" |
public static final java.lang.String |
EQUALS_SYMBOL |
"=" |
public static final java.lang.String |
EXPORT |
"export " |
public static final java.lang.String |
FILE_PATH_DELIMITER |
"/" |
public static final java.lang.String |
FILE_TRANSFER_SERVICE_KEY |
"fts" |
public static final java.lang.String |
GENIE_AGENT_ENV_SCRIPT_LOG_FILE_NAME |
"env-setup.log" |
public static final java.lang.String |
GENIE_AGENT_ENV_SCRIPT_OUTPUT_FILE_NAME |
"env.sh" |
public static final java.lang.String |
GENIE_AGENT_ENV_SCRIPT_RESOURCE |
"genie-env.sh" |
public static final java.lang.String |
GENIE_APPLICATION_DIR_ENV_VAR |
"GENIE_APPLICATION_DIR" |
public static final java.lang.String |
GENIE_CLUSTER_DIR_ENV_VAR |
"GENIE_CLUSTER_DIR" |
public static final java.lang.String |
GENIE_CLUSTER_ID_ENV_VAR |
"GENIE_CLUSTER_ID" |
public static final java.lang.String |
GENIE_CLUSTER_NAME_ENV_VAR |
"GENIE_CLUSTER_NAME" |
public static final java.lang.String |
GENIE_CLUSTER_TAGS_ENV_VAR |
"GENIE_CLUSTER_TAGS" |
public static final java.lang.String |
GENIE_COMMAND_DIR_ENV_VAR |
"GENIE_COMMAND_DIR" |
public static final java.lang.String |
GENIE_COMMAND_ID_ENV_VAR |
"GENIE_COMMAND_ID" |
public static final java.lang.String |
GENIE_COMMAND_NAME_ENV_VAR |
"GENIE_COMMAND_NAME" |
public static final java.lang.String |
GENIE_COMMAND_TAGS_ENV_VAR |
"GENIE_COMMAND_TAGS" |
public static final java.lang.String |
GENIE_DONE_FILE_CONTENT_PREFIX |
"printf \'{\"exitCode\": \"%s\"}\\n\' \"$?\" > " |
public static final java.lang.String |
GENIE_DONE_FILE_NAME |
"genie/genie.done" |
public static final java.lang.String |
GENIE_ENV_PATH |
"/genie/logs/env.log" |
public static final java.lang.String |
GENIE_FORWARDED_FROM_HEADER |
"Genie-Forwarded-From" |
public static final java.lang.String |
GENIE_INIT_FAILURE_MESSAGE_FILE_NAME |
"initFailureDetails.txt" |
public static final java.lang.String |
GENIE_JOB_DIR_ENV_VAR |
"GENIE_JOB_DIR" |
public static final java.lang.String |
GENIE_JOB_ID_ENV_VAR |
"GENIE_JOB_ID" |
public static final java.lang.String |
GENIE_JOB_LAUNCHER_SCRIPT |
"run" |
public static final java.lang.String |
GENIE_JOB_MEMORY_ENV_VAR |
"GENIE_JOB_MEMORY" |
public static final java.lang.String |
GENIE_JOB_NAME_ENV_VAR |
"GENIE_JOB_NAME" |
public static final java.lang.String |
GENIE_JOB_TAGS_ENV_VAR |
"GENIE_JOB_TAGS" |
public static final java.lang.String |
GENIE_KILL_REASON_FILE_NAME |
"genie/kill-reason" |
public static final java.lang.String |
GENIE_LOG_PATH |
"/genie/logs/genie.log" |
public static final java.lang.String |
GENIE_PATH_VAR |
"genie" |
public static final java.lang.String |
GENIE_REQUESTED_CLUSTER_TAGS_ENV_VAR |
"GENIE_REQUESTED_CLUSTER_TAGS" |
public static final java.lang.String |
GENIE_REQUESTED_COMMAND_TAGS_ENV_VAR |
"GENIE_REQUESTED_COMMAND_TAGS" |
public static final java.lang.String |
GENIE_TEMPORARY_DONE_FILE_NAME |
"genie/genie.done.temp" |
public static final java.lang.String |
JOB_EXECUTION_DTO_KEY |
"jexecdto" |
public static final java.lang.String |
JOB_EXECUTION_ENV_KEY |
"jee" |
public static final java.lang.String |
KILL_PARENT_PID_FLAG |
"-P" |
public static final java.lang.String |
KILL_PROCESS_GROUP_FLAG |
"-g" |
public static final java.lang.String |
LOGS_PATH_VAR |
"logs" |
public static final java.lang.String |
PID |
"pid" |
public static final java.lang.String |
SEMICOLON_SYMBOL |
";" |
public static final java.lang.String |
SOURCE |
"source " |
public static final java.lang.String |
STDERR_LOG_FILE_NAME |
"stderr" |
public static final java.lang.String |
STDERR_REDIRECT |
" 2> " |
public static final java.lang.String |
STDOUT_LOG_FILE_NAME |
"stdout" |
public static final java.lang.String |
STDOUT_REDIRECT |
" > " |
public static final java.lang.String |
UNIX_PKILL_COMMAND |
"pkill" |
public static final java.lang.String |
WHITE_SPACE |
" " |
public static final java.lang.String |
WRITER_KEY |
"writer" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
API_TIMER_NAME |
"genie.security.oauth2.pingFederate.api.timer" |
protected static final java.lang.String |
AUTHENTICATION_TIMER_NAME |
"genie.security.oauth2.pingFederate.authentication.timer" |
protected static final java.lang.String |
CLIENT_ID_KEY |
"client_id" |
protected static final java.lang.String |
ERROR_KEY |
"error" |
protected static final java.lang.String |
SCOPE_KEY |
"scope" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
CLIENT_ID_KEY |
"client_id" |
protected static final java.lang.String |
GENIE_PREFIX |
"genie_" |
protected static final java.lang.String |
ROLE_PREFIX |
"ROLE_" |
protected static final java.lang.String |
SCOPE_KEY |
"scope" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SCRIPT_LOAD_BALANCER_PRECEDENCE |
2147483597 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
GENIE_ID_PREFIX |
"genie.id:" |
public static final java.lang.String |
GENIE_NAME_PREFIX |
"genie.name:" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
FIND_TERMINATED_CLUSTERS_SQL |
"SELECT id FROM clusters WHERE id NOT IN (SELECT DISTINCT(cluster_id) FROM jobs WHERE cluster_id IS NOT NULL) AND status = \'TERMINATED\' FOR UPDATE;" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SELECT_FOR_UPDATE_UNUSED_FILES_SQL |
"SELECT id FROM files WHERE id NOT IN (SELECT DISTINCT(setup_file) FROM applications WHERE setup_file IS NOT NULL) AND id NOT IN (SELECT DISTINCT(file_id) FROM applications_configs) AND id NOT IN (SELECT DISTINCT(file_id) FROM applications_dependencies) AND id NOT IN (SELECT DISTINCT(setup_file) FROM clusters WHERE setup_file IS NOT NULL) AND id NOT IN (SELECT DISTINCT(file_id) FROM clusters_configs) AND id NOT IN (SELECT DISTINCT(file_id) FROM clusters_dependencies) AND id NOT IN (SELECT DISTINCT(setup_file) FROM commands WHERE setup_file IS NOT NULL) AND id NOT IN (SELECT DISTINCT(file_id) FROM commands_configs) AND id NOT IN (SELECT DISTINCT(file_id) FROM commands_dependencies) AND id NOT IN (SELECT DISTINCT(setup_file) FROM jobs WHERE setup_file IS NOT NULL) AND id NOT IN (SELECT DISTINCT(file_id) FROM jobs_configs) AND id NOT IN (SELECT DISTINCT(file_id) FROM jobs_dependencies) AND created <= :createdThreshold FOR UPDATE;" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SELECT_FOR_UPDATE_UNUSED_TAGS_SQL |
"SELECT id FROM tags WHERE id NOT IN (SELECT DISTINCT(tag_id) FROM applications_tags) AND id NOT IN (SELECT DISTINCT(tag_id) FROM clusters_tags) AND id NOT IN (SELECT DISTINCT(tag_id) FROM commands_tags) AND id NOT IN (SELECT DISTINCT(tag_id) FROM criteria_tags) AND id NOT IN (SELECT DISTINCT(tag_id) FROM jobs_tags) AND created <= :createdThreshold FOR UPDATE;" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.aws.credentials" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.tasks.cluster-checker" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ENABLED_PROPERTY |
"genie.tasks.database-cleanup.enabled" |
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.tasks.database-cleanup" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.data.service.retry" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ENABLED_PROPERTY |
"genie.tasks.disk-cleanup.enabled" |
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.tasks.disk-cleanup" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.completion-check-back-off" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.file.cache" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ENABLED_PROPERTY |
"genie.grpc.server.enabled" |
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.grpc.server" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.health" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.http" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.grpc.server.services.job-file-sync" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.cleanup" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ENABLED_PROPERTY |
"genie.jobs.forwarding.enabled" |
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.forwarding" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.locations" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.max" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.memory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_COUNT |
100 |
public static final boolean |
DEFAULT_ENABLED |
false |
public static final java.lang.String |
ENABLED_PROPERTY |
"genie.jobs.users.active-limit.enabled" |
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.users.active-limit" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.users" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ENABLED_PROPERTY |
"genie.leader.enabled" |
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.leader" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.mail" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.retry" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.s3filetransfer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ENABLED_PROPERTY |
"genie.jobs.clusters.load-balancers.script.enabled" |
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.jobs.clusters.load-balancers.script" |
public static final java.lang.String |
REFRESH_RATE_PROPERTY |
"genie.jobs.clusters.load-balancers.script.refreshRate" |
public static final java.lang.String |
SCRIPT_FILE_DESTINATION_PROPERTY |
"genie.jobs.clusters.load-balancers.script.destination" |
public static final java.lang.String |
SCRIPT_FILE_SOURCE_PROPERTY |
"genie.jobs.clusters.load-balancers.script.source" |
public static final java.lang.String |
TIMEOUT_PROPERTY |
"genie.jobs.clusters.load-balancers.script.timeout" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ENABLED_PROPERTY |
"genie.swagger.enabled" |
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.swagger" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.tasks.executor.pool" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.tasks.scheduler.pool" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_PREFIX |
"genie.zookeeper.leader" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
APPLICATION_ID |
"applicationId" |
public static final java.lang.String |
APPLICATION_NAME |
"applicationName" |
public static final java.lang.String |
CLASS_NAME |
"class" |
public static final java.lang.String |
CLUSTER_ID |
"clusterId" |
public static final java.lang.String |
CLUSTER_NAME |
"clusterName" |
public static final java.lang.String |
COMMAND_ID |
"commandId" |
public static final java.lang.String |
COMMAND_NAME |
"commandName" |
public static final java.lang.String |
EXCEPTION_CLASS |
"exceptionClass" |
public static final java.lang.String |
STATUS |
"status" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
FAILURE |
"failure" |
public static final java.lang.String |
SUCCESS |
"success" |