0

ローカルの vagrant マシンで druid を実行しようとしています。パペットを使用してアーカイブを取得したり、それらを抽出したりします。ただし、ヒストリカル ノードとオーバーロード ノードを実行しようとすると問題が発生します。

次のコードを使用してサーバーを起動します。

file_line { "configure_historical_server":
  path    => '/usr/share/druid-services-0.6.160/config/historical/runtime.properties',
  line    => 'druid.extensions.coordinates=["io.druid.extensions:druid-s3-  extensions:0.6.147","io.druid.extensions:druid-hdfs-storage:0.6.147"]',
  match   => '^druid.extensions.coordinates*',
  require => [ Exec["run_coordinator"] ],
}

exec { "run_historical":
  cwd     => "/usr/share/druid-services-0.6.160/",
  command => "nohup java -Xmx256m -Duser.timezone=UTC -Dfile.encoding=UTF-8 -classpath lib/*:/usr/lib/hadoop-hdfs/*:/usr/lib/hadoop/*:/usr/lib/hadoop/client/*:config/historical io.druid.cli.Main server historical&",
  path    => ["/bin", "/usr/bin"],
  require => [ File_Line["configure_historical_server"] ],

}

file_line { "configure_overlord_server":
  path    => '/usr/share/druid-services-0.6.160/config/overlord/runtime.properties',
  line    => 'druid.extensions.coordinates=["io.druid.extensions:druid-kafka-seven:0.6.147","io.druid.extensions:druid-hdfs-storage:0.6.147"]',
  match   => '^druid.extensions.coordinates*',
  require => [ Exec["run_historical"] ],
}

exec { "run_overlord":
  cwd     => "/usr/share/druid-services-0.6.160/",
  command => "nohup java -Xmx2g -Duser.timezone=UTC -Dfile.encoding=UTF-8 -classpath lib/*:/usr/lib/hadoop-hdfs/*:/usr/lib/hadoop/*:/usr/lib/hadoop/client/*:config/overlord io.druid.cli.Main server overlord&",
  path    => ["/bin", "/usr/bin"],
  require => [ File_Line["configure_overlord_server"] ],
}

しかし、次のエラーが原因でオーバーロード サーバーとヒストリカル サーバーの両方が失敗します。

Caused by: java.io.FileNotFoundException: /home/vagrant/.m2/repository/org/apache/hadoop/hadoop-hdfs/2.3.0/aether-e687f19b-733b-4348-a06f-e67797a26748-hadoop-hdfs-2.3.0.jar-in-progress (No such file or directory)
at java.io.FileInputStream.open(Native Method)
at java.io.FileInputStream.<init>(FileInputStream.java:138)
at org.eclipse.aether.internal.impl.DefaultFileProcessor.copy(DefaultFileProcessor.java:151)
at org.eclipse.aether.internal.impl.DefaultFileProcessor.copy(DefaultFileProcessor.java:139)
at org.eclipse.aether.internal.impl.DefaultFileProcessor.move(DefaultFileProcessor.java:214)
at io.tesla.aether.connector.AetherRepositoryConnector$GetTask.rename(AetherRepositoryConnector.java:624)
at io.tesla.aether.connector.AetherRepositoryConnector$GetTask.run(AetherRepositoryConnector.java:404)
at io.tesla.aether.connector.AetherRepositoryConnector.get(AetherRepositoryConnector.java:232)
... 8 more

これを修正する方法はありますか?これらのサーバーをコマンドラインから次々と起動すると(ヒストリカルが起動するまで待ってからオーバーロードを起動します)、すべて正常に動作します。

4

0 に答える 0