如何在grails和hadoop之间编写连接脚本?

oxcyiej7  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(273)

我需要将grails中生成的文件动态复制到hadoop中。我将如何在grails中为此编写代码?无论何时生成文件,都应该将其复制到hadoop中。如果传入文件已经存在,应该在hadoop中更新它。

cdmah0mi

cdmah0mi1#

我使用shell脚本连接grails和hadoop。
我拥有运行hadoop作业的所有命令 myjob.sh (工作流脚本)
我在控制器中添加了执行shell脚本的代码

def scriptCom="/folderlocation/shellscript.sh"

println "[[Running $scriptCom]]"
def proc = scriptCom.execute()

def oneMinute = 60000
proc.waitForOrKill(oneMinute)

if(proc.exitValue()!=0){
    println "[[return code: ${proc.exitValue()}]]"
    println "[[stderr: ${proc.err.text}]]"
    return null
}else{
    println "[[stdout:$revisionid]]"
    return proc.in.text.readLines()
}

相关问题