《兴业证券》专题
-
Spring批和石英运行作业状态
我使用的是spring batch 3.0.2和quartz 2.2.1。两者都使用由两个API提供的元表。Spring批处理作业由quartz调度，并在调度时间调用。Quartz和Spring批处理表中都有所有信息。 现在我想要得到工作运行状态，这是由石英时间表。我不知道，我怎么能把石英作业键和Spring批联系起来。这样我就可以找到quartz系统调度的spring批处理作业的运行状态。
-
如何使用REST API停止Flink作业
-
对hadoop作业跟踪器api的困惑
我在试着从工作跟踪器那里收集一些信息。对于初学者，我想从获得正在运行的作业信息开始，如作业id或作业名称等，但已经卡住了，以下是我获得的（打印当前正在运行的作业的作业id）： 当试图显示作业id时，上面的工作很有魅力，但现在我也想显示作业名称。所以我在打印作业id后添加了这一行： 首先从jobClient获取，然后获取它的名称http://hadoop.apache.org/mapreduce/d
-
作业启动网关和持久队列
我向连接到JobLaunchingGateway的spring-integration通道发送一条消息，对于每个消息，JobLaunchingGateway尝试启动一个新的TaskExecutor。 让通道由一个持久队列（例如ActiveMQ）支持，让任务执行器池大小等于2。 我想对系统进行配置，以便当executor池大小已经使用时，新消息不会被JobLaunchingGateway使用，而是保
-
Spring Boot：Spring Batch作业不会自动启动
主类 作业配置 HelloWorldTasklet 为了使事情更清楚，这是我在jar中看到的文件夹列表。看起来spring boot maven插件是用来创建jar的？那么，为什么批处理作业不在Eclipse之外启动： 注意：如您所见，日志还显示确实选择了主概要文件，因为在启动任务时，我传递了作为输入参数。
-
Spring使用Quartz的顺序作业计划
Spring使用Quartz的顺序作业计划 我有三个或更多的工作，这取决于他们各自以前的工作，他们将按顺序运行。如果完成运行，当完成运行。如果在上一个中发生任何错误，则不会激发下一个触发的作业。我试图了解工作链使用石英，但无法通过它。 作业顺序如下所示 提前谢了。
-
Spring Integration Service Activator处理器业务逻辑
我目前刚接触Spring integration。 基本上尝试使用Java Spring integration DSL异步轮询多个文件位置。我需要获取文件名，并使用文件名执行一些操作，最后将文件推送到S3，我的问题是这些使用文件执行操作的任务是否可以在任务执行器或服务激活器处理程序中执行。我不确定哪个地方是对的。 我在这里附上了示例代码。 还有一种方法可以检索通道中文件的文件名，因为我需要将它作
-
如何进行“顺序”作业调度（Quartz？）
我正在利用石英调度，有2个工作。第一个工作是执行大约2分钟的任务，第二个是设置为临时文件的清理操作。因此，我需要设置时间表，以一种方式工作，即在第一个作业被执行/完成执行任务后，我需要在第二个作业的帮助下进行清洁操作。 考虑到Quartz 2.1.x下的示例9-Job Listeners，该示例说明我们可以定义一个名为jobWasExecuted（_,_）的方法；并在第一个作业被执行/或处于运行状
-
Quartz排定程序：作业执行多次
如何将CronTimer迭代器设置为1？或者如何停止排定程序多次执行作业。 有什么建议吗？谢谢，古扬·沙阿。
-
通过Jenkins作业部署maven的策略
我有一个Jenkins的工作，它为master git分支使用maven构建目标“干净包部署”。但是，由于nexus repo不允许重新部署，如果Jenkins作业在没有版本更改的情况下第二次运行，它将失败并出现预期的400错误： 有人能提出一种不同的策略吗？这样，部署目标就可以运行，而不会让Jenkins的工作失败？
-
使用批处理作业的FlatFileItemReader和FlatFileItemWriter
我想从文本文件中读取、解析和写入数据。我实现了这一点，但我有一个关于标识符声明的问题。我在下面展示了我的类。 客户数据apper.java 顾客JAVA 文件管理器。xml 我想问这个问题，我可以在FieldSetMapper中使用下面的类吗？如果我在定义标识符时不使用Camelcase符号，那么写入数据库就不起作用了。有什么方法或方法吗？非常感谢。 顾客JAVA
-
多次运行的Spring批处理作业
Spring批处理作业与flatfileitemreader（从csv读取）、processor（更新adwords api提要详细信息，对于csv文件中的每个记录（大约有40条记录），这一步大约需要40秒）和正在更新DB中记录的定制writer一起使用。 web.xml
-
Quartz作业无法使用Spring JpaRepository函数
Job1在org.eko.businessjobs.Job1.doperform(Job1.java:23)在org.eko.jobs.businessjoba.executeinternal(businessjoba.java:34)在org.springframework.scheduling.quartz.quartzjobbean.execute(quartzjobbean.java:75
-
为SQL Server 2012企业版搜索JDBC河
我在使用ElasticSearch River的JDBC驱动程序从SQL Server 2012 enterprise获取数据时遇到问题。 这是我的设置： 操作系统：Windows 2008 R2 X64 ES： 1.2.1 JDK：jdk-7u60-windows-x64 JRE： jre-7u60-windows-x64 适用于SQL服务器的Microsoft JDBC驱动程序4.0 当我运行
-
Flink HA群集作业管理器问题
我有一个Flink 1.2集群的设置，由3个JobManager1和2个TaskManager1组成。我从JobManager1开始动物园管理员法定人数，我得到确认，动物园管理员开始其他2个JobManager1，然后我在这个JobManager1上开始一个Flink作业。 flink-conf.yaml在所有5个虚拟机上都是相同的，这意味着jobmanager。rpc。地址：指向各处的JobMa