You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ca...@apache.org on 2019/10/23 18:06:21 UTC
[samza] branch master updated (9a9b7d7 -> 80f06f3)
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