This is an automated email from the ASF dual-hosted git repository.
cameronlee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from 9a9b7d7 SAMZA-2356: [Transactional State] Do not trim changelog if
time since last checkpoint is greater than min.compaction.lag. (#1196)
add 80f06f3 SAMZA-2332: [AM isolation] YarnJob should pass new command
and additional environment variables for AM deployment (#1172)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
.../classloader/DependencyIsolationUtils.java | 40 ++++++++
.../java/org/apache/samza/config/JobConfig.java | 7 ++
.../apache/samza/config/ShellCommandConfig.scala | 24 +++++
.../org/apache/samza/config/TestJobConfig.java | 14 +++
.../scala/org/apache/samza/job/yarn/YarnJob.scala | 78 +++++++++-----
.../org/apache/samza/config/TestYarnConfig.java | 29 +++---
.../org/apache/samza/job/yarn/TestYarnJob.java | 114 +++++++++++++++++++++
8 files changed, 268 insertions(+), 39 deletions(-)
create mode 100644
samza-core/src/main/java/org/apache/samza/classloader/DependencyIsolationUtils.java
copy samza-api/src/main/java/org/apache/samza/config/ConfigException.java =>
samza-yarn/src/test/java/org/apache/samza/config/TestYarnConfig.java (59%)
create mode 100644
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestYarnJob.java
