MAPREDUCE服务 MRS-在IDEA中提交Storm拓扑:操作步骤

时间：2024-06-29 14:10:58

MAPREDUCE服务 MRS 提交Storm拓扑

操作步骤

修改WordCountTopology.java类，使用remoteSubmit方式提交应用程序。并替换Jar文件地址。

使用remoteSubmit方式提交应用程序

public static void main(String[] args) 
         throws Exception 
     { 
         TopologyBuilder builder = buildTopology(); 
          
         /* 
          * 任务的提交认为三种方式 
          * 1、命令行方式提交，这种需要将应用程序jar包复制到客户端机器上执行客户端命令提交 
          * 2、远程方式提交，这种需要将应用程序的jar包打包好之后在IntelliJ IDEA中运行main方法提交 
          * 3、本地提交 ，在本地执行应用程序，一般用来测试 
          * 命令行方式和远程方式安全和普通模式都支持 
          * 本地提交仅支持普通模式 
          *  
          * 用户同时只能选择一种任务提交方式，默认命令行方式提交，如果是其他方式，请删除代码注释即可 
          */ 
          
         submitTopology(builder, SubmitType.REMOTE); 
     }

根据实际情况修改userJarFilePath为实际的拓扑Jar包地址

private static void remoteSubmit(TopologyBuilder builder) 
         throws AlreadyAliveException, InvalidTopologyException, NotALeaderException, AuthorizationException, 
         IOException 
     { 
         Config config = createConf(); 
          
         String userJarFilePath = "D:\\example.jar"; 
         System.setProperty(STORM_SUBMIT_JAR_PROPERTY, userJarFilePath); 
          
         //安全模式下的一些准备工作 
         if (isSecurityModel()) 
         { 
             securityPrepare(config); 
         } 
         config.setNumWorkers(1); 
         StormSubmitter.submitTopologyWithProgressBar(TOPO LOG Y_NAME, config, builder.createTopology()); 
     }