我可以使用submitJob函数异步提交任务，但是如何获得结果呢？代码如下： def Queryfun(){}
submitJob
浏览 31提问于2019-04-30得票数 0
不幸的是，包没有提供任何测试或示例，我自己也搞不清楚应该如何组合connectGearman和submitJob来将作业放到中。connectGearman的结果是：ghci> :t conn但是submitJob使
浏览 10提问于2017-03-14得票数 0
回答已采纳
我使用submitJob函数获取jobId，并尝试使用cancelJob函数取消作业，但未能停止作业。我应该使用什么函数来停止作业？我使用下面的代码: submitJob("aa"，“a1”，重放，date,ds，``sink，date,时间，10) cancelJob(aa)
浏览 14提问于2019-04-22得票数 1
2回答
在我给JobClient.runJob(jobConf)之后
如何获得此JobID任务的MapReduce？是否在作业仍在运行时获得ID？
浏览 4提问于2014-02-13得票数 0
回答已采纳
我从Step函数提交一个AWS批处理作业。批处理作业接受命令行参数。我可以像这样在step函数中运行它： "Comment": "Submit aws batch job with parameters", "SubmitJob": {
"Type": "Task"
浏览 7提问于2022-08-11得票数 2
回答已采纳
我有一个mapreduce代码，它使用JobClient提交作业。org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:844)导致这个错误的代码片段是 j.init(conf);
RunningJob check = j.submitJob
浏览 1提问于2012-12-10得票数 0
回答已采纳
最近在PowerShell中使用了started，并希望通过引入一个函数来设置备份作业来简化我的脚本，所以我从以下几个方面开始：{}submitJob "SS03ICT","Wednesday (01)&qu
浏览 3提问于2016-04-21得票数 0
回答已采纳
1回答
我试着使用下面的代码来获取每个映射器和还原器所花费的时间，但是我在这里得到了映射器和还原器的数量0。other_args.get(1)));
RunningJob runjob = jobclient.submitJob
浏览 3提问于2015-03-09得票数 0
回答已采纳
使用Java Spring创建rest API，并希望获得Map格式的输入，但得到以下错误。有没有人知道是什么导致了这种异常的发生？已查看资源(无法解决问题)：
public interface ApiController { JobSubmitResultDTO submitJob(@RequestBody JobSubmitRe
浏览 3提问于2020-03-20得票数 2
我正在使用的方法(可能还有其他有此问题的方法，我还没有详细检查)是由POST请求触发的方法。它返回一个异步对象，因为该方法所做的计算返回一个未来。所有这些都像我在本地机器上描述的那样工作。submitJob调用会触发长时间运行的计算。正如我所说的，我不想等待它，这就是为什么我甚至不使用它返回的任何地方的Futu
浏览 2提问于2013-07-31得票数 3
回答已采纳
1回答
我正在使用DolphinDB中的OPC插件。", callback1{t2})submitJob("i4", "", callback1{t5})
submitJob("i6", "subtestReal8" , suba, ".te
浏览 5提问于2019-07-28得票数 0
2回答
在我的应用程序中，当我点击Run按钮时，gsp页面中的脚本如下：submitJob()函数是在ExtJs JavaScript文件中定义的，它执行一些操作并调用控制器代码，从而呈现不同的gsp输出页面，如下所示：
render(template: "/plugin/jobPlot_out<e
浏览 0提问于2015-05-14得票数 0
当邮件不存在时，我断言为空值，并使用断言消息进行报告--“邮箱中不存在邮件”。但是，断言消息不会在每次测试失败后显示，而是报告所有测试运行的结束，即在处理电子表格的所有行之后。(Test.java:110)Failed tests: Run 1: Test.submitJob:110 Mail does not exist expected object tonot be null
Run 2:
浏览 0提问于2017-02-16得票数 1
一旦一个职位创建者发布了一个职位，它应该等待工作完成，除了“它已经完成”之外没有产生任何结果，然后才能继续进行。有人有什么建议吗？我们也非常欢迎阅读有关并发策略的链接！
浏览 0提问于2012-09-12得票数 0
回答已采纳
我尝试在下面的代码中使用Jobclient类的submitJob(jobConf)方法 JobClientJobClient(); System.out.println("from conf" +j.getConf().toString());我一直在错误堆栈的j.s
浏览 0提问于2012-12-07得票数 1
回答已采纳
1回答
我想在AWS批处理中使用API网关
我已经知道如何在AWS lambda naad中使用API，因为lambda中有250 MB的限制，所以我无法使用它进行集成，现在正在尝试AWS批处理。
浏览 1提问于2019-07-23得票数 0
请有人提供一个submitJob方法调用的例子。我相信我可以为我的用例实现它。在我当前的实现中，我使用paritions调用并行调用，但是在调用下一个调用之前，它们正在等待响应。如果有人使用过SparkContext.submitJob，请提供一个例子，因为我是新的火花和scala。submitJob：SimpleFutureActionR分析-我的rdd已经被分区了，我是否在rdd中为No.of.partitions提供了范围0？resultHan
浏览 6提问于2020-03-12得票数 1
每当有新文件上传到云存储存储桶时，都会触发云函数。此函数应调用用pyspark编写的dataproc作业，以读取文件并将其加载到BigQuery。我想知道如何从云函数调用google dataproc作业。请提个建议。
浏览 2提问于2018-05-10得票数 2
1回答
但是，由于清理阶段总是经过，步骤函数的最终结果总是Pass，而如果阶段1或2失败，我需要执行清理，但是步骤函数的最终结果应该是失败。调查的备选方案： }清理阶段如下： &
浏览 3提问于2021-09-21得票数 1
1回答
我想使用MapReduce和Hadoopv.1.0.3编写我自己的单词计数示例(我在MacOS上)，但是我不明白为什么它不能共享我的代码：package org.myorg;
JobClient j=new JobClient(conf);.
浏览 1提问于2014-03-03得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
