This is an automated email from the ASF dual-hosted git repository.
yaniv pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-amaterasu.git.
from 06806ee Merge pull request #36 from ebarten/feature/AMATERASU-56
add 10f039b AMATERASU-51: Add support for configuring the path for action
level environment path Move JobManager from Scala -> Kotlin
add 10d6d0f crated kotlin SequentialAction and ErrorAction implementations
add 6e81057 Merge remote-tracking branch
'remotes/origin/feature/AMATERASU-56' into feature/AMATERASU-51
add c2623f9 AMATERASU-51: Add support for configuring the path for action
level environment path Move JobParser from Scala -> Kotlin & into leader-common
add c47e8c5 fixed license headers
add f0555b9 new kotlin based jpb parser now builds
add 44f3a8a tests are now fixed
add 292bb55 AMATERASU-51: Add support for configuring the path for action
level environment path PArse action by JobParser and add it as a parameter to
ActionData so that it could receive the parsed input from JobParser via
SequentialAction
add 89e2f18 AMATERASU-51: Add support for configuring the path for action
level environment path Add test for JobParserTests to test config is read
correctly.
add 7da3d12 Merge branch 'feature/AMATERASU-51' of
github.com:ebarten/incubator-amaterasu into feature/AMATERASU-51
add db5a3eb fixed config parsing
add 17d0b6f AMATERASU-51: Add support for configuring the path for action
level environment path Some code cleanup
add 095bac5 AMATERASU-51: Add support for configuring the path for action
level environment path Some code cleanup: remove unused imports
new d4f3c9a Merge pull request #37 from ebarten/feature/AMATERASU-51
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/amaterasu/common/logging/Logging.java | 19 ++-
.../common/configuration/enums/ActionStatus.kt | 19 ++-
.../amaterasu/common/dataobjects/ActionData.kt | 5 +-
.../apache/amaterasu/common/logging/KLogging.kt | 19 ++-
leader-common/build.gradle | 6 +-
.../amaterasu/leader/common/dsl/JobParser.kt | 169 +++++++++++++++++++
.../leader/common/execution/JobManager.kt | 150 +++++++++++++++++
.../leader/common/execution/actions/Action.kt | 1 -
.../leader/common/execution/actions/ErrorAction.kt | 48 ++++++
.../common/execution/actions/SequentialAction.kt | 51 ++++++
.../execution/actions/SequentialActionBase.kt | 66 ++++++++
.../frameworks/FrameworkProvidersFactory.scala | 2 +-
.../common}/utilities/ActiveReportListener.scala | 2 +-
.../leader/common/utilities/DataLoader.scala | 30 ++--
.../common/utilities/MemoryFormatParser.scala | 2 +-
leader/build.gradle | 20 ++-
.../org/apache/amaterasu/leader/yarn/Client.java | 4 +-
.../leader/common/actions/SequentialAction.scala | 135 ---------------
.../apache/amaterasu/leader/dsl/JobParser.scala | 181 --------------------
.../amaterasu/leader/execution/JobLoader.scala | 6 +-
.../amaterasu/leader/execution/JobManager.scala | 187 ---------------------
.../leader/mesos/schedulers/JobScheduler.scala | 33 ++--
.../amaterasu/leader/yarn/ApplicationMaster.scala | 34 ++--
.../leader/yarn/YarnRMCallbackHandler.scala | 6 +-
leader/src/test/resources/simple-maki.yml | 5 +-
.../common/execution/ActionStatusTests.scala | 8 +-
.../common/execution/JobExecutionTests.scala | 26 ++-
.../common/execution/JobParserTests.scala | 24 ++-
.../common/execution/JobRestoreTests.scala | 7 +-
29 files changed, 664 insertions(+), 601 deletions(-)
create mode 100644
leader-common/src/main/kotlin/org/apache/amaterasu/leader/common/dsl/JobParser.kt
create mode 100644
leader-common/src/main/kotlin/org/apache/amaterasu/leader/common/execution/JobManager.kt
create mode 100644
leader-common/src/main/kotlin/org/apache/amaterasu/leader/common/execution/actions/ErrorAction.kt
create mode 100644
leader-common/src/main/kotlin/org/apache/amaterasu/leader/common/execution/actions/SequentialAction.kt
create mode 100644
leader-common/src/main/kotlin/org/apache/amaterasu/leader/common/execution/actions/SequentialActionBase.kt
rename {leader/src/main/scala/org/apache/amaterasu/leader =>
leader-common/src/main/scala/org/apache/amaterasu/leader/common}/execution/frameworks/FrameworkProvidersFactory.scala
(96%)
rename {leader/src/main/scala/org/apache/amaterasu/leader =>
leader-common/src/main/scala/org/apache/amaterasu/leader/common}/utilities/ActiveReportListener.scala
(97%)
delete mode 100755
leader/src/main/scala/org/apache/amaterasu/leader/common/actions/SequentialAction.scala
delete mode 100755
leader/src/main/scala/org/apache/amaterasu/leader/dsl/JobParser.scala
delete mode 100755
leader/src/main/scala/org/apache/amaterasu/leader/execution/JobManager.scala
