org.apache.helix.task.WorkflowContext.setJobState()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(91)

本文整理了Java中org.apache.helix.task.WorkflowContext.setJobState()方法的一些代码示例，展示了WorkflowContext.setJobState()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WorkflowContext.setJobState()方法的具体详情如下：
包路径：org.apache.helix.task.WorkflowContext
类名称：WorkflowContext
方法名：setJobState

WorkflowContext.setJobState介绍

暂无

代码示例

代码示例来源：origin: com.linkedin.gobblin/gobblin-cluster

  1. private void markJobComplete(String jobName, JobContext jobContext,
  2.   WorkflowConfig workflowConfig, WorkflowContext workflowContext) {
  3.  long currentTime = System.currentTimeMillis();
  4.  workflowContext.setJobState(jobName, TaskState.COMPLETED);
  5.  jobContext.setFinishTime(currentTime);
  6.  if (isWorkflowFinished(workflowContext, workflowConfig)) {
  7.   workflowContext.setFinishTime(currentTime);
  8.  }
  9. }

代码示例来源：origin: org.apache.helix/helix-core

  1. protected void markJobComplete(String jobName, JobContext jobContext,
  2.   WorkflowConfig workflowConfig, WorkflowContext workflowContext,
  3.   Map<String, JobConfig> jobConfigMap, ClusterDataCache clusterDataCache) {
  4.  long currentTime = System.currentTimeMillis();
  5.  workflowContext.setJobState(jobName, TaskState.COMPLETED);
  6.  jobContext.setFinishTime(currentTime);
  7.  if (isWorkflowFinished(workflowContext, workflowConfig, jobConfigMap, clusterDataCache)) {
  8.   workflowContext.setFinishTime(currentTime);
  9.   updateWorkflowMonitor(workflowContext, workflowConfig);
  10.  }
  11.  scheduleJobCleanUp(jobConfigMap.get(jobName), workflowConfig, currentTime);
  12. }

代码示例来源：origin: apache/helix

  1. protected void markJobFailed(String jobName, JobContext jobContext, WorkflowConfig workflowConfig,
  2.   WorkflowContext workflowContext, Map<String, JobConfig> jobConfigMap,
  3.   TaskDataCache clusterDataCache) {
  4.  long currentTime = System.currentTimeMillis();
  5.  workflowContext.setJobState(jobName, TaskState.FAILED);
  6.  if (jobContext != null) {
  7.   jobContext.setFinishTime(currentTime);
  8.  }
  9.  if (isWorkflowFinished(workflowContext, workflowConfig, jobConfigMap, clusterDataCache)) {
  10.   workflowContext.setFinishTime(currentTime);
  11.   updateWorkflowMonitor(workflowContext, workflowConfig);
  12.  }
  13.  scheduleJobCleanUp(jobConfigMap.get(jobName), workflowConfig, currentTime);
  14. }

代码示例来源：origin: org.apache.helix/helix-core

  1. protected void markJobFailed(String jobName, JobContext jobContext, WorkflowConfig workflowConfig,
  2.   WorkflowContext workflowContext, Map<String, JobConfig> jobConfigMap,
  3.   ClusterDataCache clusterDataCache) {
  4.  long currentTime = System.currentTimeMillis();
  5.  workflowContext.setJobState(jobName, TaskState.FAILED);
  6.  if (jobContext != null) {
  7.   jobContext.setFinishTime(currentTime);
  8.  }
  9.  if (isWorkflowFinished(workflowContext, workflowConfig, jobConfigMap, clusterDataCache)) {
  10.   workflowContext.setFinishTime(currentTime);
  11.   updateWorkflowMonitor(workflowContext, workflowConfig);
  12.  }
  13.  scheduleJobCleanUp(jobConfigMap.get(jobName), workflowConfig, currentTime);
  14. }

代码示例来源：origin: apache/helix

  1. protected void markJobComplete(String jobName, JobContext jobContext,
  2.   WorkflowConfig workflowConfig, WorkflowContext workflowContext,
  3.   Map<String, JobConfig> jobConfigMap, ClusterDataCache clusterDataCache) {
  4.  long currentTime = System.currentTimeMillis();
  5.  workflowContext.setJobState(jobName, TaskState.COMPLETED);
  6.  jobContext.setFinishTime(currentTime);
  7.  if (isWorkflowFinished(workflowContext, workflowConfig, jobConfigMap, clusterDataCache.getTaskDataCache())) {
  8.   workflowContext.setFinishTime(currentTime);
  9.   updateWorkflowMonitor(workflowContext, workflowConfig);
  10.  }
  11.  scheduleJobCleanUp(jobConfigMap.get(jobName), workflowConfig, currentTime);
  12. }

代码示例来源：origin: org.apache.helix/helix-core

  1. protected void handleJobTimeout(JobContext jobCtx, WorkflowContext workflowCtx,
  2.   String jobResource, JobConfig jobCfg) {
  3.  jobCtx.setFinishTime(System.currentTimeMillis());
  4.  workflowCtx.setJobState(jobResource, TaskState.TIMED_OUT);
  5.  // Mark all INIT task to TASK_ABORTED
  6.  for (int pId : jobCtx.getPartitionSet()) {
  7.   if (jobCtx.getPartitionState(pId) == TaskPartitionState.INIT) {
  8.    jobCtx.setPartitionState(pId, TaskPartitionState.TASK_ABORTED);
  9.   }
  10.  }
  11.  _clusterStatusMonitor.updateJobCounters(jobCfg, TaskState.TIMED_OUT);
  12.  _rebalanceScheduler.removeScheduledRebalance(jobResource);
  13.  TaskUtil.cleanupJobIdealStateExtView(_manager.getHelixDataAccessor(), jobResource);
  14. }

代码示例来源：origin: apache/helix

  1. protected void handleJobTimeout(JobContext jobCtx, WorkflowContext workflowCtx,
  2.   String jobResource, JobConfig jobCfg) {
  3.  jobCtx.setFinishTime(System.currentTimeMillis());
  4.  workflowCtx.setJobState(jobResource, TaskState.TIMED_OUT);
  5.  // Mark all INIT task to TASK_ABORTED
  6.  for (int pId : jobCtx.getPartitionSet()) {
  7.   if (jobCtx.getPartitionState(pId) == TaskPartitionState.INIT) {
  8.    jobCtx.setPartitionState(pId, TaskPartitionState.TASK_ABORTED);
  9.   }
  10.  }
  11.  _clusterStatusMonitor.updateJobCounters(jobCfg, TaskState.TIMED_OUT);
  12.  _rebalanceScheduler.removeScheduledRebalance(jobResource);
  13.  TaskUtil.cleanupJobIdealStateExtView(_manager.getHelixDataAccessor(), jobResource);
  14. }

代码示例来源：origin: org.apache.helix/helix-core

  1. } else {
  2.  scheduleSingleJob(job, jobConfig);
  3.  workflowCtx.setJobState(job, TaskState.NOT_STARTED);
  4.  scheduledJobs++;

代码示例来源：origin: apache/helix

  1. } else {
  2.  scheduleSingleJob(job, jobConfig);
  3.  workflowCtx.setJobState(job, TaskState.NOT_STARTED);
  4.  scheduledJobs++;

代码示例来源：origin: org.apache.helix/helix-core

  1. workflowCtx.setJobState(jobResource, TaskState.STOPPED);
  2. workflowCtx.setJobState(jobResource, TaskState.IN_PROGRESS);
  3.     workflowCtx.setJobState(jobResource, TaskState.FAILED);
  4.     if (workflowConfig.isTerminable()) {
  5.      workflowCtx.setWorkflowState(TaskState.FAILED);
  6. workflowCtx.setJobState(jobResource, TaskState.COMPLETED);
  7. jobCtx.setFinishTime(currentTime);
  8. if (isWorkflowComplete(workflowCtx, workflowConfig)) {

代码示例来源：origin: apache/helix

  1. workflowCtx.setJobState(jobResource, TaskState.STOPPED);
  2. workflowCtx.setJobState(jobResource, TaskState.IN_PROGRESS);
  3.     workflowCtx.setJobState(jobResource, TaskState.FAILED);
  4.     if (workflowConfig.isTerminable()) {
  5.      workflowCtx.setWorkflowState(TaskState.FAILED);
  6. workflowCtx.setJobState(jobResource, TaskState.COMPLETED);
  7. jobCtx.setFinishTime(currentTime);
  8. if (isWorkflowComplete(workflowCtx, workflowConfig)) {

代码示例来源：origin: com.linkedin.gobblin/gobblin-cluster

  1. workflowCtx.setJobState(jobResource, TaskState.STOPPED);
  2. workflowCtx.setJobState(jobResource, TaskState.IN_PROGRESS);

代码示例来源：origin: apache/helix

  1. for (String jobToFail : cfg.getJobDag().getAllNodes()) {
  2.  if (ctx.getJobState(jobToFail) == TaskState.IN_PROGRESS) {
  3.   ctx.setJobState(jobToFail, TaskState.ABORTED);

代码示例来源：origin: org.apache.helix/helix-core

  1. for (String jobToFail : cfg.getJobDag().getAllNodes()) {
  2.  if (ctx.getJobState(jobToFail) == TaskState.IN_PROGRESS) {
  3.   ctx.setJobState(jobToFail, TaskState.ABORTED);

代码示例来源：origin: apache/helix

  1. public static WorkflowContext buildWorkflowContext(String workflowResource,
  2.   TaskState workflowState, Long startTime, TaskState... jobStates) {
  3.  WorkflowContext workflowContext =
  4.    new WorkflowContext(new ZNRecord(TaskUtil.WORKFLOW_CONTEXT_KW));
  5.  workflowContext.setName(workflowResource);
  6.  workflowContext.setStartTime(startTime == null ? System.currentTimeMillis() : startTime);
  7.  int jobId = 0;
  8.  for (TaskState jobstate : jobStates) {
  9.   workflowContext
  10.     .setJobState(TaskUtil.getNamespacedJobName(workflowResource, JOB_KW) + jobId++, jobstate);
  11.  }
  12.  workflowContext.setWorkflowState(workflowState);
  13.  return workflowContext;
  14. }

代码示例来源：origin: apache/helix

  1. jobCtx.setStartTime(System.currentTimeMillis());
  2.  jobCtx.setName(jobName);
  3.  workflowCtx.setJobState(jobName, TaskState.IN_PROGRESS);
  4.   || TaskState.TIMED_OUT.equals(workflowState))) {
  5.  jobState = TaskState.TIMING_OUT;
  6.  workflowCtx.setJobState(jobName, TaskState.TIMING_OUT);
  7. } else if (jobState != TaskState.TIMING_OUT && jobState != TaskState.FAILING) {
  8.    workflowCtx.setJobState(jobName, TaskState.STOPPED);
  9.   } else {
  10.    workflowCtx.setJobState(jobName, TaskState.STOPPING);
  11.   workflowCtx.setJobState(jobName, TaskState.IN_PROGRESS);

代码示例来源：origin: org.apache.helix/helix-core

  1. jobCtx.setStartTime(System.currentTimeMillis());
  2.  jobCtx.setName(jobName);
  3.  workflowCtx.setJobState(jobName, TaskState.IN_PROGRESS);
  4.   || TaskState.TIMED_OUT.equals(workflowState))) {
  5.  jobState = TaskState.TIMING_OUT;
  6.  workflowCtx.setJobState(jobName, TaskState.TIMING_OUT);
  7. } else if (jobState != TaskState.TIMING_OUT && jobState != TaskState.FAILING) {
  8.    workflowCtx.setJobState(jobName, TaskState.STOPPED);
  9.   } else {
  10.    workflowCtx.setJobState(jobName, TaskState.STOPPING);
  11.   workflowCtx.setJobState(jobName, TaskState.IN_PROGRESS);

代码示例来源：origin: apache/helix

  1. return buildEmptyAssignment(jobResource, currStateOutput);
  2. workflowCtx.setJobState(jobResource, TaskState.FAILING);

代码示例来源：origin: org.apache.helix/helix-core

  1. return buildEmptyAssignment(jobResource, currStateOutput);
  2. workflowCtx.setJobState(jobResource, TaskState.FAILING);

代码示例来源：origin: apache/helix

  1. wfCtx.setJobState(_testJobPrefix + "0", TaskState.COMPLETED);
  2. wfCtx.setJobState(_testJobPrefix + "1", TaskState.COMPLETED);
  3. wfCtx.setWorkflowState(TaskState.IN_PROGRESS);
  4. wfCtx.setName(_testWorkflow);
  5. wfCtx.setJobState(_testJobPrefix + "0", TaskState.FAILED);
  6. taskDataCache.updateJobContext(_testJobPrefix + "0", jbCtx0);
  7. jbCtx2.setName(_testJobPrefix + "2");
  8. jbCtx2.setPartitionState(1, TaskPartitionState.INIT);
  9. wfCtx.setJobState(_testJobPrefix + "2", TaskState.IN_PROGRESS);
  10. taskDataCache.updateJobContext(_testJobPrefix + "2", jbCtx2);

内容来源于网络，如有侵权，请联系作者删除！

WorkflowContext

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com