| commit | e35fa6c863d5ffd98e92fa911b70ac3d81f506d1 | [log] [tgz] |
|---|---|---|
| author | Yaniv Rodenski <yaniv@shinto.io> | Sat Apr 13 00:25:32 2019 +1000 |
| committer | Yaniv Rodenski <yaniv@shinto.io> | Sat Apr 13 00:25:32 2019 +1000 |
| tree | 2a31a2c7fca669fdcbcf3d7858f50ec3f686fc11 | |
| parent | 40600a4b96f3b72acc205e8104163ff693998d4b [diff] |
fixing pip install
diff --git a/frameworks/python/dispatcher/src/main/kotlin/org/apache/amaterasu/frameworks/python/dispatcher/runners/providers/PythonRunnerProviderBase.kt b/frameworks/python/dispatcher/src/main/kotlin/org/apache/amaterasu/frameworks/python/dispatcher/runners/providers/PythonRunnerProviderBase.kt index 578fa44..b5e1322 100644 --- a/frameworks/python/dispatcher/src/main/kotlin/org/apache/amaterasu/frameworks/python/dispatcher/runners/providers/PythonRunnerProviderBase.kt +++ b/frameworks/python/dispatcher/src/main/kotlin/org/apache/amaterasu/frameworks/python/dispatcher/runners/providers/PythonRunnerProviderBase.kt
@@ -47,7 +47,7 @@ val dependencies = runnerResources + mandatoryPYPIPackages dependencies.forEach { resource -> - println("====> RESOURCESSSSSS: $resource") + println("====> RESOURCES: $resource") reqFile.appendText("$resource\n") }
diff --git a/leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt b/leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt index fc4b340..8c45b41 100644 --- a/leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt +++ b/leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt
@@ -251,7 +251,7 @@ jobManager.actionStarted(actionData.id) containersIdsToTask[container.id.containerId] = actionData notifier.info("created container for ${actionData.name} created") - ctx.localResources.forEach { t: String, u: LocalResource -> notifier.info("resource: $t = ${u.resource}") } + //ctx.localResources.forEach { t: String, u: LocalResource -> notifier.info("resource: $t = ${u.resource}") } log.info("launching container succeeded: ${container.id.containerId}; task: ${actionData.id}") } }