[Bugfix]ds db autoinit (#554)

* [bugfix][worker] 安装DS时自动初始化元数据库 fix: context名称错误 * [bugfix][worker] yarn 公平调度器去除默认test队列
datavane · May 14, 2024 · 97444e3 · 97444e3
1 parent 7bc2e48
commit 97444e3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/datasophon-api/src/main/resources/meta/DDP-1.2.2/YARN/etc/hadoop/fair-scheduler.xml b/datasophon-api/src/main/resources/meta/DDP-1.2.2/YARN/etc/hadoop/fair-scheduler.xml
@@ -1,13 +1,14 @@
 <?xml version="1.0"?>
 <allocations>
+	<!--
 	<queue name="test">
 		<minResources>2048mb,2vcores</minResources>
 		<maxResources>4096mb,4vcores</maxResources>
 		<maxRunningApps>4</maxRunningApps>
 		<maxAMShare>0.5</maxAMShare>
 		<weight>1.0</weight>
 		<schedulingPolicy>fair</schedulingPolicy>
-	</queue>
+	</queue> -->
 	<queuePlacementPolicy>
 		<rule name="specified" create="false"/>
 		<rule name="default" />

diff --git a/...ophon-worker/src/main/java/com/datasophon/worker/strategy/ServiceRoleStrategyContext.java b/...ophon-worker/src/main/java/com/datasophon/worker/strategy/ServiceRoleStrategyContext.java
@@ -56,7 +56,7 @@ public class ServiceRoleStrategyContext {
         map.put("FlinkClient", new FlinkHandlerStrategy("FLINK", "FlinkClient"));
 
         //DolphinScheduler
-        map.put("MasterServer", new DSMasterHandlerStrategy("USCHEDULER", "MasterServer2"));
+        map.put("MasterServer", new DSMasterHandlerStrategy("DS", "MasterServer"));
 
     }