cameronlee314 commented on a change in pull request #1182: SAMZA-2343: Remove
original split deployment code
URL: https://github.com/apache/samza/pull/1182#discussion_r333762720
##########
File path: samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala
##########
@@ -88,25 +85,7 @@ class YarnJob(config: Config, hadoopConfig: Configuration)
extends StreamJob {
}
def buildAmCmd() = {
- // figure out if we have framework is deployed into a separate location
- val fwkPath = config.get(JobConfig.SAMZA_FWK_PATH, "")
- var fwkVersion = config.get(JobConfig.SAMZA_FWK_VERSION)
- if (fwkVersion == null || fwkVersion.isEmpty()) {
- fwkVersion = "STABLE"
- }
- logger.info("Inside YarnJob: fwk_path is %s, ver is %s use it directly "
format(fwkPath, fwkVersion))
-
- var cmdExec = "./__package/bin/run-jc.sh" // default location
-
- if (!fwkPath.isEmpty()) {
- // if we have framework installed as a separate package - use it
- cmdExec = fwkPath + "/" + fwkVersion + "/bin/run-jc.sh"
-
- logger.info("Using FWK path: " + "export SAMZA_LOG_DIR=%s && ln -sfn %s
logs && exec %s 1>logs/%s 2>logs/%s".
- format(ApplicationConstants.LOG_DIR_EXPANSION_VAR,
ApplicationConstants.LOG_DIR_EXPANSION_VAR, cmdExec,
- ApplicationConstants.STDOUT, ApplicationConstants.STDERR))
-
- }
+ val cmdExec = "./__package/bin/run-jc.sh" // default location
Review comment:
I noticed this too, but I will actually be adding more logic to this method
in https://github.com/apache/samza/pull/1172, so I left it as is.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
