操作步骤 修改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());
} 执行WordCountTopology.java类的Main方法提交应用程序。
