Skip to content

Commit 9308df7

Browse files
committed
fix compile error
1 parent dc61a7b commit 9308df7

File tree

2 files changed

+14
-1
lines changed

2 files changed

+14
-1
lines changed

fe/fe-core/src/main/java/org/apache/doris/task/AgentTaskCleanupDaemon.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,8 @@ public AgentTaskCleanupDaemon() {
4545
protected void runAfterCatalogReady() {
4646
LOG.info("Begin to clean up inactive agent tasks");
4747
SystemInfoService infoService = Env.getCurrentSystemInfo();
48-
infoService.getAllClusterBackends(false)
48+
infoService.getAllClusterBackendsNoException()
49+
.values()
4950
.forEach(backend -> {
5051
long id = backend.getId();
5152
if (backend.isAlive()) {

fe/fe-core/src/main/java/org/apache/doris/task/PushTask.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -220,6 +220,18 @@ public void countDownLatch(long backendId, long tabletId) {
220220
}
221221
}
222222

223+
public void countDownLatchWithStatus(long backendId, long tabletId, Status st) {
224+
if (this.latch == null) {
225+
return;
226+
}
227+
if (latch.markedCountDownWithStatus(backendId, tabletId, st)) {
228+
if (LOG.isDebugEnabled()) {
229+
LOG.debug("pushTask current latch count with status: {}. backend: {}, tablet:{}, st::{}",
230+
latch.getCount(), backendId, tabletId, st);
231+
}
232+
}
233+
}
234+
223235
// call this always means one of tasks is failed. count down to zero to finish entire task
224236
public void countDownToZero(TStatusCode code, String errMsg) {
225237
if (this.latch != null) {

0 commit comments

Comments
 (0)