apache / shardingsphere-elasticjob

Distributed scheduled job
Apache License 2.0
8.12k stars 3.28k forks source link

shardingsphere ui status is offline but application is success running #2208

Open GoyaDo opened 1 year ago

GoyaDo commented 1 year ago

image the job is success runing but status is offline and the other job status is online ,is right. i want this job status is correct

POM

<dependency>
            <groupId>org.apache.shardingsphere.elasticjob</groupId>
            <artifactId>elasticjob-lite-spring-boot-starter</artifactId>
            <version>3.0.3</version>
            <exclusions>
                <exclusion>
                    <groupId>curator-recipes</groupId>
                    <artifactId>org.apache.curator</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>curator-framework</groupId>
                    <artifactId>org.apache.curator</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>5.1.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>5.1.0</version>
        </dependency>

YAML

elasticjob:
  reg-center:
    server-lists: 127.0.0.1:2181
    namespace: jtys_sign_upload_job
  tracing:
    type: RDB
  jobs:
    signDataFlowJob:
      overwrite: true
      elastic-job-class: com.wisdom.jtys.task.elastic.SignDataFlowJob
      cron: 0/10 * * * * ?
      sharding-total-count: 1
      sharding-item-parameters: 0=100

JAVA


@Component
@Slf4j
@RequiredArgsConstructor
public class SignDataFlowJob implements DataflowJob<UploadInfo> {

    private final UploadInfoService uploadInfoService;
    private final BaseServiceFeign baseServiceFeign;
    private final TransferDataFactory transferDataFactory;

    @Override
    public List<UploadInfo> fetchData(ShardingContext shardingContext) {

        // 默认只有一个分片
        int shardingTotalCount = shardingContext.getShardingTotalCount();
        if (shardingTotalCount > 1) {
            return null;
        }
        log.info("当前抓取任务分片:{}", shardingTotalCount);
        return uploadInfoService.schedulerUpload(count);
    }

    @Override
    public void processData(ShardingContext shardingContext, List<UploadInfo> uploadInfoList) {

        log.info("当前处理数据任务分片:{}", shardingContext.getShardingTotalCount());

        // ...
    }
}
yaoxs1996 commented 1 year ago

I have a same problem in ejob-lite 3.0.2

linghengqian commented 2 months ago

I would say that the ElasticJob UI is currently in a deadlock state that no one knows how to maintain. So I put the corresponding Issue Tag.