0

我正在尝试在本地流浪机器上运行德鲁伊。我使用 puppet 来获取档案、提取它们等。但是在尝试运行历史节点和霸主节点时遇到问题。

我使用以下代码启动服务器：

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