我们在1.0.6中编写了一些storm拓扑，正在测试将它们转换为2.2.0。
在1.0.6中，我们有如下类，可以在ide中运行/调试：

import org.apache.storm.flux.Flux;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

public class StormTopology {

    public static void main(String[] args) throws Exception {

        // Get the original args
        List<String> argList = new ArrayList<String>(Arrays.asList(args));
        String file = StormTopology.class.getClassLoader().getResource("topology.yaml").getFile();
        argList.add("--local");
        argList.add(file);

        file = StormTopology.class.getClassLoader().getResource("dev.properties").getFile();
        argList.add("--filter");
        argList.add(file);
        // Just added a longer value of sleep so that topology does not get killed forcefully while debugging etc.
        argList.add("--sleep");
        argList.add("36000000");

        String[] fluxArgs = argList.toArray(new String[argList.size()]);

        /*
         * Same as calling storm jar StormTopology.jar org.apache.storm.flux.Flux --local topology.yaml --filter dev.properties
         */
        Flux.main(fluxArgs);
    }
}

在2.2.0世界中做同样的事情运气不佳，pom有：

<dependency>
            <groupId>org.apache.storm</groupId>
            <artifactId>storm-client</artifactId>
            <version>2.2.0</version>
            <scope>provided</scope>
        </dependency>

        <dependency>
            <groupId>org.apache.storm</groupId>
            <artifactId>storm-server</artifactId>
            <version>2.2.0</version>
            <scope>test</scope>
        </dependency>

尝试了一些事情（将“-local”更改为“local”，等等），但最新的尝试是得到下面的错误。是否仍然可以使用flux.main（）来复制1.0.6中发生的事情（如果可以的话，希望语法帮助），或者我们需要以编程方式切换到另一种方式？

Exception in thread "main" java.lang.ClassNotFoundException: /C:/ETL/StormTopology/target/classes/topology.yaml
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:264)
    at org.apache.storm.LocalCluster.lambda$main$1(LocalCluster.java:396)
    at org.apache.storm.LocalCluster.withLocalModeOverride(LocalCluster.java:348)
    at org.apache.storm.LocalCluster.main(LocalCluster.java:393)
    at StormTopology.main(StormTopology.java:35)