diff --git hadoop-yarn-project/CHANGES.txt hadoop-yarn-project/CHANGES.txt index 7792935..01a216b 100644 --- hadoop-yarn-project/CHANGES.txt +++ hadoop-yarn-project/CHANGES.txt @@ -14,6 +14,9 @@ Trunk - Unreleased YARN-524 TestYarnVersionInfo failing if generated properties doesn't include an SVN URL. (stevel) + + YARN-1039 Add longRunning flag to ApplicationSubmissionContext + (Craig Welch via Xuan Gong) Release 2.5.0 - UNRELEASED diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/ApplicationSubmissionContext.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/ApplicationSubmissionContext.java index 529df11..97c0a6a 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/ApplicationSubmissionContext.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/ApplicationSubmissionContext.java @@ -318,6 +318,26 @@ public abstract void setKeepContainersAcrossApplicationAttempts( boolean keepContainers); /** + * Get the flag which indicates that the application is long running. + * + * @return the flag which indicates that the application is long running. + */ + @Public + @Stable + public abstract boolean getLongRunning(); + + /** + * Set the flag which indicates that the application is long running. + * + * @param keepContainers + * the flag which indicates that the application is long running. + */ + @Public + @Stable + public abstract void setLongRunning( + boolean longRunning); + + /** * Get tags for the application * * @return the application tags diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/yarn_protos.proto hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/yarn_protos.proto index 48aac9d..94ceaf4 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/yarn_protos.proto +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/proto/yarn_protos.proto @@ -288,6 +288,7 @@ message ApplicationSubmissionContextProto { optional string applicationType = 10 [default = "YARN"]; optional bool keep_containers_across_application_attempts = 11 [default = false]; repeated string applicationTags = 12; + optional bool long_running = 13 [default = false]; } enum ApplicationAccessTypeProto { diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ApplicationSubmissionContextPBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ApplicationSubmissionContextPBImpl.java index c4a3a72..813fd10 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ApplicationSubmissionContextPBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ApplicationSubmissionContextPBImpl.java @@ -369,6 +369,19 @@ public boolean getKeepContainersAcrossApplicationAttempts() { return p.getKeepContainersAcrossApplicationAttempts(); } + @Override + public void + setLongRunning(boolean longRunning) { + maybeInitBuilder(); + builder.setLongRunning(longRunning); + } + + @Override + public boolean getLongRunning() { + ApplicationSubmissionContextProtoOrBuilder p = viaProto ? proto : builder; + return p.getLongRunning(); + } + private PriorityPBImpl convertFromProtoFormat(PriorityProto p) { return new PriorityPBImpl(p); }