Java ジョブを Linux サーバーにデプロイして、さまざまな API からのデータを消費し、Kinesis に公開しました。私のジョブは、データを公開するために Kinesis ストリームを開くことができず、以下のエラーがスローされます。どんな提案でも大いに役立ちます。
31253 [メイン] エラー 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) で 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)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) at com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) at 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. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) で java.lang.Thread.run(Thread.java:745) で、concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)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) at com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) at 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. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) で java.lang.Thread.run(Thread.java:745) で、concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)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) at com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) at 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) at com.amazonaws.services.kinesis.producer.Daemon.access$000(Daemon.java:61) at 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. java.lang.Thread.run(Thread.java:745) の util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)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. java.lang.Thread.run(Thread.java:745) の util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)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) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang. Thread.run(スレッド.java:745)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) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang. Thread.run(スレッド.java:745)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) 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) で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) 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) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) で java.lang.Thread.run(Thread.java:745) で1142) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) で java.lang.Thread.run(Thread.java:745) で