我正在通过配置单元jdbc客户端执行插入查询。我执行的方法是: boolean execute(String sql) throws SQLException
[这个]。这是一个阻塞呼叫。我知道在一些跳跃之后,hadoop集群上会启动一个map reduce作业。
问题:现在,根据我的要求,如果mr工作不能在规定的时间内完成,我需要终止它。目前,我所知道的杀死mr job的唯一方法是通过Yarn, yarn application -kill application_1428487296152_25597
或者 hadoop job -kill $jobId
. 但是在上面的例子中,因为我是通过jdbc执行的,所以我既没有得到yarn app id,也没有得到hadoop作业id。我应该怎么做呢?
ps:我有一系列mr应用程序在一个工作流中运行。超时规范处于工作流级别。因此,需要按需终止流。
pps:我使用的是hivejdbc客户端的1.2.1版本。
暂无答案!
目前还没有任何答案,快来回答吧!