sumanyu

java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce$class
	at kafka.utils.Pool.<init>(Pool.scala:28)
	at kafka.producer.ProducerStatsRegistry$.<init>(ProducerStats.scala:34)
	at kafka.producer.ProducerStatsRegistry$.<clinit>(ProducerStats.scala)
	at kafka.producer.async.DefaultEventHandler.<init>(DefaultEventHandler.scala:48)
	at kafka.producer.Producer.<init>(Producer.scala:59)
	at com.virtualpowersystems.services.kafka.KafkaPublisher$class.setupKafkaPublisher(KafkaPublisher.scala:40)
	at com.virtualpowersystems.services.kafka.LazyKafkaPublisher$$anon$1.setupKafkaPublisher(KafkaPublisher.scala:68)
	at com.virtualpowersystems.services.kafka.LazyKafkaPublisher.getPubInstance(KafkaPublisher.scala:69)
	at com.virtualpowersystems.services.KafkaSpec.<init>(KafkaSpec.scala:21)

sumanyu

{
  "id": "",
  "host": "",
  "psuBlock": [
    {
      "utilities": [
        {
          "slot": "",
          "status": ""
        }

sumanyu

#!/bin/sh

set -e

export ICE_ROOT_DIR="$HOME/icesky"
export ICE_MAIN_DIR="$ICE_ROOT_DIR/src/main"
export PYTHONPATH=$ICE_ROOT_DIR:$PYTHONPATH

# Install influxDB
wget http://s3.amazonaws.com/influxdb/influxdb_latest_amd64.deb

sumanyu

{
  "id": "zk-pod",
  "kind": "Pod",
  "apiVersion": "v1beta1",
  "desiredState": {
    "manifest": {
      "version": "v1beta1",
      "id": "zk-pod",
      "containers": [
        {

sumanyu

{
  "id": "zk-service",
  "kind": "Service",
  "apiVersion": "v1beta1",
  "port": 2181,
  "containerPort": 2181,
  "selector": {
    "name": "zk-pod"
  }
}

sumanyu

{
  "id": "kafka-pod",
  "kind": "Pod",
  "apiVersion": "v1beta1",
  "desiredState": {
    "manifest": {
      "version": "v1beta1",
      "id": "kafka-pod",
      "containers": [{
          "name": "kafka1",

sumanyu

{
  "id": "kafka-service",
  "kind": "Service",
  "apiVersion": "v1beta1",
  "port": 9092,
  "containerPort": 9092,
  "selector": {
    "name": "kafka-pod"
  }
}

sumanyu

    super.validatePowerSource match {
      case Success(_) => this.successNel
      case f@Failure(_) => f
    }
    
    Attemt
    
  def singleValidation [A] (objectRef: A)(validation: ValidationNel[ValidationFailure, A]) = validation match {
    case Success(_)=> objectRef.successNel
    case f@Failure(_) => f

sumanyu

java.lang.AbstractMethodError
	at org.json4s.DefaultFormats$class.$init$(Formats.scala:324)
	at org.scalatra.swagger.SwaggerSerializers$$anon$10.<init>(SwaggerSerializers.scala:149)
	at org.scalatra.swagger.SwaggerSerializers$.<init>(SwaggerSerializers.scala:149)
	at org.scalatra.swagger.SwaggerSerializers$.<clinit>(SwaggerSerializers.scala)
	at org.scalatra.swagger.SwaggerBase$class.jsonFormats(SwaggerBase.scala:102)
	at com.virtualpowersystems.specs.ResourcesApp.jsonFormats(ResourcesApp.scala:22)
	at org.scalatra.swagger.SwaggerBaseBase$$anonfun$renderIndex$7.apply(SwaggerBase.scala:89)
	at org.scalatra.swagger.SwaggerBaseBase$$anonfun$renderIndex$7.apply(SwaggerBase.scala:89)
	at scala.Option.map(Option.scala:145)

sumanyu

[2015-03-30 20:16:46,375] INFO Will not load MX4J, mx4j-tools.jar is not in the classpath (kafka.utils.Mx4jLoader$)
[2015-03-30 20:16:46,559] INFO conflict in /brokers/ids/0 data: {"jmx_port":-1,"timestamp":"1427746606536","host":"10.6.3.2","version":1,"port":9092} stored data: {"jmx_port":-1,"timestamp":"1427746516895","host":"10.6.3.2","version":1,"port":9092} (kafka.utils.ZkUtils$)
[2015-03-30 20:16:46,590] INFO I wrote this conflicted ephemeral node [{"jmx_port":-1,"timestamp":"1427746606536","host":"10.6.3.2","version":1,"port":9092}] at /brokers/ids/0 a while back in a different session, hence I will backoff for this node to be deleted by Zookeeper and retry (kafka.utils.ZkUtils$)
[2015-03-30 20:16:48,012] ERROR Error handling event ZkEvent[Data of /controller changed sent to kafka.server.ZookeeperLeaderElector$LeaderChangeListener@21bbc3eb] (org.I0Itec.zkclient.ZkEventThread)
java.lang.IllegalStateException: Kafka scheduler has not been started
	at kafka.utils.KafkaScheduler.ensureStarted(KafkaSchedule