Java批处理作业侦听器afterJob获取作业的id
Java批处理作业侦听器是一种用于监听和处理批处理作业的事件的组件。afterJob是其中的一个方法，用于在作业执行完成后获取作业的id。
作业的id是作业在批处理系统中的唯一标识符，可以用来识别和跟踪作业的执行情况。在afterJob方法中，可以通过调用相应的API或者从作业的上下文中获取作业的id。
Java批处理作业侦听器的优势在于可以实现对批处理作业的灵活控制和监控。通过监听作业的事件，可以在作业执行前后进行一系列的操作，例如记录日志、发送通知、执行后续任务等。
Java批处理作业侦听器的应用场景包括但不限于：
- 批量数据处理：可以用于处理大量的数据，例如数据清洗、数据转换、数据导入导出等。
- 定时任务：可以用于定时执行一些重复性的任务，例如定时生成报表、定时备份数据等。
- 批量任务调度：可以用于调度和管理一组相关的任务，例如批量文件处理、批量邮件发送等。
腾讯云提供了一系列与批处理相关的产品和服务，其中包括：
- 腾讯云批处理（Tencent Batch）：提供高性能、高可靠的批处理作业调度和管理服务，支持作业侦听器等批处理相关功能。详情请参考：腾讯云批处理产品介绍
- 腾讯云函数计算（Tencent Cloud Function）：提供无服务器的计算服务，可以用于执行简单的批处理任务。详情请参考：腾讯云函数计算产品介绍
- 腾讯云容器服务（Tencent Kubernetes Engine）：提供容器化的批处理作业调度和管理服务，支持作业侦听器等批处理相关功能。详情请参考：腾讯云容器服务产品介绍
以上是关于Java批处理作业侦听器afterJob获取作业的id的完善且全面的答案。
相关·内容
我是Java批处理新手。我部署了一个简单的批处理作业，其中包括一个JobListener on WebSphere解放17.0.0.4 (注意，我使用的是WebSphere的JSR-352实现，而不是Spring )。批处理作业本身按照预期运行:它读取输入文件，进行简单的数据转换，并将其写入DB。但是，在JobListener成功执行的afterJob()方法中，我看到批处理状态为STARTED，退出状态为null。(这些值与我在beforeJob()方法中看到的值相同)。除非有异常，否则我希望afterJob()看到已完成的状态。
afterJob()记录的执行id与JobOperator.
浏览 3提问于2018-01-17得票数 3
回答已采纳
如果一个Spring批处理作业具有为其配置的JobExecutionListener实例列表，那么每个侦听器的执行顺序是什么。例子：
<job id="myJob" xmlns="http://www.springframework.org/schema/batch">
<batch:listeners>
<batch:listener ref="myJobExecutionListener1" />
<batch:listener ref
浏览 0提问于2019-10-30得票数 2
回答已采纳
1回答
我使用一个JobListener来编写一个批处理执行日志文件。在我的第一次尝试中，我的代码在每种情况下都依赖于调用afterJob()，但是我发现，当通过JobOperator.stop(jobExecutionId)停止执行时，不会调用它。我也知道，停止的工作可以恢复。
批处理API是否为要通知停止事件的作业提供挂钩？
javax.batch.api.listener.JobListener.afterJob()
作业执行结束后，afterJob方法接收控制。
javax.batch.operations.JobOperator.stop(jobExecutionId)
此方法通知
浏览 8提问于2021-05-31得票数 0
回答已采纳
我有自己的Spring作业(MyTaskletJob)，它实现了实现Tasklet的接口IJobBase，
实现另一个名为rollBack的方法所需要的是我的工作
公共接口IJobBase扩展Tasklet{
void rollBack();
}
公共类MyTaskletJob IJobBase{
public RepeatStatus execute(StepContribution arg0, ChunkContext arg1){
…}
public void rollBack(){
…}
}
Spring配置：
&l
浏览 0提问于2013-03-07得票数 1
1回答
我有一个Spring批处理作业，其运行方式如下：
public void myMethod() throws JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException {
logger.log("Job Starting");
JobParameters param = new JobParametersBuilder()
.addString(&
浏览 0提问于2018-10-12得票数 0
回答已采纳
在这种情况下，我必须调用批处理过程并更新服务层中作业的状态。这里的JobRepositoryFactoryBean已经由事务管理器组成，所以我不应该用@Transactional注释我的服务方法，如果我注释了，我会在运行时得到异常，如果没有用@Transactional注释，我会得到运行时异常，说"no session found for current thread“。请帮我解决这个问题。
浏览 0提问于2014-07-15得票数 1
我想知道是否有方法来合并在大多数批处理作业结束时执行的一个常见的spring批处理步骤。
我知道抽象的工作，但它只让我提前一步，而不是附加步骤。我想看看除了做一些花哨的ApllicationContextAware之外还有什么简单的方法，然后提取所有批处理作业，并在所有这些任务中附加共同的步骤。
希望有更好的方法。
浏览 1提问于2013-12-27得票数 0
回答已采纳
我想运行一个包含一组步骤的spring批处理作业，最后，我希望向redis发送一个通知，其中包含作业执行的状态。假设所有步骤都已执行，我应该发送"Pass“。如果有任何执行或任何错误，我想传递“失败”。因此，我的最后一步将是通知redis更新状态，不管它是否完成，很好，或者得到了异常。
我的问题是：
我能在Spring批处理中实现这一点吗？
我可以使用通知函数作为最后一步，还是应该为此使用任何特定的方法？
我怎样才能获得工作的地位？
我知道我可以得到这样的职位：
JobExecution execution = jobLauncher.run(job, param
浏览 0提问于2019-07-26得票数 0
回答已采纳
我遇到了这样一种情况:传入JobExecutionListener.afterJob()方法的作业状态具有FINISHED作业执行状态，但是当我去检查batch db模式中的相同JobExecution时，我发现作业状态仍然设置为RUNNING。
我需要他们两个保持同步。
有什么办法可以拥有这个吗？我可以直接使用JobRepository在afterJob ()方法中使用传递的JobExecution实例安全地更新批处理数据库吗？这有什么副作用吗？
浏览 0提问于2017-09-08得票数 0
我有一个JobExecutionListener.afterJob()实现，它打印从前面所有步骤执行中获得的一些信息：
JobExecutionListener.beforeJob()：
jobExecution.getExecutionContext().putString("key", "");
step1: StepExecutionListener.beforeStep()：
ExecutionContext context = stepExecution.getJobExecution().getExecutionContext();
context.
浏览 0提问于2014-04-02得票数 1
2回答
我有一个带有一系列作业的spring批处理应用程序。我想在所有的工作完成后发送一封电子邮件，但我不确定做这件事的最佳方法。我所考虑的方案如下：
按一定的顺序运行作业，修改上一个作业的JobListener，这样它就会发送电子邮件。这样做的缺点是，如果在批处理的末尾再添加一个作业，它将无法工作。
添加一个新的作业，这将发送电子邮件和订单的作业，确保这个额外的工作是最后运行。
在完成整个批处理时是否会触发任何内置的春季批处理构造？
最后一个选项将是我喜欢的解决方案，所以我的问题是，是否有任何春季批处理类侦听批完成(类似于JobExecutionListenerSupport或步
浏览 0提问于2018-06-21得票数 2
3回答
我有一堆应该同时运行的作业。
每一项工作都有它的后续工作。
Afterjob应该一个接一个地运行。
仅当作业完成时，Afterjob才能启动。
第一个完成的作业应立即调用其后续作业。
所有其他完成的作业应该将它们的售后作业放入队列中。
我正在尝试使用任务假脱机程序(tsp)将后续作业放入队列中。但是，如果任务完成了，我不知道如何捕捉。
#!/bin/bash
# Starting jobs and collecting their pids
job1 & job1_pid=$! &
job2 & job2_pid=$1 &
job3 & job3_pid
浏览 0提问于2018-07-03得票数 1
我是Spring batch和Spring的新手。我正在开发一个批处理作业，它将在WebSphere应用服务器上运行。到目前为止，我只是用一些虚拟步骤构建了一个骨架。我还有一个监听程序，用于在作业结束时更新一些Oracle DB表。这是我的appContext的一部分：
<batch:job id="spedizioneJob" restartable="true" parent="bankitJob">
<batch:step id="verifyInputStep" next="tec
浏览 1提问于2014-10-03得票数 0
使用TaskExecutor重新启动失败的春季批处理作业的正确方法是什么？
我有一个任务是从HTTP加载数据，有时会有500个错误--使这个作业失败)。我想重新启动这个工作，直到它成功。
如果我创建JobExecutionListener并在afterJob()方法中实现逻辑，就会得到该作业实际上正在运行的错误消息。如果我使用Spring中的RetryTemplate，这也不起作用，因为这是在TaskExecutor中运行的。
任何代码示例都会有很大帮助。
浏览 5提问于2016-10-17得票数 2
回答已采纳
1回答
问题陈述:在spring作业成功完成后，将无法访问设置在spring批处理分区内的ExecutionContext中的数据。
分区代码：
for (String files : fileNameListmatch) {
ExecutionContext executionContext = new ExecutionContext();
executionContext.putString("file", files);
partitionData.put("partition: " +
浏览 0提问于2020-02-11得票数 0
我对弹簧技术很陌生。我正在尝试构建一个ETL类似的应用程序，使用spring批处理与spring启动。
能够运行基本作业(读->进程->写)。现在，我想从一个配置文件(稍后)或命令行(现在就可以使用)读取参数(如日期、文件名、类型等)，并在我的工作中使用它们。
入境点：
// Imports
@SpringBootApplication
@EnableBatchProcessing
public class EtlSpringBatchApplication {
public static void main(String[] args) {
Spring
浏览 1提问于2020-05-21得票数 2
回答已采纳
可以使用CosmosDB作为Spring Batch的作业存储库吗？如果这是不可能的，我们可以使用内存中的DB来处理Spring批处理作业吗？作业本身在消息到达远程队列时触发。我们在当前的Spring批处理作业中使用了进程指示器的变体，以跟踪正在处理的“块”。我们的saveStep属性也被禁用。读取器总是使用DB查询，以避免拾取相同的块并防止重复处理。在处理完该作业的所有记录之前，我们不会提交队列中的消息。因此，如果节点死掉并在处理过程中重新启动，则将重新传递相同的消息，这需要重新启动作业。考虑到这一切，我们有两种选择，一种是想出一种实现cosmos作业存储库的方法，另一种是简单地使用内存中并
浏览 3提问于2020-09-29得票数 0
我需要有以下工作流程：
运行"beforejob“->运行作业( job1，job2，job3) ->当job1，job2，job3完成时运行"afterJob”。
只有在所有作业job1、job2、job3都已通过状态的情况下，作业"afterJob“才应已通过状态。
如果某些作业job1、job2、job3的状态为FAILED，则"afterJob“也应处于FAILED状态。
它类似于，但只有在所有作业都已通过状态的情况下，join插件才会运行joinJob。
PS。
我需要它发送通知的状态不是从每个作业，但从每个组的一个afterJob。
浏览 3提问于2012-09-10得票数 1
我使用的是spring-batch和spring-boot 2.5.6。我决定使用以Kafka为中间件的远程分区。我有一个经理和三个工人。因此，为管理器的输入主题分配了一个分区，为员工的输入分配了三个分区。
管理器获取一个文件，创建多个ExecutionContext，并通过Kafka发送这些文件。工作人员开始处理相应的步骤，并在流程结束时发送消息。经理将汇总员工的结果，并决定完成所有员工的工作。到目前一切尚好。
现在假设我首先运行一个需要大量时间才能完成的长期运行的作业，然后运行一个完成很快的小任务。不足为奇的是，第二个作业完成得更快，并发出一个已完成的信号，经理将使用此消息并继续该过程。我
浏览 7提问于2022-06-13得票数 0
回答已采纳
我使用这个示例作为春季批处理应用程序的起点，使用远程分块： --在本例中，我添加了我的自定义读取器/编写器，但没有更改任何配置。这个例子很好，只是当所有的奴隶都完成后，我不能停止工作。
我试过使用JobListner，在'afterJob‘方法中停止作业，但没有结果。
public class MyJobExecutionListener implements JobExecutionListener {
@Override
public void beforeJob(JobExecution jobExecution) {
// TODO Auto-generated me
浏览 0提问于2019-01-02得票数 0
回答已采纳
我有一个JobExecutionListener，它在执行后将作业状态写入日志文件。如何才能得到处理的项目数？
@Component
public class JobListener implements JobExecutionListener {
@Override
public void afterJob(JobExecution task) {
log.info(task.getStatus());
//number of entries??
}
}
浏览 1提问于2014-04-23得票数 0
回答已采纳
如何检测正在调用afterJob listener的已完成作业的作业id？我有一个正在批处理中启动的作业，我有一个监听器。
我的工作是PayrollJob，监听器是PayrollJobListener
<job id="payroll" xmlns="http://xmlns.jcp.org/xml/ns/javaee" version="1.0">
<listeners>
<listener ref="payrollJobListener"/>
</lis
浏览 1提问于2016-07-15得票数 1
我创建了一些Spring项目，并使用(SCDF)部署了这些作业。
在SCDF中启动任务(作业)之后，它创建JVM来执行任务(作业)。
但是，当任务完成时，JVM不会结束。它仍然存在。
当我开始工作20次时，它宣布
Cannot launch task A. The maximum concurrent task executions is at its limit [20]
还有一些关于我的工作的信息，作业的第一个日志以：
HikariPool-1 - Shutting down...
但是在Spring批处理项目中使用了下面的属性之后：
spring.cloud.task.singleIns
浏览 0提问于2020-02-08得票数 1
回答已采纳
我已经在JobExecutionListener的afterJob()方法中实现了将失败和成功的处理数存储到作业执行上下文中的函数：
public void afterJob(JobExecution jobExecution) {
final long jobExecutionId = jobExecution.getId();
final BatchStatus jobStatus = jobExecution.getStatus();
final ExecutionContext jobExecutionContext = jobExecution.get
浏览 1提问于2018-07-25得票数 0
1回答
我使用jsr-352编写我的工作，并将其部署在wildfly上。如何调度一个在上次结束时间后有一定延迟的作业，如下面的时间线，其中=是执行时间，-是延迟时间：
===============--=====--========--
注意:最大作业执行次数为1
浏览 17提问于2018-01-28得票数 0
2回答
我创建了一个捆绑多个批处理作业的应用程序。用户可以启动作业，然后将作业放在队列中。当作业完成后，我想向用户发送报告。
我知道有JobExecutionListener接口。我可以在afterJob()方法中实现电子邮件功能。下一步是将此侦听器注册到我的作业中。
有什么办法能自动完成我所有的工作吗？我不想为每一份新工作配置它。
浏览 4提问于2015-09-15得票数 2
回答已采纳
我是Spring batch的新手。我已经使用这个任务配置了一个新项目： @Configuration
@EnableBatchProcessing
@Log4j2
public class BatchConfiguration {
/* ... */
@Bean
public Job myJob(JobBuilderFactory jobBuilderFactory, Step stepInit, Step stepMain, Step stepReport) {
return jobBuilderFactory.get("myJob&#
浏览 83提问于2020-09-16得票数 1
回答已采纳
2回答
是否有解决方案允许您检查给定作业(JobInstance)的作业存储库，当天是否存在已完成的作业，如果当天batch_job_execution表上没有完成状态，那么我必须发送一个通知或退出代码，就像我们今天什么都没有得到的那样。
我计划在一个从JobExecutionListenerSupport扩展的类中实现该解决方案，如下所示：
public class JobCompletionNotificationListener extends JobExecutionListenerSupport {
private Logger logger = LoggerFactory.getLogg
浏览 1提问于2020-02-24得票数 0
我使用Spring 2.0.4，default版本启用了缓存，默认缓存提供程序只使用任何外部缓存提供程序。
我已经安排了一批每天在特定时间运行的批次。在其运行期间，涉及数据访问的某些方法调用被缓存，并且工作良好。
现在，我想在下一次函数开始之前按计划时间释放所有缓存的项。
我无法实现这个特性。你们都能指导我一些想法或如何实施吗？
这就是我想要实现的。我有一个标记为@Configuration的JobExecutionListener类。我正在使用它的afterJob方法来清除所有缓存。
@Configuration
@JobScope
public class JobTwoExecutionL
浏览 0提问于2018-09-28得票数 1
回答已采纳
我正在使用下面的ItemWriteListener来存储所遇到的id值。
我知道春季有Step和Job上下文，所以我尝试使用作业上下文来存储和撤回值。
@JobScope
@Component
public class JobWriteNotificationListener implements ItemWriteListener<Retailer> {
private ExecutionContext context;
public JobWriteNotificationListener(StepExecution context) {
th
浏览 0提问于2019-06-23得票数 1
回答已采纳
1回答
我有一个春季批处理过程，它从数据库读取数据并写入文件。基本上，场景是，用户可以发送请求，作业将启动和执行流程。但问题是，如果用户发送5次请求，将有5个不同的春季作业启动并运行。但这些都是重复的。那么，我们是否可以避免或阻止创建重复的弹簧作业呢？
浏览 6提问于2022-02-12得票数 1
回答已采纳
我获得了一个正常工作的Spring批处理作业；我添加了一个作业侦听器来更改应用程序的退出状态，但是作业从未进入侦听器(从未调用beforeJob和afterJob )。这是我代码的一部分：
@Bean(name = "myJob")
public Job myJob(@Qualifier("initStep") Step initStep,
@Qualifier("firstStep") Step firstStep,
@Qualifier("onSuccessStep") Step onSucce
浏览 1提问于2020-03-19得票数 1
回答已采纳
我在阅读器的open中创建了一个连接Connection con = ds.getConnection();(其中ds是DataSource)，并在阅读器的close()中关闭了它。
但是当我运行一个有多个分区的作业时，在作业中间，我得到了连接已关闭的错误
Caused by: java.sql.SQLException: [jcc][t4][10335][10366][3.58.82] Invalid operation: Connection is closed. ERRORCODE=-4470, SQLSTATE=08003 DSRA0010E: SQL State = 08003, E
浏览 17提问于2016-07-22得票数 0
我有一个包含多个步骤的主spring批处理作业。如果该作业由于某种原因而失败，我需要调用另一个作业来使用失败结果更新数据库中的表。
如何配置我的批处理流来执行此操作？
我像这样创建了一个JobExecution，但我不知道如何从if/else语句中调用新作业：
@Bean
public JobExecutionListener dataListener() {
JobCompletionNotificationListener dataNotificationListener = new JobCompletionNotificationListener(new Jd
浏览 1提问于2016-09-21得票数 0
问题是:我有一个只有一个步骤的Spring批处理作业。此步骤被多次调用。如果每次都调用一切正常(无异常)，则作业状态为“已完成”。如果至少在步骤的一次执行中发生了糟糕的事情(抛出异常)，我已经配置了一个StepListener，它将退出代码更改为FAILED：
public class SkipCheckingListener extends StepExecutionListenerSupport {
public ExitStatus afterStep(StepExecution stepExecution) {
String exitCode = stepEx
浏览 0提问于2011-10-25得票数 2
回答已采纳
1回答
我的Spring批处理应用程序消耗了太多的资源(+4 go Ram)。
当我查看jvm时，应用程序会创建10个线程。
我使用分区程序逐个处理文件，而不使用调度程序。
jobExecutionListener用于在执行结束时停止批处理。
@Bean公共作业mainJob()抛出IOException { SimpleJobBuilder mainJob = this.jobBuilderFactory.get("mainJob") .start(previousStep()) .next(partitionStep()) .next(finalStep())返回mainJ
浏览 2提问于2019-03-06得票数 0
回答已采纳
1回答
停止使用注释语法侦听队列。
、、、、
我和一位同事正在开发一个使用Spring的应用程序，该应用程序需要从RabbitMQ队列中获取消息。这样做的想法是使用(通常是优秀的) spring注释系统来使代码易于理解。我们让系统使用@RabbitListner注释工作，但我们希望按需获得消息。@RabbitListner注释没有这样做，它只在消息可用时接收消息。需求取决于客户端的“就绪状态”，即客户端应该从te队列“获取”消息、停止列表并处理消息。然后确定它是否准备好接收一个新的并重新连接到队列。
我们一直在使用spring /Spring-兔子模块手工完成这一任务，尽管这可能是可能的，但我们确实希望使用spring来实现这一点。经过几
浏览 3提问于2015-12-17得票数 2
回答已采纳
我试图使用手动确认从一个主题消费多个消息，但如果所有消息都只有一次确认，则确认工作。
@KafkaListener(
id = "${kafka.buyers.product-sales-pricing.id}",
topics = "${kafka.buyers.product-sales-pricing.topic}",
groupId = "${kafka.buyers.group-id}",
concurrency = "${kafka.buyers.concurrency}"
)
publ
浏览 4提问于2019-08-01得票数 1
我正在尝试用一个兔子绑定器来配置一个spring云流应用程序。
spring cloud stream : 3.1.4
spring cloud stream rabbit binder : 3.1.4
spring version : 2.5.5
下面是我的配置：
spring:
cloud:
stream:
rabbit:
bindings:
listen-in-0:
consumer:
queueNameGroupOnly: true
enable-
浏览 2提问于2021-10-27得票数 1
回答已采纳
那么两个部分的问题。
首先，我最近在一个春季批处理作业的侦听器中遇到了一个错误。这项工作处理了2000份记录，并成功地处理了其中的1790份。侦听器在遇到异常并失败之前只处理了大约100条记录。作业中没有任何其他异常被记录下来，除了相同的异常被记录并在前面
2018-01-10 15:21:24.798错误16416 -池-5线程-7 o.s.batch.core.job.AbstractJob : afterStep回调中遇到的异常
是否有可能在监听器完成处理/提交其余210条记录之前，杀死侦听器的异常也停止了作业？这似乎没有多大意义，但我不确定还有什么会导致这些记录不被提交。
第二
浏览 2提问于2018-01-11得票数 0
2回答
如何在spring batch中停止作业？我尝试使用下面的代码来使用这种方法：
public class jobListener implements JobExecutionListener{
@Override
public void beforeJob(JobExecution jobExecution) {
jobExecution.setExitStatus(ExitStatus.STOPPED);
}
@Override
public void afterJob(JobExecution jobExecution) {
// TODO A
浏览 27提问于2017-08-25得票数 5
1回答
X射线集成到我的服务中，当一些端点从其他服务中触发时，一切正常。
Spring批处理作业用于处理某些数据并将其部分推送到SNS主题。这项工作是通过SimpleJobLauncher启动的。
问题是，在从Spring批处理到SNS的过程中，引发了以下异常：SegmentNotFoundException: No segment in progress。
根据文档，看起来我需要将跟踪ID传递给作业：
有谁知道将X射线与Spring批处理集成的最佳方法是什么？最干净的解决方案是什么？
浏览 6提问于2022-03-21得票数 0
我们可以使用JUnit来测试java批处理作业吗？由于Junit在本地运行，java批处理作业在服务器上运行，所以我不确定如何从JobOperator测试用例开始作业(我尝试过使用JUnit类)。
如果JUnit不是正确的工具，那么我们如何对java批处理代码进行单元测试。
我正在使用IBM的JSR 352实现，运行在WAS上
浏览 7提问于2016-09-14得票数 2
我们有大约20个不同的Spring批处理作业(一些作为微服务运行，一些集中在一个Spring Boot应用程序中)。我需要做的是收集所有作业遇到的所有错误，以及处理的记录数量，并在电子邮件中总结所有这些错误。 作为开始，我已经实现了ItemListenerSupport： public class BatchItemListener extends ItemListenerSupport<BaseDomainDataObject, BaseDomainDataObject> {
private final static Log logger = LogFactory.ge
浏览 5提问于2019-11-19得票数 0
回答已采纳
spring批管理如何从UI中停止正在运行的作业。
在春季批管理的在线文档中，我阅读了以下几行。
“正在执行的作业可以由用户停止(不管它是否可启动)。停止信号通过数据库发送，一旦由Spring批处理在运行作业的任何进程中检测到，作业就会停止(状态从停止移动到停止)，不再进行进一步的处理。”
这是否意味着Spring管理UI正在直接更改spring批处理表中的作业状态？
更新：我尝试在正在运行的作业上执行以下查询。
update batch_job_execution set status="STOPPED" where job_ins
tance_id=19;
上面的查
浏览 3提问于2015-10-22得票数 1
1回答
我正在从普通的spring批处理迁移到spring云任务，并通过spring云数据流执行spring批处理。在我的工作和我为文件伤害而部署的示例工作中，我都遇到了以下问题：
我正在使用带有postgres后端的spring-cloud-dataflow-server-local-1.4.0.RELEASE。我还对该示例进行了修改，以便使用postgres数据库。
当我尝试第二次使用不同的参数运行任务时，就会出现问题。当我第一次运行它时：
task launch fileInjectTask --arguments "filePath=classpath:data.csv --spri
浏览 0提问于2018-03-21得票数 1
我正在使用AWSBatch Java com.amazonaws.services.batch (AWS SDK for Java - 1.11.483)以编程方式提交作业。
然而，我们的科学家不断更新工作定义。每次有新的作业定义时，我都必须用修订号更新环境变量，以便将其传递给客户端。说
此值可以是作业定义的名称:修订，也可以是(ARN)。
我是否可以将其默认为最新版本，并且每次提交BatchJob时，都会在不知道上一次修订的情况下选择最新版本吗？
浏览 0提问于2019-01-29得票数 8
回答已采纳
我正在寻找最好的解决方案，以创建一个java web应用程序，以生成excel/PDf格式的报告。一些类似于Google Adwords的东西，用户可以创建计划报告，并在以后生成报告时下载它。
我正在考虑开发和java应用程序，其中用户登录，选择一个预定义的报告，并提供输入参数(如报告日期等)，这个请求将被排队或保存为Quarts作业(首选持久队列)。作业将监控队列/作业并执行作业，生成报告(输出excel /pdf)并存储在磁盘中。当用户刷新屏幕或稍后重新登录时，报告应可供下载。
使用Spring batch和Quartz调度器可以做到这一点吗？我也希望像Spring admin一样，我可以
浏览 0提问于2012-12-06得票数 4
回答已采纳
1回答
我试图将作业数组中作业的索引作为参数传递给另一个bash脚本。
numSims=3
numTreatments=6 # uses numTreatments top rows of parameters.csv
maxFail=10
j=1
while [ $j -le $numSims ];
do
bsub -q someQueue -J "mySim[1-$numTreatments]%2" ./another_script.sh $LSB_JOBINDEX $j $maxFail
let j=j+1
done
这里的最终想法是为1中的每一个提交n
浏览 4提问于2012-06-26得票数 2
回答已采纳
1回答
如何在我的程序(运行火花流作业)中获得每个rdd作业所需的时间。例如
val streamrdd = KafkaUtils.createDirectStream[String, String, StringDecoder,StringDecoder](ssc, kafkaParams, topicsSet)
val processrdd = streamrdd.map(some operations...).savetoxyz
在上面的代码中，对于每个微批rdd，作业是为map和saveto操作运行的。
我想得到每个流媒体工作的timetake。我可以在端口4040 UI中看到作业，但想要
浏览 1提问于2016-09-12得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
