问题：

Apache Storm运行不正常，无法正常工作。日志生成异常

淳于嘉树

2023-03-14

我使用ApacheStorm与Apache Kafka。使用的喷口是Kafka喷口，但它没有阅读Kafka主题的任何内容。我不知道这是否与我在暴风的工人中面临的问题有关。如果您知道任何相关解决方案，请告知我。

Storm拓扑已成功上载到Storm。我获取了日志，下面是工作人员在其工作人员中编写的内容。日志文件：

java.lang.ExceptionInInitializerError
    at java.nio.file.FileSystems.getDefault(FileSystems.java:176) ~[?:1.8.0_91]
    at java.nio.file.Paths.get(Paths.java:84) ~[?:1.8.0_91]
    at org.apache.storm.util$is_absolute_path_QMARK_.invoke(util.clj:68) ~[storm-core-1.0.1.jar:1.0.1]
    at org.apache.storm.config$absolute_storm_local_dir.invoke(config.clj:94) ~[storm-core-1.0.1.jar:1.0.1]
    at org.apache.storm.config$worker_root.invoke(config.clj:290) ~[storm-core-1.0.1.jar:1.0.1]
    at org.apache.storm.config$worker_root.invoke(config.clj:292) ~[storm-core-1.0.1.jar:1.0.1]
    at org.apache.storm.config$worker_pids_root.invoke(config.clj:296) ~[storm-core-1.0.1.jar:1.0.1]
    at org.apache.storm.config$worker_pid_path.invoke(config.clj:304) ~[storm-core-1.0.1.jar:1.0.1]
    at org.apache.storm.daemon.worker$fn__8450$exec_fn__2461__auto____8451.invoke(worker.clj:592) ~[storm-core-1.0.1.jar:1.0.1]
    at clojure.lang.AFn.applyToHelper(AFn.java:178) ~[clojure-1.7.0.jar:?]
    at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.7.0.jar:?]
    at clojure.core$apply.invoke(core.clj:630) ~[clojure-1.7.0.jar:?]
    at org.apache.storm.daemon.worker$fn__8450$mk_worker__8545.doInvoke(worker.clj:583) [storm-core-1.0.1.jar:1.0.1]
    at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.7.0.jar:?]
    at org.apache.storm.daemon.worker$_main.invoke(worker.clj:771) [storm-core-1.0.1.jar:1.0.1]
    at clojure.lang.AFn.applyToHelper(AFn.java:165) [clojure-1.7.0.jar:?]
    at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.7.0.jar:?]
    at org.apache.storm.daemon.worker.main(Unknown Source) [storm-core-1.0.1.jar:1.0.1]

Caused by: java.security.PrivilegedActionException
    at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_91]
    at java.nio.file.FileSystems$DefaultFileSystemHolder.defaultFileSystem(FileSystems.java:96) ~[?:1.8.0_91]
    at java.nio.file.FileSystems$DefaultFileSystemHolder.<clinit>(FileSystems.java:90) ~[?:1.8.0_91]
    ... 18 more

Caused by: sun.nio.fs.UnixException: No such file or directory
    at sun.nio.fs.UnixNativeDispatcher.getcwd(Native Method) ~[?:1.8.0_91]
    at sun.nio.fs.UnixFileSystem.<init>(UnixFileSystem.java:67) ~[?:1.8.0_91]
    at sun.nio.fs.LinuxFileSystem.<init>(LinuxFileSystem.java:39) ~[?:1.8.0_91]
    at sun.nio.fs.LinuxFileSystemProvider.newFileSystem(LinuxFileSystemProvider.java:46) ~[?:1.8.0_91]
    at sun.nio.fs.LinuxFileSystemProvider.newFileSystem(LinuxFileSystemProvider.java:39) ~[?:1.8.0_91]
    at sun.nio.fs.UnixFileSystemProvider.<init>(UnixFileSystemProvider.java:56) ~[?:1.8.0_91]
    at sun.nio.fs.LinuxFileSystemProvider.<init>(LinuxFileSystemProvider.java:41) ~[?:1.8.0_91]
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_91]
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[?:1.8.0_91]
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_91]
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_91]
    at java.lang.Class.newInstance(Class.java:442) ~[?:1.8.0_91]
    at sun.nio.fs.DefaultFileSystemProvider.createProvider(DefaultFileSystemProvider.java:48) ~[?:1.8.0_91]
    at sun.nio.fs.DefaultFileSystemProvider.create(DefaultFileSystemProvider.java:63) ~[?:1.8.0_91]
    at java.nio.file.FileSystems$DefaultFileSystemHolder.getDefaultProvider(FileSystems.java:108) ~[?:1.8.0_91]
    at java.nio.file.FileSystems$DefaultFileSystemHolder.access$000(FileSystems.java:89) ~[?:1.8.0_91]
    at java.nio.file.FileSystems$DefaultFileSystemHolder$1.run(FileSystems.java:98) ~[?:1.8.0_91]
    at java.nio.file.FileSystems$DefaultFileSystemHolder$1.run(FileSystems.java:96) ~[?:1.8.0_91]
    at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_91]
    at java.nio.file.FileSystems$DefaultFileSystemHolder.defaultFileSystem(FileSystems.java:96) ~[?:1.8.0_91]
    at java.nio.file.FileSystems$DefaultFileSystemHolder.<clinit>(FileSystems.java:90) ~[?:1.8.0_91]
    ... 18 more

2016-07-24 13:14:33.154 o.a.s.util [ERROR] Halting process: ("Error on initialization")
java.lang.RuntimeException: ("Error on initialization")
    at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.0.1.jar:1.0.1]
    at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
    at org.apache.storm.daemon.worker$fn__8450$mk_worker__8545.doInvoke(worker.clj:583) [storm-core-1.0.1.jar:1.0.1]
    at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.7.0.jar:?]
    at org.apache.storm.daemon.worker$_main.invoke(worker.clj:771) [storm-core-1.0.1.jar:1.0.1]
    at clojure.lang.AFn.applyToHelper(AFn.java:165) [clojure-1.7.0.jar:?]
    at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.7.0.jar:?]
    at org.apache.storm.daemon.worker.main(Unknown Source) [storm-core-1.0.1.jar:1.0.1]

共有1个答案

易招

2023-03-14

解决方案是检查Storm本地集群中的任务并行数。在最新版本中，他们为此任务并行性属性添加了一个最大值。这是自动删除额外工作人员的文件夹。它只是将工人人数从3人改为2人或更少，以便正常执行。

国际工人=2；

conf.setMaxTaskParallelism（工人）；

谢谢大家的评论。

类似资料：

JProgressBar无法正常工作

问题内容：因此，我的设置无法按我想要的方式工作。因此，每当我运行该程序时，它就会立即从0变为100。我尝试使用，任务，并尝试了，但没有任何尝试。这是我的程序： @MadProgrammer这是我尝试做一名摆动工作人员并将每个名称写入文档并更新进度栏的尝试。该程序将达到86％左右并停止运行，永远不会创建完成的文档。该程序将创建一个空白文档。这是我首先创建的SwingWorker对象，这是两种方法
AlphaComposite.CLEAR无法正常工作

问题内容：我在JLayeredpane上有两个JPanels。其中一个显示pdf，重叠的一个具有透明背景（我使用过setOpaque（false））。现在，我可以将图形添加到透明面板中，这样看来我实际上是在注释pdf。我想要一个橡皮擦工具来删除这些注释。我尝试使用以下代码其中path是由多条线构成的形状。现在，不是在先前的图形上绘制透明线，而是绘制黑线。我要去哪里错了？问题答案：请
jQuery.addClass无法正常工作

问题内容：这看起来有效，但无法正常工作。我希望菜单悬停时’huh’div不透明。我尝试了淡入/淡出效果，但效果很好，但只有一次很奇怪。问题答案：不带点使用：
String.replaceAll（）无法正常工作

问题内容：我正在编辑从tesseract ocr获得的一些电子邮件。这是我的代码：但是输出不正确。输入：输出：但是，当我在每次替换后将结果分配给新的String时，它都能正常工作。为什么在同一字符串中连续分配不起作用？问题答案：您将在Javadoc中的String.replaceAll（）中注意到，第一个参数是正则表达式。句点（）和管道（）以及花括号（）都有特殊的含义。您需要对它
ImageIO.write无法正常工作？

问题内容：我正在编写3D绘画，但在Java中发现了问题。在代码的一部分中，它起作用了：在另一种情况下，它不起作用：你能告诉我如何使它工作吗？谢谢在我问之前，是的，它确实执行了那部分代码。编辑：哦，现在工作正常，谢谢问题答案：代替：
array_key_exists无法正常工作

问题内容： array_key_exists不适用于大型多维数组。对于前 array_key_exists（’test’，$ arr）返回’false’，但它可以与一些简单的数组一起使用。问题答案： array_key_exists不能递归工作（正如MattiVirkkunen指出的那样）。看一下PHP手册，可以使用以下代码来执行递归搜索：

Apache Storm运行不正常，无法正常工作。日志生成异常

共有1个答案

相关问答

相关文章

相关阅读

相关工具

相关文档