通过jdbc为insert语句计算应用程序的id

qv7cva1a  于 2021-05-31  发布在  Hadoop
关注(0)|答案(0)|浏览(202)

我正在通过配置单元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版本。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题