Apache Storm-LocalCluster已停止日志记录，但java进程仍在运行

Question

我们将Apache Storm的LocalCluster作为java进程运行，即通过nohup运行。

我们正在运行一个具有以下配置的简单拓扑。

Config config = new Config();
config.setMessageTimeoutSecs(120);
config.setNumWorkers(1);
config.setDebug(false);
config.setMaxSpoutPending(1);

我们正在将拓扑提交给LocalCluster。我们的shutdown钩子是跨源找到的默认钩子。

Runtime.getRuntime().addShutdownHook(new Thread() {
            @Override
            public void run() {
                cluster.killTopology(TOPOLOGY_NAME);
                cluster.shutdown();
            }
        });

主要问题是java进程，即via nohup仍然显示在ps-ef中。会发生什么问题？

Answer 1

您可以尝试使用config.setdebug（true）；启用调试日志记录，这可能让您知道正在发生什么。

另外，下次拓扑挂起时，您应该可以通过使用jstack或向Java进程发送一个SIGQUIT(kill-3)来知道它在做什么。这将导致进程为JVM中的每个线程转储堆栈跟踪，这将让您了解它挂起的原因。

如果您正在进行，请不要在生产中使用LocalCluster。是用来测试的。