[
https://issues.apache.org/jira/browse/STORM-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
AK47Sonic updated STORM-3554:
-----------------------------
Description:
Hi team,
[Storm version: 2.1.0]
According to the doc [https://storm.apache.org/releases/2.1.0/Local-mode.html],
after I shutdown LocalCluster by calling shutdown or close method, JVM still
run and can't exit on IDEA. I think it is a simple demo blow. Is it a bug?
import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.topology.TopologyBuilder;
public class WordCountTopology {
public static void main(String[] args) throws Exception
{
TopologyBuilder builder = new TopologyBuilder();
// builder.setSpout("spout", new RandomSentenceSpout(), 5);
// builder.setBolt("split", new SplitSentenceBolt(),
8).shuffleGrouping("spout");
// builder.setBolt("count", new WordCountBolt(), 2).fieldsGrouping("split", new
Fields("word"));
Config conf = new Config();
conf.setDebug(true);
String topologyName = "word-count";
conf.setNumWorkers(2);
LocalCluster cluster = null;
cluster = new LocalCluster();
cluster.submitTopology(topologyName, conf, builder.createTopology());
Thread.sleep(10000);
// cluster.close();
cluster.shutdown();
}
}
POM.xml:
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<storm.version>2.1.0</storm.version>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-client</artifactId>
<version>${storm.version}</version>
</dependency>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-server</artifactId>
<version>${storm.version}</version>
</dependency>
</dependencies>
was:
Hi team,
[Storm version: 2.1.0]
According to the doc [https://storm.apache.org/releases/2.1.0/Local-mode.html],
after I shutdown LocalCluster by calling shutdown or close method, JVM still
run and can't exit on IDEA. I think it is a simple demo blow. Is it a bug?
import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.topology.TopologyBuilder;
public class WordCountTopology {
public static void main(String[] args) throws Exception
{
TopologyBuilder builder = new TopologyBuilder();
// builder.setSpout("spout", new RandomSentenceSpout(), 5);
// builder.setBolt("split", new SplitSentenceBolt(),
8).shuffleGrouping("spout");
// builder.setBolt("count", new WordCountBolt(), 2).fieldsGrouping("split", new
Fields("word"));
Config conf = new Config();
conf.setDebug(true);
String topologyName = "word-count";
conf.setNumWorkers(2);
LocalCluster cluster = null;
cluster = new LocalCluster();
cluster.submitTopology(topologyName, conf, builder.createTopology());
Thread.sleep(10000);
// cluster.close();
cluster.shutdown();
}
}
> LocalCluster can't be shutdown and JVM still run
> ------------------------------------------------
>
> Key: STORM-3554
> URL: https://issues.apache.org/jira/browse/STORM-3554
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-client, storm-server
> Affects Versions: 2.1.0
> Environment: Storm 2.1.0
> IntelliJ IDEA
> Reporter: AK47Sonic
> Priority: Major
>
> Hi team,
> [Storm version: 2.1.0]
> According to the doc
> [https://storm.apache.org/releases/2.1.0/Local-mode.html], after I shutdown
> LocalCluster by calling shutdown or close method, JVM still run and can't
> exit on IDEA. I think it is a simple demo blow. Is it a bug?
>
> import org.apache.storm.Config;
> import org.apache.storm.LocalCluster;
> import org.apache.storm.topology.TopologyBuilder;
> public class WordCountTopology {
> public static void main(String[] args) throws Exception
> {
> TopologyBuilder builder = new TopologyBuilder();
> // builder.setSpout("spout", new RandomSentenceSpout(), 5);
> // builder.setBolt("split", new SplitSentenceBolt(),
> 8).shuffleGrouping("spout");
> // builder.setBolt("count", new WordCountBolt(), 2).fieldsGrouping("split",
> new Fields("word"));
> Config conf = new Config();
> conf.setDebug(true);
> String topologyName = "word-count";
> conf.setNumWorkers(2);
> LocalCluster cluster = null;
> cluster = new LocalCluster();
> cluster.submitTopology(topologyName, conf, builder.createTopology());
> Thread.sleep(10000);
> // cluster.close();
> cluster.shutdown();
> }
> }
> POM.xml:
> <properties>
> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
> <storm.version>2.1.0</storm.version>
> </properties>
> <dependencies>
> <dependency>
> <groupId>org.apache.storm</groupId>
> <artifactId>storm-client</artifactId>
> <version>${storm.version}</version>
> </dependency>
> <dependency>
> <groupId>org.apache.storm</groupId>
> <artifactId>storm-server</artifactId>
> <version>${storm.version}</version>
> </dependency>
> </dependencies>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
