标签: job-scheduling

我正在运行一个 sbatch 脚本，它已成功提交。

sbatch sbatch_script.sh

Submitted batch job 309376

squeue -u <my_username>但是当我运行并且没有生成输出时它不会显示。

有没有办法检查出了什么问题？例如，我可以检查一些环境变量设置/输出日志吗？

我正在使用Quartz Enterprise Job Scheduler(1.8.3).作业配置来自几个xml文件,我们有一个特殊的作业,可以检测这些xml文件中的更改并重新计划作业.这很有用,但问题是我还需要这个"调度程序工作"来重新安排自己.一旦这个工作重新安排自己,由于某种原因,我看到它被执行了很多次.但我没有看到任何例外.

我已经复制并隔离了这个问题.这将是切入点:

public class App {
    public static void main(final String[] args) throws ParseException, SchedulerException {
    // get the scheduler from the factory
    final Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

    // start the scheduler
    scheduler.start();

    // schedule the job to run every 20 seconds
    final JobDetail jobDetail = new JobDetail("jobname", "groupname", TestJob.class);        
    final Trigger trigger = new CronTrigger("triggername", "groupname", "*/20 * * * * ?");

    // set the scheduler in the job data map, so the job can re-configure …

我正在测试Quartz来安排工作.但是,该作业包含3个不可序列化的参数.

我在下面创建了一个示例应用程序,指示我如何实现该功能.有谁知道如何使用Quartz将自定义对象用作参数？

下面是调度工作的触发器,我已经评论了给我问题的区域.

public class Trigger {

public void run() throws Exception {

    SchedulerFactory sf = new StdSchedulerFactory();
    Scheduler sched = sf.getScheduler();
    Date startTime = DateBuilder.nextGivenSecondDate(null, 15);


    JobDetail job = newJob(SimpleJob.class)
            .withIdentity("job6", "group1")
            .build();

    SimpleTrigger trigger = newTrigger()
            .withIdentity("trigger6", "group1")
            .startAt(startTime)
            .withSchedule(simpleSchedule()
                    .withIntervalInSeconds(60)
                    .repeatForever())
            .build();

    Date ft = sched.scheduleJob(job, trigger);

    TestObject testObject = new TestObject();

    // This is the part giving trouble!
    job.getJobDataMap().put(SimpleJob.test,testObject);

    sched.start();
}

}

这是我要安排的工作.

public class SimpleJob implements Job {

public static final TestObject test = null; …

我们可以在同一个hadoop集群中同时使用Fair调度程序和Capacity Scheduler.哪种调度程序是好的和有效的.谁能帮我 ？

我正在尝试从 sos-berlin jobscheduler 执行一个 php 文件。我的操作系统是 windows 7。我正在遵循文档

http://www.sos-berlin.com/mediawiki/index.php/How_to_execute_a_PHP_script_with_JS

#!/usr/bin/php

<?php 

 echo "hello";

?>

但是当我执行脚本时我收到错误

'#!' is not recognized as an internal or external command, operable program or batch file.

我开始明白 #!/usr/bin/php 是一个 Linux 命令。我应该在这里给出等效的批处理命令。我用谷歌搜索，但没有找到任何有用的结果。请任何人帮助我...

提前致谢。

我为工作定义了以下触发器：

var postbagJobTrigger = (ICronTrigger)TriggerBuilder.Create()
        .WithIdentity("cronJOBBER", "Campaigns")
        .WithCronSchedule("0 13 9 1/5 * ? *")
        .StartAt(new DateTime(2014, 12, 3))
        .EndAt(new DateTime(2015, 3, 3))
        .WithPriority(1)
        .Build();

我期望的是第一次触发DateTime(2014, 12, 3)。但是，当我看到这份工作的解雇时间表时，第一次是DateTime(2014, 12, 6)。当我添加StartNow()条件时，第一时间将是现在开始符合计划的时间DateTime(2014, 10, 31)。我怎样才能知道触发器在我的第一次运行StartAt()？

什么是默认作业优先级,如果我提交作业而不给予JOB任何优先权.

我试图通过下面的命令提交JOB

SBMJOB CMD(JAVA CLASS(test.jar)PARM(true)OUTPUT(*NONE))JOB(MYTESTJOBNAME)

这项工作的优先考虑是什么.任何帮助赞赏.

谢谢

我的用例是使用气流控制跨微服务的大量预定作业。我正在尝试的解决方案是使用气流作为集中式作业调度程序并通过进行 http 调用来触发作业。其中一些作业将运行很长时间，例如。超过 10 分钟或长达 1 小时。

如何通过气流定期检查这些作业的状态？如果远程任务已完成但气流不知道作业成功怎么办？我可以将作业完成事件发布到 kafka 并让气流在 kafka 上监听以获取作业状态吗？

我的混合式Cordova Android应用程序使用一个自定义插件，在该插件中，我大约每30分钟执行一次后台工作。到现在为止，我已经使用AlarmManger了setInexact报警执行工作。我对该路由唯一真正的问题是，警报无法在重新启动后幸免。鉴于我现在只支持Android的6（API 23）+设备现在我与更换试验AlarmManager用JobScheduler。到目前为止，我的努力如下所示

public class UnyService extends JobService 
{

 @Override
 public boolean onStartJob(JobParameters params) 
 {
  UnyHandler.sendMessage(Message.obtain(UnyHandler,1,params));
  return true;
 }

 @Override
 public boolean onStopJob(JobParameters params)
 {
  UnyHandler.removeMessages(1);
  return false;
 }

我正在使用Handler来执行实际工作。的代码Handler如下所示

 private Handler UnyHandler = new Handler(new Handler.Callback()
 {
  @Override
  public boolean handleMessage(Message msg)
  {
   Feedback.postBackInfo("Handled it!");
   jobFinished((JobParameters)msg.obj,false);
   return true;
  }

  });

然后，我使用以下代码启动并运行该作业

private void launchTimerJob()
{
 timerJob = 
 (JobScheduler)context.getSystemService(Context.JOB_SCHEDULER_SERVICE);
 JobInfo.Builder builder = new JobInfo.Builder(1,new 
 ComponentName(Utils.packName,UnyService.class.getName()));

 builder.setPeriodic(30000);
 builder.setPersisted(true);
 builder.setBackoffCriteria(30000,JobInfo.BACKOFF_POLICY_LINEAR); …