test/dataflow
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge branch 'develop' of http://git.yuandian.com/testdemo/dataflow into develop

Browse Source 
Conflicts:
	src/main/java/com/yuandian/dataflow/controller/TaskLog.java
This commit is contained in:
huangsimin 2022-07-28 16:25:26 +08:00
commit 819325e744
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/yuandian/dataflow/controller/PacketsProcessor.java
View File

@ -9,6 +9,8 @@ package com.yuandian.dataflow.controller;
import java.io.Serializable;
import java.time.Instant;
import java.util.ArrayList;
import java.util.Random;
import java.util.concurrent.ThreadLocalRandom;
import com.alipay.sofa.jraft.Status;
import com.alipay.sofa.jraft.rpc.RpcContext;
@ -43,6 +45,8 @@ public class PacketsProcessor implements RpcProcessor<PacketsProcessor.PacketsRe
private ArrayList<Any> packets = new ArrayList<>();
}
public static Random rand = new Random();
@Override
public void handleRequest(RpcContext rpcCtx, PacketsRequest request) {
// StateServerFactory.getStateServer().updateFsmStateAsync(s, onCompleted);
@ -54,8 +58,11 @@ public class PacketsProcessor implements RpcProcessor<PacketsProcessor.PacketsRe
log.debug("{} handler request.packets.size(): {}", StateFactory.getServerId(), request.packets.size());
// TODO: request.packets 入库,回填, 告警 等操作
Thread.sleep(ThreadLocalRandom .current().nextLong(100, 3000));
} catch (InterruptedException e) {
log.info(e.toString());
} finally { // 确保 更新 最终的任务状态给master.
// 读状态 Closure<State> 里的 getValue<State>为 State的状态

2
src/main/java/com/yuandian/dataflow/statemachine/MasterFactory.java
View File

@ -122,7 +122,7 @@ public class MasterFactory {
});
}
Thread.sleep(5000);
Thread.sleep(2000);
}
} catch (InterruptedException e) {
log.info("{}", e.toString());