Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit359dd0f

Browse files
fix: 使用集群外有agent的机器作为文件分发源，文件源文件仍然需要宿主机agnet#3888
1.移除未使用的fileWorkerHostService类
1 parent51cf960 commit359dd0f

File tree

2 files changed

+1
-7
lines changed

2 files changed

+1
-7
lines changed

‎src/backend/job-execute/service-job-execute/src/main/java/com/tencent/bk/job/execute/engine/prepare/third/ThirdFilePrepareService.java‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,6 @@ public class ThirdFilePrepareService {
7777
privatefinalStepInstanceServicestepInstanceService;
7878
privatefinalFileSourceTaskLogDAOfileSourceTaskLogDAO;
7979
privatefinalAccountServiceaccountService;
80-
privatefinalFileWorkerHostServicefileWorkerHostService;
8180
privatefinalThirdFileDistributeSourceHostProvisionerthirdFileDistributeSourceHostProvisioner;
8281
privatefinalLogServicelogService;
8382
privatefinalTaskExecuteMQEventDispatchertaskExecuteMQEventDispatcher;
@@ -90,7 +89,6 @@ public ThirdFilePrepareService(ResultHandleManager resultHandleManager,
9089
StepInstanceServicestepInstanceService,
9190
FileSourceTaskLogDAOfileSourceTaskLogDAO,
9291
AccountServiceaccountService,
93-
FileWorkerHostServicefileWorkerHostService,
9492
LogServicelogService,
9593
TaskExecuteMQEventDispatchertaskExecuteMQEventDispatcher,
9694
ThirdFileDistributeSourceHostProvisionerthirdFileDistributeSourceHostProvisioner) {
@@ -99,7 +97,6 @@ public ThirdFilePrepareService(ResultHandleManager resultHandleManager,
9997
this.stepInstanceService =stepInstanceService;
10098
this.fileSourceTaskLogDAO =fileSourceTaskLogDAO;
10199
this.accountService =accountService;
102-
this.fileWorkerHostService =fileWorkerHostService;
103100
this.logService =logService;
104101
this.taskExecuteMQEventDispatcher =taskExecuteMQEventDispatcher;
105102
this.thirdFileDistributeSourceHostProvisioner =thirdFileDistributeSourceHostProvisioner;
@@ -398,7 +395,7 @@ private ThirdFilePrepareTask asyncWatchThirdFilePulling(
398395
newRecordableThirdFilePrepareTaskResultHandler(stepInstance,resultHandler));
399396
batchResultHandleTask.initDependentService(
400397
fileSourceTaskResource,stepInstanceService,accountService,
401-
fileWorkerHostService,logService,taskExecuteMQEventDispatcher,
398+
logService,taskExecuteMQEventDispatcher,
402399
fileSourceTaskLogDAO,thirdFileDistributeSourceHostProvisioner
403400
);
404401
resultHandleManager.handleDeliveredTask(batchResultHandleTask);

‎src/backend/job-execute/service-job-execute/src/main/java/com/tencent/bk/job/execute/engine/prepare/third/ThirdFilePrepareTask.java‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,6 @@ public class ThirdFilePrepareTask implements ContinuousScheduledTask, JobTaskCon
9393
volatileAtomicBooleanisDoneWrapper =newAtomicBoolean(false);
9494
privateServiceFileSourceTaskResourcefileSourceTaskResource;
9595
privateAccountServiceaccountService;
96-
privateFileWorkerHostServicefileWorkerHostService;
9796
privateLogServicelogService;
9897
privateTaskExecuteMQEventDispatchertaskExecuteMQEventDispatcher;
9998
privateFileSourceTaskLogDAOfileSourceTaskLogDAO;
@@ -128,15 +127,13 @@ public void initDependentService(
128127
ServiceFileSourceTaskResourcefileSourceTaskResource,
129128
StepInstanceServicestepInstanceService,
130129
AccountServiceaccountService,
131-
FileWorkerHostServicefileWorkerHostService,
132130
LogServicelogService,
133131
TaskExecuteMQEventDispatchertaskExecuteMQEventDispatcher,
134132
FileSourceTaskLogDAOfileSourceTaskLogDAO,
135133
ThirdFileDistributeSourceHostProvisionerthirdFileDistributeSourceHostProvisioner
136134
) {
137135
this.fileSourceTaskResource =fileSourceTaskResource;
138136
this.accountService =accountService;
139-
this.fileWorkerHostService =fileWorkerHostService;
140137
this.logService =logService;
141138
this.taskExecuteMQEventDispatcher =taskExecuteMQEventDispatcher;
142139
this.fileSourceTaskLogDAO =fileSourceTaskLogDAO;

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp