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_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_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 |
NO_ID_FOUND |
"<no id>" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CLUSTER_COMMAND_QUERY |
"SELECT cc.cluster_id, c.unique_id FROM ( SELECT cc.cluster_id as cluster_id, MIN(cc.command_order) as command_order FROM ( SELECT c.id as id FROM clusters c join clusters_tags ct on c.id = ct.cluster_id join tags t on ct.tag_id = t.id WHERE t.tag IN (:clusterTags) AND c.status = \'UP\' GROUP BY c.id HAVING COUNT(c.id) = :clusterTagsCount ) AS selected_clusters join clusters_commands cc ON selected_clusters.id = cc.cluster_id join ( SELECT c.id as id FROM commands c join commands_tags ct on c.id = ct.command_id join tags t on ct.tag_id = t.id WHERE t.tag IN (:commandTags) AND c.status = \'ACTIVE\' GROUP BY c.id HAVING COUNT(c.id) = :commandTagsCount ) AS selected_commands ON selected_commands.id = cc.command_id GROUP BY cc.cluster_id ) as cluster_id_order join clusters_commands cc on cluster_id_order.cluster_id = cc.cluster_id AND cc.command_order = cluster_id_order.command_order join commands c on cc.command_id = c.id;" |
public static final java.lang.String |
DELETE_TERMINATED_CLUSTERS_COMMANDS_REFERENCES_SQL |
"DELETE FROM clusters_commands WHERE cluster_id IN ( SELECT id FROM clusters WHERE id NOT IN (SELECT DISTINCT(cluster_id) FROM jobs WHERE cluster_id IS NOT NULL) AND status = \'TERMINATED\');" |
public static final java.lang.String |
DELETE_TERMINATED_CLUSTERS_CONFIGS_FILE_REFERENCES_SQL |
"DELETE FROM clusters_configs WHERE cluster_id IN ( SELECT id FROM clusters WHERE id NOT IN (SELECT DISTINCT(cluster_id) FROM jobs WHERE cluster_id IS NOT NULL) AND status = \'TERMINATED\');" |
public static final java.lang.String |
DELETE_TERMINATED_CLUSTERS_DEPENDENCIES_FILE_REFERENCES_SQL |
"DELETE FROM clusters_dependencies WHERE cluster_id IN ( SELECT id FROM clusters WHERE id NOT IN (SELECT DISTINCT(cluster_id) FROM jobs WHERE cluster_id IS NOT NULL) AND status = \'TERMINATED\');" |
public static final java.lang.String |
DELETE_TERMINATED_CLUSTERS_SQL |
"DELETE FROM clusters WHERE id NOT IN (SELECT DISTINCT(cluster_id) FROM jobs WHERE cluster_id IS NOT NULL) AND status = \'TERMINATED\';" |
public static final java.lang.String |
DELETE_TERMINATED_CLUSTERS_TAGS_REFERENCES_SQL |
"DELETE FROM clusters_tags WHERE cluster_id IN ( SELECT id FROM clusters WHERE id NOT IN (SELECT DISTINCT(cluster_id) FROM jobs WHERE cluster_id IS NOT NULL) AND status = \'TERMINATED\');" |
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 int |
DEFAULT_COUNT |
100 |
public static final boolean |
DEFAULT_ENABLED |
false |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_ORDER |
2147483646 |
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" |
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 |
CLIENT_SECRET_KEY |
"client_secret" |
protected static final java.lang.String |
ERROR_KEY |
"error" |
protected static final java.lang.String |
GRANT_TYPE |
"urn:pingidentity.com:oauth2:grant_type:validate_bearer" |
protected static final java.lang.String |
GRANT_TYPE_KEY |
"grant_type" |
protected static final java.lang.String |
SCOPE_KEY |
"scope" |
protected static final java.lang.String |
TOKEN_NAME_KEY |
"token" |
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" |