我已经在 linux 服务器上部署了我的 java 作业,以使用来自各种 API 的数据并将其发布到 Kinesis。我的工作无法打开 Kinesis 流来发布数据并引发以下错误。任何建议都会有很大帮助。
31253 [main] 错误 com.est.producer.KinesisEstProducer - 写入 kinesis java.util.concurrent.ExecutionException 时出错:com.amazonaws.services.kinesis.producer.IrrecoverableError:在 com.google 调用 mkfifo 后管道未显示.common.util.concurrent.AbstractFuture$Sync.getValue(AbstractFuture.java:299) 在 com.google.common.util.concurrent.AbstractFuture$Sync.get(AbstractFuture.java:286) 在 com.google.common.util .concurrent.AbstractFuture.get(AbstractFuture.java:116) 在 com.est.producer.KinesisEstProducer.send(KinesisEstProducer.java:78) 在 com.est.cable.kafka.agent.Agent.main(Agent.java:102 ) 原因:com.amazonaws.services.kinesis.producer.IrrecoverableError:在 com.amazonaws.services.kinesis.producer.Daemon 调用 mkfifo 后管道未显示。com.amazonaws.services.kinesis.producer.Daemon.fatalError(Daemon.java:480) 上的 fatalError(Daemon.java:502) com.amazonaws.services.kinesis.producer.Daemon.createPipesUnix(Daemon.java:401)在 com.amazonaws.services.kinesis.producer.Daemon.createPipes(Daemon.java:354) 在 com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) 在 com.amazonaws.services。 kinesis.producer.Daemon$1.run(Daemon.java:127) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266 ) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:第745章)第745章)第745章)502) 在 com.amazonaws.services.kinesis.producer.Daemon.fatalError(Daemon.java:480) 在 com.amazonaws.services.kinesis.producer.Daemon.createPipesUnix(Daemon.java:401) 在 com.amazonaws.services .kinesis.producer.Daemon.createPipes(Daemon.java:354) 在 com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) 在 com.amazonaws.services.kinesis.producer.Daemon$1 .run(Daemon.java:127) 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 在 java.util.concurrent.FutureTask.run(FutureTask.java:266) 在 java.util。 concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:745)502) 在 com.amazonaws.services.kinesis.producer.Daemon.fatalError(Daemon.java:480) 在 com.amazonaws.services.kinesis.producer.Daemon.createPipesUnix(Daemon.java:401) 在 com.amazonaws.services .kinesis.producer.Daemon.createPipes(Daemon.java:354) 在 com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) 在 com.amazonaws.services.kinesis.producer.Daemon$1 .run(Daemon.java:127) 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 在 java.util.concurrent.FutureTask.run(FutureTask.java:266) 在 java.util。 concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:745)amazonaws.services.kinesis.producer.Daemon.fatalError(Daemon.java:480) 在 com.amazonaws.services.kinesis.producer.Daemon.createPipesUnix(Daemon.java:401) 在 com.amazonaws.services.kinesis.producer。 Daemon.createPipes(Daemon.java:354) 在 com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) 在 com.amazonaws.services.kinesis.producer.Daemon$1.run(Daemon. java:127) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:745)amazonaws.services.kinesis.producer.Daemon.fatalError(Daemon.java:480) 在 com.amazonaws.services.kinesis.producer.Daemon.createPipesUnix(Daemon.java:401) 在 com.amazonaws.services.kinesis.producer。 Daemon.createPipes(Daemon.java:354) 在 com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) 在 com.amazonaws.services.kinesis.producer.Daemon$1.run(Daemon. java:127) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:745)com.amazonaws.services.kinesis.producer.Daemon.createPipesUnix(Daemon.java:401) 上的 fatalError(Daemon.java:480) com.amazonaws.services.kinesis.producer.Daemon.createPipes(Daemon.java:354)在 com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) 在 com.amazonaws.services.kinesis.producer.Daemon$1.run(Daemon.java:127) 在 java.util.concurrent .Executors$RunnableAdapter.call(Executors.java:511) 在 java.util.concurrent.FutureTask.run(FutureTask.java:266) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java. util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:745)com.amazonaws.services.kinesis.producer.Daemon.createPipesUnix(Daemon.java:401) 上的 fatalError(Daemon.java:480) com.amazonaws.services.kinesis.producer.Daemon.createPipes(Daemon.java:354)在 com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) 在 com.amazonaws.services.kinesis.producer.Daemon$1.run(Daemon.java:127) 在 java.util.concurrent .Executors$RunnableAdapter.call(Executors.java:511) 在 java.util.concurrent.FutureTask.run(FutureTask.java:266) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java. util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java:745)createPipesUnix(Daemon.java:401) at com.amazonaws.services.kinesis.producer.Daemon.createPipes(Daemon.java:354) at com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61 ) at com.amazonaws.services.kinesis.producer.Daemon$1.run(Daemon.java:127) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask .run(FutureTask.java:266) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang。线程运行(线程.java:745)createPipesUnix(Daemon.java:401) at com.amazonaws.services.kinesis.producer.Daemon.createPipes(Daemon.java:354) at com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61 ) at com.amazonaws.services.kinesis.producer.Daemon$1.run(Daemon.java:127) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask .run(FutureTask.java:266) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang。线程运行(线程.java:745)在 com.amazonaws.services.kinesis.producer.Daemon 访问 $000(Daemon.java:61)$1.run(Daemon.java:127) 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)在 java.util.concurrent.FutureTask.run(FutureTask.java:266) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java :617) 在 java.lang.Thread.run(Thread.java:745)在 com.amazonaws.services.kinesis.producer.Daemon 访问 $000(Daemon.java:61)$1.run(Daemon.java:127) 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)在 java.util.concurrent.FutureTask.run(FutureTask.java:266) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java :617) 在 java.lang.Thread.run(Thread.java:745)第1142章第1142章