remove scheduler client

db/wedpr_ddl.sql

@@ -146,7 +146,7 @@ CREATE TABLE if not exists wedpr_job_worker_table (
     job_id VARCHAR(255),
     type VARCHAR(255),
     status VARCHAR(255),
-    args TEXT,
+    args LONGTEXT,
     upstreams TEXT,
     inputs_statement TEXT,
     outputs TEXT,

wedpr-components/scheduler/src/main/java/com/webank/wedpr/components/scheduler/config/SchedulerLoader.java

@@ -132,29 +132,6 @@ protected void registerExecutors(
                         new ExecutiveContextBuilder(projectMapperWrapper),
                         threadPoolService);
         executorManager.registerExecutor(ExecutorType.DAG.getType(), dagSchedulerExecutor);
-        /*
-        boolean enableLocalDagScheduler = true;
-        if (enableLocalDagScheduler) {
-            DagSchedulerExecutor dagSchedulerExecutor =
-                    new DagSchedulerExecutor(
-                            loadBalancer,
-                            jobWorkerMapper,
-                            jobChecker,
-                            storage,
-                            fileMetaBuilder,
-                            executorManager);
-            executorManager.registerExecutor(ExecutorType.REMOTE.getType(), dagSchedulerExecutor);
-        } else {
-            SchedulerClient schedulerClient = new SchedulerClient();
-            RemoteSchedulerExecutor remoteSchedulerExecutor =
-                    new RemoteSchedulerExecutor(
-                            schedulerClient, jobChecker, storage, fileMetaBuilder);
-
-            executorManager.registerExecutor(
-                    ExecutorType.REMOTE.getType(), remoteSchedulerExecutor);
-        }
-        */
-
         /*
         // register the executor
         PSIExecutor psiExecutor = new PSIExecutor(storage, fileMetaBuilder, jobChecker);

wedpr-components/scheduler/src/main/java/com/webank/wedpr/components/scheduler/executor/impl/mpc/MPCJobParam.java

@@ -6,7 +6,6 @@
 import com.webank.wedpr.common.utils.Common;
 import com.webank.wedpr.common.utils.ObjectMapperFactory;
 import com.webank.wedpr.common.utils.WeDPRException;
-import com.webank.wedpr.components.scheduler.client.SchedulerClient;
 import com.webank.wedpr.components.scheduler.executor.impl.model.DatasetInfo;
 import com.webank.wedpr.components.scheduler.executor.impl.model.FileMeta;
 import com.webank.wedpr.components.scheduler.executor.impl.model.FileMetaBuilder;
@@ -33,28 +32,10 @@ public class MPCJobParam {
     // the dataset information
     private List<DatasetInfo> dataSetList;
 
-    @JsonIgnore private transient List<String> datasetIDList;
-
-    public void transferSQL2MPC() throws Exception {
-        if (Common.isEmptyStr(sql)) {
-            return;
-        }
-
-        if (!Common.isEmptyStr(mpcContent)) {
-            return;
-        }
+    @JsonIgnore private DatasetInfo selfDataset;
+    @JsonIgnore private int selfIndex = -1;
 
-        SchedulerClient schedulerClient = new SchedulerClient();
-        String mpcContent = schedulerClient.transferSQL2MPCContent(jobID, sql);
-
-        this.mpcContent = mpcContent;
-
-        logger.info(
-                "transfer sql to mpc code, jobId: {}, sql: {}, mpc code: {}",
-                jobID,
-                sql,
-                mpcContent);
-    }
+    @JsonIgnore private transient List<String> datasetIDList;
 
     public boolean checkNeedRunPSI() {
 
@@ -84,7 +65,6 @@ public void check() throws Exception {
             throw new WeDPRException("Invalid mpc job param, must define the mpc code or sql!");
         }
 
-        this.transferSQL2MPC();
         for (DatasetInfo datasetInfo : dataSetList) {
             datasetInfo.setDatasetIDList(datasetIDList);
             datasetInfo.check();