Home Forums Kamanja Forums Problems & Solutions Failed to add container/message

Tagged: 

This topic contains 11 replies, has 4 voices, and was last updated by  William 1 year, 3 months ago.

  • Author
    Posts
  • #19564 Reply

    Jordan Woods
    Participant

    I have installed Kamanja and am working through the examples. On both the “Hello World” and “Medicine” examples, I got to step 4, where the user adds a container. Running this command prompts the following:

     

    admin@mkscoringengine:~/kamanja-1.5.0_2.11/bin$ clear

    admin@mkscoringengine:~/kamanja-1.5.0_2.11/bin$ bash $KAMANJA_HOME/bin/kamanja $KAMANJA_HOME/config/MetadataAPIConfig.properties add container $KAMANJA_HOME/input/SampleApplications/metadata/container/CoughCodes_Medical.json TENANTID tenant1

    WARN [main] – DATABASE_SCHEMA remains unset

    WARN [main] – DATABASE_LOCATION remains unset

    WARN [main] – DATABASE_HOST remains unset

    WARN [main] – ADAPTER_SPECIFIC_CONFIG remains unset

    WARN [main] – SSL_PASSWD remains unset

    WARN [main] – AUDIT_PARMS remains unset

    WARN [main] – DATABASE remains unset

    SLF4J: Class path contains multiple SLF4J bindings.

    SLF4J: Found binding in [jar:file:/home/admin/kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs2_2.11-1.5.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]

    SLF4J: Found binding in [jar:file:/home/admin/kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs_2.11-1.5.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]

    SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

    SLF4J: Actual binding is of type [org.slf4j.helpers.NOPLoggerFactory]

    ERROR [main] – Node Undefined not found in metadata

    ERROR [main] – Failed to compile the message definition

    java.io.FileNotFoundException: /home/admin/Kamanja-1.5.0_2.11/workingdir/CoughCodes.scala (No such file or directory)

    at java.io.FileOutputStream.open0(Native Method) ~[?:1.8.0_101]

    at java.io.FileOutputStream.open(FileOutputStream.java:270) ~[?:1.8.0_101]

    at java.io.FileOutputStream.<init>(FileOutputStream.java:213) ~[?:1.8.0_101]

    at java.io.FileOutputStream.<init>(FileOutputStream.java:162) ~[?:1.8.0_101]

    at java.io.FileWriter.<init>(FileWriter.java:90) ~[?:1.8.0_101]

    at com.ligadata.MetadataAPI.CompilerProxy.dumpStrTextToFile(CompilerProxy.scala:1658) ~[KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.CompilerProxy.compileMessageDef(CompilerProxy.scala:409) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MessageAndContainerUtils$.AddContainerOrMessage(MessageAndContainerUtils.scala:263) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MetadataAPIImpl$.AddContainerOrMessage(MetadataAPIImpl.scala:1972) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MetadataAPIImpl$.AddContainer(MetadataAPIImpl.scala:2019) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.Utility.ContainerService$.addContainer(ContainerService.scala:90) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI$.route(StartMetadataAPI.scala:595) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI$.main(StartMetadataAPI.scala:354) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI.main(StartMetadataAPI.scala) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    Result: {

    “APIResults” : {

    “Status Code” : -1,

    “Function Name” : “AddContainerOrMessage”,

    “Result Data” : “{\n  \”Container\”: {\n    \”NameSpace\”: \”com.ligadata.kamanja.samples.containers\”,\n    \”Name\”: \”CoughCodes\”,\n    \”Version\”: \”00.01.00\”,\n    \”Description\”: \”Container for Cough Codes\”,\n    \”Fixed\”: \”true\”,\n    \”Persist\”: \”true\”,\n    \”Fields\”: [\n      {\n        \”Name\”: \”icd9Code\”,\n        \”Type\”: \”System.String\”\n      },\n      {\n        \”Name\”: \”icd9Description\”,\n        \”Type\”: \”System.String\”\n      }\n    ],\n    \”PartitionKey\”: [\n      \”icd9Code\”\n    ]\n  }\n}\n”,

    “Result Description” : “Error: com.ligadata.Exceptions.MsgCompilationFailedException: /home/admin/Kamanja-1.5.0_2.11/workingdir/CoughCodes.scala (No such file or directory)Failed to add container/message”

    }

    }

    admin@mkscoringengine:~/kamanja-1.5.0_2.11/bin$

     

  • #19567 Reply

    Dhaval Kolapkar

    Hi,

    Could you check if you have the directory /home/admin/Kamanja-1.5.0_2.11/workingdir/

    Also are you following the steps in the quick start and the add message,cluster config, comiple config worked properly?

  • #19568 Reply

    William
    Keymaster

    Please open the file $KAMANJA_HOME/config/log4j2.xml and replace the line

    <Root level=”WARN”>

    with

    <Root level=”DEBUG”>

    Then rerun the command. This ought to reveal a bit more information on what is going on.

  • #19570 Reply

    Jordan Woods
    Participant

    Hi Dhaval & William,

    Dhaval: I was following the quick start guide, and everything installed/worked without a problem up until this point. In the “$KAMANJA_HOME/workingdir” directory, I have the following: a msg1 directory, msg1Factory.java, msg1_local.scala, msg1.scala.

    William: I modified the level to DEBUG and reran it. Results follow:

     

    admin@mkscoringengine:~/kamanja-1.5.0_2.11$ cd workingdir/

    admin@mkscoringengine:~/kamanja-1.5.0_2.11/workingdir$ ls

    msg1  msg1Factory.java  msg1_local.scala  msg1.scala

    admin@mkscoringengine:~/kamanja-1.5.0_2.11/workingdir$ bash $KAMANJA_HOME/bin/kamanja $KAMANJA_HOME/config/MetadataAPIConfig.properties add container $KAMANJA_HOME/input/SampleApplications/metadata/container/CoughCodes_Medical.json TENANTID tenant1

    DEBUG [main] – MetadataLoad…loading typedefs

    DEBUG [main] – MetadataLoad…loading typedefs

    DEBUG [main] – MetadataLoad…loading ContainerInterfaces definitions

    DEBUG [main] – MetadataLoad…loading EnvContext

    DEBUG [main] – MetadataLoad…loading MessageInterface

    DEBUG [main] – MetadataLoad…loading ContainerInterface

    DEBUG [main] – MetadataLoad…loading Context

    DEBUG [main] – MetadataLoad…loading KamanjaModelEvent

    DEBUG [main] – MetadataLoad…loading Metric Message definitions

    DEBUG [main] – MetadataLoad… adding array of EnvContext

    DEBUG [main] – MetadataLoad… adding array of MessageInterface

    DEBUG [main] – MetadataLoad… adding array of ContainerInterface

    DEBUG [main] – MetadataLoad… adding array of Context

    DEBUG [main] – MetadataLoad… adding array of KamanjaModelEvent

    DEBUG [main] – MetadataLoad…loading KamanjaStatusEvent

    DEBUG [main] – MetadataLoad…loading KamanjaStatisticsEvent

    DEBUG [main] – MetadataLoad…loading KamanjaExceptionEvent

    DEBUG [main] – MetadataLoad…loading KamanjaExecutionFailureEvent

    DEBUG [main] – MetadataLoad… adding array of KamanjaStatusEvent

    DEBUG [main] – MetadataLoad… adding array of KamanjaStatisticsEvent

    DEBUG [main] – MetadataLoad… adding array of KamanjaExceptionEvent

    DEBUG [main] – MetadataLoad… adding array of KamanjaExecutionFailureEvent

    DEBUG [main] – MetadataLoad…loading KamanjaMessageEvent

    DEBUG [main] – MetadataLoad… adding array of KamanjaMessageEvent

    DEBUG [main] – MetadataLoad…loading Pmml udfs

    DEBUG [main] – MetadataLoad…loading Iterable functions

    DEBUG [main] – MetadataLoad…loading container filter functions

    DEBUG [main] – MetadataLoad…loading container map functions

    DEBUG [main] – MetadataLoad…loading container groupBy functions

    DEBUG [main] – MetadataLoad…loading function macro definitions

    DEBUG [main] – MetadataLoad…loading Macro functions

    DEBUG [main] – MetadataLoad…loading FactoryOfModelInstanceFactories definitions

    DEBUG [main] – MetadataLoad…loading SerializeDeserializeConfig instances for kbinary, csv, and json

    DEBUG [main] – NODE_ID = Undefined

    DEBUG [main] – API_LEADER_SELECTION_ZK_NODE = /ligadata

    DEBUG [main] – ZK_SESSION_TIMEOUT_MS = 3000

    DEBUG [main] – ZK_CONNECTION_TIMEOUT_MS = 3000

    DEBUG [main] – NOTIFY_ENGINE = YES

    DEBUG [main] – SERVICE_HOST = localhost

    DEBUG [main] – MANIFEST_PATH = /home/admin/Kamanja-1.5.0_2.11/config/manifest.mf

    DEBUG [main] – SECURITY_IMPL_JAR = /home/admin/Kamanja-1.5.0_2.11/lib/system/simpleapacheshiroadapter_2.11-1.0.jar

    DEBUG [main] – GIT_ROOT = /home/admin/Kamanja-1.5.0_2.11

    DEBUG [main] – TYPE_FILES_DIR = /home/admin/Kamanja-1.5.0_2.11/input/SampleApplications/metadata/type/

    DEBUG [main] – CONTAINER_FILES_DIR = /home/admin/Kamanja-1.5.0_2.11/input/SampleApplications/metadata/container/

    DEBUG [main] – JAR_PATHS = /home/admin/Kamanja-1.5.0_2.11/lib/system,/home/admin/Kamanja-1.5.0_2.11/lib/application

    DEBUG [main] – CLASSPATH = /home/admin/Kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs_2.11-1.5.0.jar:/home/admin/Kamanja-1.5.0_2.11/lib/system/KamanjaInternalDeps_2.11-1.5.0.jar:/home/admin/Kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs2_2.11-1.5.0.jar

    DEBUG [main] – COMPILER_WORK_DIR = /home/admin/Kamanja-1.5.0_2.11/workingdir

    DEBUG [main] – METADATA_DATASTORE = {“StoreType”: “h2db”,”connectionMode”: “embedded”,”SchemaName”: “kamanja”,”Location”: “/home/admin/Kamanja-1.5.0_2.11/storage”,”portnumber”: “9100”,”user”: “test”,”password”: “test”}

    DEBUG [main] – MODEL_EXEC_LOG = false

    DEBUG [main] – JAVA_HOME = /usr

    DEBUG [main] – AUDIT_IMPL_JAR = /home/admin/Kamanja-1.5.0_2.11/lib/system/auditadapters_2.11-1.0.jar

    DEBUG [main] – API_LEADER_SELECTION_ZK_NODE = /kamanja

    DEBUG [main] – DO_AUDIT = NO

    DEBUG [main] – DO_AUTH = NO

    DEBUG [main] – FUNCTION_FILES_DIR = /home/admin/Kamanja-1.5.0_2.11/input/SampleApplications/metadata/function/

    DEBUG [main] – ROOT_DIR = /home/admin/Kamanja-1.5.0_2.11

    DEBUG [main] – SECURITY_IMPL_CLASS = com.ligadata.Security.SimpleApacheShiroAdapter

    DEBUG [main] – ZNODE_PATH = /kamanja

    DEBUG [main] – CONCEPT_FILES_DIR = /home/admin/Kamanja-1.5.0_2.11/input/SampleApplications/metadata/concept/

    DEBUG [main] – SSL_CERTIFICATE = /home/admin/Kamanja-1.5.0_2.11/config/keystore.jks

    DEBUG [main] – CONFIG_FILES_DIR = /home/admin/Kamanja-1.5.0_2.11/config/

    DEBUG [main] – MESSAGE_FILES_DIR = /home/admin/Kamanja-1.5.0_2.11/input/SampleApplications/metadata/message/

    DEBUG [main] – MODEL_FILES_DIR = /home/admin/Kamanja-1.5.0_2.11/input/SampleApplications/metadata/model/

    DEBUG [main] – ZOOKEEPER_CONNECT_STRING = localhost:2181

    DEBUG [main] – JAR_TARGET_DIR = /home/admin/Kamanja-1.5.0_2.11/lib/application

    DEBUG [main] – SCALA_HOME = /usr

    DEBUG [main] – AUDIT_IMPL_CLASS = com.ligadata.audit.adapters.AuditCassandraAdapter

    DEBUG [main] – SERVICE_PORT = 8081

    WARN [main] – DATABASE_SCHEMA remains unset

    WARN [main] – DATABASE_LOCATION remains unset

    WARN [main] – DATABASE_HOST remains unset

    WARN [main] – ADAPTER_SPECIFIC_CONFIG remains unset

    WARN [main] – SSL_PASSWD remains unset

    WARN [main] – AUDIT_PARMS remains unset

    WARN [main] – DATABASE remains unset

    SLF4J: Class path contains multiple SLF4J bindings.

    SLF4J: Found binding in [jar:file:/home/admin/kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs2_2.11-1.5.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]

    SLF4J: Found binding in [jar:file:/home/admin/kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs_2.11-1.5.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]

    SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

    SLF4J: Actual binding is of type [org.slf4j.helpers.NOPLoggerFactory]

    DEBUG [main] – Opening datastore

    DEBUG [main] – Getting DB Connection for dataStoreInfo:{“StoreType”: “h2db”,”connectionMode”: “embedded”,”SchemaName”: “kamanja”,”Location”: “/home/admin/Kamanja-1.5.0_2.11/storage”,”portnumber”: “9100”,”user”: “test”,”password”: “test”}

    DEBUG [main] – Trying to load class:<root>.package, resolve:false

    DEBUG [main] – Trying to load class:<root>.scala, resolve:false

    DEBUG [main] – Trying to load class:scala, resolve:false

    DEBUG [main] – Trying to load class:scala.package, resolve:false

    DEBUG [main] – Trying to load class:scala.Throwable, resolve:false

    DEBUG [main] – Trying to load class:scala.Exception, resolve:false

    DEBUG [main] – Trying to load class:scala.Error, resolve:false

    DEBUG [main] – Trying to load class:scala.RuntimeException, resolve:false

    DEBUG [main] – Trying to load class:scala.NullPointerException, resolve:false

    DEBUG [main] – Trying to load class:scala.ClassCastException, resolve:false

    DEBUG [main] – Trying to load class:scala.IndexOutOfBoundsException, resolve:false

    DEBUG [main] – Trying to load class:scala.ArrayIndexOutOfBoundsException, resolve:false

    DEBUG [main] – Trying to load class:scala.StringIndexOutOfBoundsException, resolve:false

    DEBUG [main] – Trying to load class:scala.UnsupportedOperationException, resolve:false

    DEBUG [main] – Trying to load class:scala.IllegalArgumentException, resolve:false

    DEBUG [main] – Trying to load class:scala.NoSuchElementException, resolve:false

    DEBUG [main] – Trying to load class:scala.NumberFormatException, resolve:false

    DEBUG [main] – Trying to load class:scala.AbstractMethodError, resolve:false

    DEBUG [main] – Trying to load class:scala.InterruptedException, resolve:false

    DEBUG [main] – Trying to load class:scala.AnyRef, resolve:false

    DEBUG [main] – Trying to load class:scala.TraversableOnce, resolve:false

    DEBUG [main] – Trying to load class:scala.Traversable, resolve:false

    DEBUG [main] – Trying to load class:scala.Traversable, resolve:false

    DEBUG [main] – Trying to load class:scala.Iterable, resolve:false

    DEBUG [main] – Trying to load class:scala.Iterable, resolve:false

    DEBUG [main] – Trying to load class:scala.Seq, resolve:false

    DEBUG [main] – Trying to load class:scala.Seq, resolve:false

    DEBUG [main] – Trying to load class:scala.IndexedSeq, resolve:false

    DEBUG [main] – Trying to load class:scala.IndexedSeq, resolve:false

    DEBUG [main] – Trying to load class:scala.Iterator, resolve:false

    DEBUG [main] – Trying to load class:scala.Iterator, resolve:false

    DEBUG [main] – Trying to load class:scala.BufferedIterator, resolve:false

    DEBUG [main] – Trying to load class:scala.List, resolve:false

    DEBUG [main] – Trying to load class:scala.List, resolve:false

    DEBUG [main] – Trying to load class:scala.Nil, resolve:false

    DEBUG [main] – Trying to load class:scala.$colon$colon, resolve:false

    DEBUG [main] – Trying to load class:scala.$colon$colon, resolve:false

    DEBUG [main] – Trying to load class:scala.$plus$colon, resolve:false

    DEBUG [main] – Trying to load class:scala.$colon$plus, resolve:false

    DEBUG [main] – Trying to load class:scala.Stream, resolve:false

    DEBUG [main] – Trying to load class:scala.Stream, resolve:false

    DEBUG [main] – Trying to load class:scala.$hash$colon$colon, resolve:false

    DEBUG [main] – Trying to load class:scala.Vector, resolve:false

    DEBUG [main] – Trying to load class:scala.Vector, resolve:false

    DEBUG [main] – Trying to load class:scala.StringBuilder, resolve:false

    DEBUG [main] – Trying to load class:scala.StringBuilder, resolve:false

    DEBUG [main] – Trying to load class:scala.Range, resolve:false

    DEBUG [main] – Trying to load class:scala.Range, resolve:false

    DEBUG [main] – Trying to load class:scala.BigDecimal, resolve:false

    DEBUG [main] – Trying to load class:scala.BigDecimal, resolve:false

    DEBUG [main] – Trying to load class:scala.BigInt, resolve:false

    DEBUG [main] – Trying to load class:scala.BigInt, resolve:false

    DEBUG [main] – Trying to load class:scala.Equiv, resolve:false

    DEBUG [main] – Trying to load class:scala.Equiv, resolve:false

    DEBUG [main] – Trying to load class:scala.Fractional, resolve:false

    DEBUG [main] – Trying to load class:scala.Fractional, resolve:false

    DEBUG [main] – Trying to load class:scala.Integral, resolve:false

    DEBUG [main] – Trying to load class:scala.Integral, resolve:false

    DEBUG [main] – Trying to load class:scala.Numeric, resolve:false

    DEBUG [main] – Trying to load class:scala.Numeric, resolve:false

    DEBUG [main] – Trying to load class:scala.Ordered, resolve:false

    DEBUG [main] – Trying to load class:scala.Ordered, resolve:false

    DEBUG [main] – Trying to load class:scala.Ordering, resolve:false

    DEBUG [main] – Trying to load class:scala.Ordering, resolve:false

    DEBUG [main] – Trying to load class:scala.PartialOrdering, resolve:false

    DEBUG [main] – Trying to load class:scala.PartiallyOrdered, resolve:false

    DEBUG [main] – Trying to load class:scala.Either, resolve:false

    DEBUG [main] – Trying to load class:scala.Either, resolve:false

    DEBUG [main] – Trying to load class:scala.Left, resolve:false

    DEBUG [main] – Trying to load class:scala.Left, resolve:false

    DEBUG [main] – Trying to load class:scala.Right, resolve:false

    DEBUG [main] – Trying to load class:scala.Right, resolve:false

    DEBUG [main] – Trying to load class:scala.runtime, resolve:false

    DEBUG [main] – Trying to load class:scala.runtime.package, resolve:false

    DEBUG [main] – Storage configuration:{“StoreType”: “h2db”,”connectionMode”: “embedded”,”SchemaName”: “kamanja”,”Location”: “/home/admin/Kamanja-1.5.0_2.11/storage”,”portnumber”: “9100”,”user”: “test”,”password”: “test”}

    DEBUG [main] – H2db configuration:{“StoreType”: “h2db”,”connectionMode”: “embedded”,”SchemaName”: “kamanja”,”Location”: “/home/admin/Kamanja-1.5.0_2.11/storage”,”portnumber”: “9100”,”user”: “test”,”password”: “test”}

    INFO [main] – hostname => /home/admin/Kamanja-1.5.0_2.11/storage

    INFO [main] – username => test

    INFO [main] – SchemaName => kamanja

    INFO [main] – clusterdIndex  => NO

    INFO [main] – autoCreateTables  => YES

    INFO [main] – Loading the Driver..

    INFO [main] – Registering Driver..

    INFO [main] – Setting up jdbc connection pool ..

    INFO [main] – Done Setting up jdbc connection pool ..

    INFO [main] – Check whether schema exists ..

    INFO [main] – Done with schema checking ..

    DEBUG [main] – Creating MetadataTables

    INFO [main] – create the container tables

    INFO [main] – create the container metadata_objects

    DEBUG [main] – The table metadata_objects already exists

    INFO [main] – create the container jar_store

    DEBUG [main] – The table jar_store already exists

    INFO [main] – create the container config_objects

    DEBUG [main] – The table config_objects already exists

    INFO [main] – create the container model_config_objects

    DEBUG [main] – The table model_config_objects already exists

    INFO [main] – create the container transaction_id

    DEBUG [main] – The table transaction_id already exists

    INFO [main] – create the container metadatacounters

    DEBUG [main] – The table metadatacounters already exists

    INFO [main] – create the container avroschemainfo

    DEBUG [main] – The table avroschemainfo already exists

    INFO [main] – create the container elementinfo

    DEBUG [main] – The table elementinfo already exists

    DEBUG [main] – Created Metadata Tables

    DEBUG [main] – The table config_objects already exists

    INFO [main] – Fetch the results of select timePartition,bucketKey,transactionId,rowId,schemaId,serializerType,serializedInfo from kamanja.config_objects

    DEBUG [main] – Parsing json : {“Cluster”:{“ClusterId”:”ligadata1″,”Description”:””,”Privileges”:””}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Cluster,JObject(List((ClusterId,JString(ligadata1)), (Description,JString()), (Privileges,JString()))))))

    DEBUG [main] – Parsed the json : JObject(List((Cluster,JObject(List((ClusterId,JString(ligadata1)), (Description,JString()), (Privileges,JString()))))))

    DEBUG [main] – Parsing json : {“ClusterCfg”:{“ClusterId”:”ligadata1″,”CfgMap”:[{“Key”:”Cache”,”Value”:”{\”TimeToIdleSeconds\”:31622400,\”CacheSizePerNodeInMB\”:256,\”EvictionPolicy\”:\”LFU\”,\”ReplicateFactor\”:1,\”CacheStartPort\”:7800}”},{“Key”:”SystemCatalog”,”Value”:”{\”Location\”:\”/home/admin/Kamanja-1.5.0_2.11/storage/syscatalog\”,\”portnumber\”:\”9100\”,\”StoreType\”:\”h2db\”,\”connectionMode\”:\”embedded\”,\”SchemaName\”:\”kamanja\”,\”user\”:\”test\”,\”password\”:\”test\”}”},{“Key”:”EnvironmentContext”,”Value”:”{\”classname\”:\”com.ligadata.SimpleEnvContextImpl.SimpleEnvContextImpl$\”,\”jarname\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”,\”dependencyjars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”]}”},{“Key”:”ZooKeeperInfo”,”Value”:”{\”ZooKeeperNodeBasePath\”:\”/kamanja\”,\”ZooKeeperConnectString\”:\”localhost:2181\”,\”ZooKeeperSessionTimeoutMs\”:\”30000\”,\”ZooKeeperConnectionTimeoutMs\”:\”30000\”}”}],”ModifiedTime”:0,”CreatedTime”:0,”UsrConfigs”:[]}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((ClusterCfg,JObject(List((ClusterId,JString(ligadata1)), (CfgMap,JArray(List(JObject(List((Key,JString(Cache)), (Value,JString({“TimeToIdleSeconds”:31622400,”CacheSizePerNodeInMB”:256,”EvictionPolicy”:”LFU”,”ReplicateFactor”:1,”CacheStartPort”:7800})))), JObject(List((Key,JString(SystemCatalog)), (Value,JString({“Location”:”/home/admin/Kamanja-1.5.0_2.11/storage/syscatalog”,”portnumber”:”9100″,”StoreType”:”h2db”,”connectionMode”:”embedded”,”SchemaName”:”kamanja”,”user”:”test”,”password”:”test”})))), JObject(List((Key,JString(EnvironmentContext)), (Value,JString({“classname”:”com.ligadata.SimpleEnvContextImpl.SimpleEnvContextImpl$”,”jarname”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”dependencyjars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”]})))), JObject(List((Key,JString(ZooKeeperInfo)), (Value,JString({“ZooKeeperNodeBasePath”:”/kamanja”,”ZooKeeperConnectString”:”localhost:2181″,”ZooKeeperSessionTimeoutMs”:”30000″,”ZooKeeperConnectionTimeoutMs”:”30000″}))))))), (ModifiedTime,JInt(0)), (CreatedTime,JInt(0)), (UsrConfigs,JArray(List())))))))

    DEBUG [main] – Parsed the json : JObject(List((ClusterCfg,JObject(List((ClusterId,JString(ligadata1)), (CfgMap,JArray(List(JObject(List((Key,JString(Cache)), (Value,JString({“TimeToIdleSeconds”:31622400,”CacheSizePerNodeInMB”:256,”EvictionPolicy”:”LFU”,”ReplicateFactor”:1,”CacheStartPort”:7800})))), JObject(List((Key,JString(SystemCatalog)), (Value,JString({“Location”:”/home/admin/Kamanja-1.5.0_2.11/storage/syscatalog”,”portnumber”:”9100″,”StoreType”:”h2db”,”connectionMode”:”embedded”,”SchemaName”:”kamanja”,”user”:”test”,”password”:”test”})))), JObject(List((Key,JString(EnvironmentContext)), (Value,JString({“classname”:”com.ligadata.SimpleEnvContextImpl.SimpleEnvContextImpl$”,”jarname”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”dependencyjars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”]})))), JObject(List((Key,JString(ZooKeeperInfo)), (Value,JString({“ZooKeeperNodeBasePath”:”/kamanja”,”ZooKeeperConnectString”:”localhost:2181″,”ZooKeeperSessionTimeoutMs”:”30000″,”ZooKeeperConnectionTimeoutMs”:”30000″}))))))), (ModifiedTime,JInt(0)), (CreatedTime,JInt(0)), (UsrConfigs,JArray(List())))))))

    DEBUG [main] – Parsing json : {“Node”:{“NodeId”:”1″,”NodePort”:6541,”NodeIpAddr”:”localhost”,”JarPaths”:[“/home/admin/Kamanja-1.5.0_2.11/lib/system”,”/home/admin/Kamanja-1.5.0_2.11/lib/application”],”Scala_home”:”/usr”,”Java_home”:”/usr”,”Classpath”:”.:/home/admin/Kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs_2.11-1.5.0.jar:/home/admin/Kamanja-1.5.0_2.11/lib/system/KamanjaInternalDeps_2.11-1.5.0.jar:/home/admin/Kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs2_2.11-1.5.0.jar”,”ClusterId”:”ligadata1″,”Power”:0,”Roles”:[“RestAPI”,”ProcessingEngine”],”Description”:””}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Node,JObject(List((NodeId,JString(1)), (NodePort,JInt(6541)), (NodeIpAddr,JString(localhost)), (JarPaths,JArray(List(JString(/home/admin/Kamanja-1.5.0_2.11/lib/system), JString(/home/admin/Kamanja-1.5.0_2.11/lib/application)))), (Scala_home,JString(/usr)), (Java_home,JString(/usr)), (Classpath,JString(.:/home/admin/Kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs_2.11-1.5.0.jar:/home/admin/Kamanja-1.5.0_2.11/lib/system/KamanjaInternalDeps_2.11-1.5.0.jar:/home/admin/Kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs2_2.11-1.5.0.jar)), (ClusterId,JString(ligadata1)), (Power,JInt(0)), (Roles,JArray(List(JString(RestAPI), JString(ProcessingEngine)))), (Description,JString()))))))

    DEBUG [main] – Parsed the json : JObject(List((Node,JObject(List((NodeId,JString(1)), (NodePort,JInt(6541)), (NodeIpAddr,JString(localhost)), (JarPaths,JArray(List(JString(/home/admin/Kamanja-1.5.0_2.11/lib/system), JString(/home/admin/Kamanja-1.5.0_2.11/lib/application)))), (Scala_home,JString(/usr)), (Java_home,JString(/usr)), (Classpath,JString(.:/home/admin/Kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs_2.11-1.5.0.jar:/home/admin/Kamanja-1.5.0_2.11/lib/system/KamanjaInternalDeps_2.11-1.5.0.jar:/home/admin/Kamanja-1.5.0_2.11/lib/system/ExtDependencyLibs2_2.11-1.5.0.jar)), (ClusterId,JString(ligadata1)), (Power,JInt(0)), (Roles,JArray(List(JString(RestAPI), JString(ProcessingEngine)))), (Description,JString()))))))

    DEBUG [main] – Parsing json : {“Tenant”:{“TenantId”:”tenant1″,”Description”:”tenant1″,”PrimaryDataStore”:”{\”Location\”:\”/home/admin/Kamanja-1.5.0_2.11/storage/tenant1_default\”,\”portnumber\”:\”9100\”,\”StoreType\”:\”h2db\”,\”connectionMode\”:\”embedded\”,\”SchemaName\”:\”testdata\”,\”user\”:\”test\”,\”password\”:\”test\”}”,”CacheConfig”:”{\”MaxSizeInMB\”:256}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Tenant,JObject(List((TenantId,JString(tenant1)), (Description,JString(tenant1)), (PrimaryDataStore,JString({“Location”:”/home/admin/Kamanja-1.5.0_2.11/storage/tenant1_default”,”portnumber”:”9100″,”StoreType”:”h2db”,”connectionMode”:”embedded”,”SchemaName”:”testdata”,”user”:”test”,”password”:”test”})), (CacheConfig,JString({“MaxSizeInMB”:256})))))))

    DEBUG [main] – Parsed the json : JObject(List((Tenant,JObject(List((TenantId,JString(tenant1)), (Description,JString(tenant1)), (PrimaryDataStore,JString({“Location”:”/home/admin/Kamanja-1.5.0_2.11/storage/tenant1_default”,”portnumber”:”9100″,”StoreType”:”h2db”,”connectionMode”:”embedded”,”SchemaName”:”testdata”,”user”:”test”,”password”:”test”})), (CacheConfig,JString({“MaxSizeInMB”:256})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”Storage_1″,”TypeString”:”Storage”,”ClassName”:””,”JarName”:””,”DependencyJars”:[],”AdapterSpecificCfg”:””,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”Location\”:\”/home/admin/Kamanja-1.5.0_2.11/storage/tenant1_storage_1\”,\”Name\”:\”Storage_1\”,\”portnumber\”:\”9100\”,\”StoreType\”:\”h2db\”,\”TypeString\”:\”Storage\”,\”connectionMode\”:\”embedded\”,\”SchemaName\”:\”testdata\”,\”user\”:\”test\”,\”password\”:\”test\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(Storage_1)), (TypeString,JString(Storage)), (ClassName,JString()), (JarName,JString()), (DependencyJars,JArray(List())), (AdapterSpecificCfg,JString()), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”Location”:”/home/admin/Kamanja-1.5.0_2.11/storage/tenant1_storage_1″,”Name”:”Storage_1″,”portnumber”:”9100″,”StoreType”:”h2db”,”TypeString”:”Storage”,”connectionMode”:”embedded”,”SchemaName”:”testdata”,”user”:”test”,”password”:”test”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(Storage_1)), (TypeString,JString(Storage)), (ClassName,JString()), (JarName,JString()), (DependencyJars,JArray(List())), (AdapterSpecificCfg,JString()), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”Location”:”/home/admin/Kamanja-1.5.0_2.11/storage/tenant1_storage_1″,”Name”:”Storage_1″,”portnumber”:”9100″,”StoreType”:”h2db”,”TypeString”:”Storage”,”connectionMode”:”embedded”,”SchemaName”:”testdata”,”user”:”test”,”password”:”test”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”HelloWorldInput”,”TypeString”:”Input”,”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”helloworldinput\”}”,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.InputAdapters.KamanjaKafkaConsumer$\”,\”Name\”:\”HelloWorldInput\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”helloworldinput\”},\”TypeString\”:\”Input\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(HelloWorldInput)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”helloworldinput”})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”HelloWorldInput”,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”helloworldinput”},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(HelloWorldInput)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”helloworldinput”})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”HelloWorldInput”,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”helloworldinput”},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”MedicalInput”,”TypeString”:”Input”,”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”medicalinput\”}”,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.InputAdapters.KamanjaKafkaConsumer$\”,\”Name\”:\”MedicalInput\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”medicalinput\”},\”TypeString\”:\”Input\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(MedicalInput)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”medicalinput”})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”MedicalInput”,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”medicalinput”},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(MedicalInput)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”medicalinput”})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”MedicalInput”,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”medicalinput”},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”FinanceInput”,”TypeString”:”Input”,”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”financeinput\”}”,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.InputAdapters.KamanjaKafkaConsumer$\”,\”Name\”:\”FinanceInput\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”financeinput\”},\”TypeString\”:\”Input\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(FinanceInput)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”financeinput”})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”FinanceInput”,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”financeinput”},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(FinanceInput)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”financeinput”})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”FinanceInput”,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”financeinput”},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”TelecomInput”,”TypeString”:”Input”,”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”telecominput\”}”,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.InputAdapters.KamanjaKafkaConsumer$\”,\”Name\”:\”TelecomInput\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”telecominput\”},\”TypeString\”:\”Input\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(TelecomInput)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”telecominput”})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”TelecomInput”,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”telecominput”},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(TelecomInput)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”telecominput”})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”TelecomInput”,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”telecominput”},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”TestIn_1″,”TypeString”:”Input”,”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”testin_1\”}”,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.InputAdapters.KamanjaKafkaConsumer$\”,\”Name\”:\”TestIn_1\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”testin_1\”},\”TypeString\”:\”Input\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(TestIn_1)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”testin_1″})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”TestIn_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”testin_1″},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(TestIn_1)), (TypeString,JString(Input)), (ClassName,JString(com.ligadata.InputAdapters.KamanjaKafkaConsumer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”testin_1″})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.InputAdapters.KamanjaKafkaConsumer$”,”Name”:”TestIn_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”testin_1″},”TypeString”:”Input”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”TestOut_1″,”TypeString”:”Output”,”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”testout_1\”}”,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.OutputAdapters.KafkaProducer$\”,\”Name\”:\”TestOut_1\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”testout_1\”},\”TypeString\”:\”Output\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(TestOut_1)), (TypeString,JString(Output)), (ClassName,JString(com.ligadata.OutputAdapters.KafkaProducer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”testout_1″})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”Name”:”TestOut_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”testout_1″},”TypeString”:”Output”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(TestOut_1)), (TypeString,JString(Output)), (ClassName,JString(com.ligadata.OutputAdapters.KafkaProducer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”testout_1″})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”Name”:”TestOut_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”testout_1″},”TypeString”:”Output”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”TestFailedEvents_1″,”TypeString”:”Output”,”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”testfailedevents_1\”}”,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.OutputAdapters.KafkaProducer$\”,\”Name\”:\”TestFailedEvents_1\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”testfailedevents_1\”},\”TypeString\”:\”Output\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(TestFailedEvents_1)), (TypeString,JString(Output)), (ClassName,JString(com.ligadata.OutputAdapters.KafkaProducer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”testfailedevents_1″})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”Name”:”TestFailedEvents_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”testfailedevents_1″},”TypeString”:”Output”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(TestFailedEvents_1)), (TypeString,JString(Output)), (ClassName,JString(com.ligadata.OutputAdapters.KafkaProducer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”testfailedevents_1″})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”Name”:”TestFailedEvents_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”testfailedevents_1″},”TypeString”:”Output”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”TestMessageEvents_1″,”TypeString”:”Output”,”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”testmessageevents_1\”}”,”TenantId”:”tenant1″,”FullAdapterConfig”:”{\”TenantId\”:\”tenant1\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.OutputAdapters.KafkaProducer$\”,\”Name\”:\”TestMessageEvents_1\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”testmessageevents_1\”},\”TypeString\”:\”Output\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(TestMessageEvents_1)), (TypeString,JString(Output)), (ClassName,JString(com.ligadata.OutputAdapters.KafkaProducer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”testmessageevents_1″})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”Name”:”TestMessageEvents_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”testmessageevents_1″},”TypeString”:”Output”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(TestMessageEvents_1)), (TypeString,JString(Output)), (ClassName,JString(com.ligadata.OutputAdapters.KafkaProducer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”testmessageevents_1″})), (TenantId,JString(tenant1)), (FullAdapterConfig,JString({“TenantId”:”tenant1″,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”Name”:”TestMessageEvents_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”testmessageevents_1″},”TypeString”:”Output”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“Adapter”:{“Name”:”TestStatus_1″,”TypeString”:”Output”,”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”AdapterSpecificCfg”:”{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”teststatus_1\”}”,”TenantId”:”System”,”FullAdapterConfig”:”{\”TenantId\”:\”System\”,\”DependencyJars\”:[\”ExtDependencyLibs_2.11-1.5.0.jar\”,\”ExtDependencyLibs2_2.11-1.5.0.jar\”],\”ClassName\”:\”com.ligadata.OutputAdapters.KafkaProducer$\”,\”Name\”:\”TestStatus_1\”,\”AdapterSpecificCfg\”:{\”HostList\”:\”localhost:9092\”,\”TopicName\”:\”teststatus_1\”},\”TypeString\”:\”Output\”,\”JarName\”:\”KamanjaInternalDeps_2.11-1.5.0.jar\”}”}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((Adapter,JObject(List((Name,JString(TestStatus_1)), (TypeString,JString(Output)), (ClassName,JString(com.ligadata.OutputAdapters.KafkaProducer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”teststatus_1″})), (TenantId,JString(System)), (FullAdapterConfig,JString({“TenantId”:”System”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”Name”:”TestStatus_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”teststatus_1″},”TypeString”:”Output”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsed the json : JObject(List((Adapter,JObject(List((Name,JString(TestStatus_1)), (TypeString,JString(Output)), (ClassName,JString(com.ligadata.OutputAdapters.KafkaProducer$)), (JarName,JString(KamanjaInternalDeps_2.11-1.5.0.jar)), (DependencyJars,JArray(List(JString(ExtDependencyLibs_2.11-1.5.0.jar), JString(ExtDependencyLibs2_2.11-1.5.0.jar)))), (AdapterSpecificCfg,JString({“HostList”:”localhost:9092″,”TopicName”:”teststatus_1″})), (TenantId,JString(System)), (FullAdapterConfig,JString({“TenantId”:”System”,”DependencyJars”:[“ExtDependencyLibs_2.11-1.5.0.jar”,”ExtDependencyLibs2_2.11-1.5.0.jar”],”ClassName”:”com.ligadata.OutputAdapters.KafkaProducer$”,”Name”:”TestStatus_1″,”AdapterSpecificCfg”:{“HostList”:”localhost:9092″,”TopicName”:”teststatus_1″},”TypeString”:”Output”,”JarName”:”KamanjaInternalDeps_2.11-1.5.0.jar”})))))))

    DEBUG [main] – Parsing json : {“UserProperties”:{“ClusterId”:”ligadata1″,”Props”:[{“Key”:”Tenants”,”Value”:”List(Map(TenantId -> tenant1, Description -> tenant1, PrimaryDataStore -> Map(Location -> /home/admin/Kamanja-1.5.0_2.11/storage/tenant1_default, portnumber -> 9100, StoreType -> h2db, connectionMode -> embedded, SchemaName -> testdata, user -> test, password -> test), CacheConfig -> Map(MaxSizeInMB -> 256)))”}]}}

    DEBUG [main] – Parsed  json  and it is : JObject(List((UserProperties,JObject(List((ClusterId,JString(ligadata1)), (Props,JArray(List(JObject(List((Key,JString(Tenants)), (Value,JString(List(Map(TenantId -> tenant1, Description -> tenant1, PrimaryDataStore -> Map(Location -> /home/admin/Kamanja-1.5.0_2.11/storage/tenant1_default, portnumber -> 9100, StoreType -> h2db, connectionMode -> embedded, SchemaName -> testdata, user -> test, password -> test), CacheConfig -> Map(MaxSizeInMB -> 256)))))))))))))))

    DEBUG [main] – Parsed the json : JObject(List((UserProperties,JObject(List((ClusterId,JString(ligadata1)), (Props,JArray(List(JObject(List((Key,JString(Tenants)), (Value,JString(List(Map(TenantId -> tenant1, Description -> tenant1, PrimaryDataStore -> Map(Location -> /home/admin/Kamanja-1.5.0_2.11/storage/tenant1_default, portnumber -> 9100, StoreType -> h2db, connectionMode -> embedded, SchemaName -> testdata, user -> test, password -> test), CacheConfig -> Map(MaxSizeInMB -> 256)))))))))))))))

    ERROR [main] – Node Undefined not found in metadata

    DEBUG [main] – The table transaction_id already exists

    DEBUG [main] – Max Transaction Id => 1

    DEBUG [main] – The table model_config_objects already exists

    INFO [main] – Fetch the results of select timePartition,bucketKey,transactionId,rowId,schemaId,serializerType,serializedInfo from kamanja.model_config_objects

    DEBUG [main] – No model config objects available in the Database

    DEBUG [main] – The table metadata_objects already exists

    INFO [main] – Fetch the results of select timePartition,bucketKey,transactionId,rowId,schemaId,serializerType,serializedInfo from kamanja.metadata_objects

    DEBUG [main] – No metadata objects available in the Database

    DEBUG [main] – Establishing connection to domain security server..

    DEBUG [main] – Trying to load class:<root>.package, resolve:false

    DEBUG [main] – Trying to load class:<root>.scala, resolve:false

    DEBUG [main] – Trying to load class:scala, resolve:false

    DEBUG [main] – Trying to load class:scala.package, resolve:false

    DEBUG [main] – Trying to load class:scala.Throwable, resolve:false

    DEBUG [main] – Trying to load class:scala.Exception, resolve:false

    DEBUG [main] – Trying to load class:scala.Error, resolve:false

    DEBUG [main] – Trying to load class:scala.RuntimeException, resolve:false

    DEBUG [main] – Trying to load class:scala.NullPointerException, resolve:false

    DEBUG [main] – Trying to load class:scala.ClassCastException, resolve:false

    DEBUG [main] – Trying to load class:scala.IndexOutOfBoundsException, resolve:false

    DEBUG [main] – Trying to load class:scala.ArrayIndexOutOfBoundsException, resolve:false

    DEBUG [main] – Trying to load class:scala.StringIndexOutOfBoundsException, resolve:false

    DEBUG [main] – Trying to load class:scala.UnsupportedOperationException, resolve:false

    DEBUG [main] – Trying to load class:scala.IllegalArgumentException, resolve:false

    DEBUG [main] – Trying to load class:scala.NoSuchElementException, resolve:false

    DEBUG [main] – Trying to load class:scala.NumberFormatException, resolve:false

    DEBUG [main] – Trying to load class:scala.AbstractMethodError, resolve:false

    DEBUG [main] – Trying to load class:scala.InterruptedException, resolve:false

    DEBUG [main] – Trying to load class:scala.AnyRef, resolve:false

    DEBUG [main] – Trying to load class:scala.TraversableOnce, resolve:false

    DEBUG [main] – Trying to load class:scala.Traversable, resolve:false

    DEBUG [main] – Trying to load class:scala.Traversable, resolve:false

    DEBUG [main] – Trying to load class:scala.Iterable, resolve:false

    DEBUG [main] – Trying to load class:scala.Iterable, resolve:false

    DEBUG [main] – Trying to load class:scala.Seq, resolve:false

    DEBUG [main] – Trying to load class:scala.Seq, resolve:false

    DEBUG [main] – Trying to load class:scala.IndexedSeq, resolve:false

    DEBUG [main] – Trying to load class:scala.IndexedSeq, resolve:false

    DEBUG [main] – Trying to load class:scala.Iterator, resolve:false

    DEBUG [main] – Trying to load class:scala.Iterator, resolve:false

    DEBUG [main] – Trying to load class:scala.BufferedIterator, resolve:false

    DEBUG [main] – Trying to load class:scala.List, resolve:false

    DEBUG [main] – Trying to load class:scala.List, resolve:false

    DEBUG [main] – Trying to load class:scala.Nil, resolve:false

    DEBUG [main] – Trying to load class:scala.$colon$colon, resolve:false

    DEBUG [main] – Trying to load class:scala.$colon$colon, resolve:false

    DEBUG [main] – Trying to load class:scala.$plus$colon, resolve:false

    DEBUG [main] – Trying to load class:scala.$colon$plus, resolve:false

    DEBUG [main] – Trying to load class:scala.Stream, resolve:false

    DEBUG [main] – Trying to load class:scala.Stream, resolve:false

    DEBUG [main] – Trying to load class:scala.$hash$colon$colon, resolve:false

    DEBUG [main] – Trying to load class:scala.Vector, resolve:false

    DEBUG [main] – Trying to load class:scala.Vector, resolve:false

    DEBUG [main] – Trying to load class:scala.StringBuilder, resolve:false

    DEBUG [main] – Trying to load class:scala.StringBuilder, resolve:false

    DEBUG [main] – Trying to load class:scala.Range, resolve:false

    DEBUG [main] – Trying to load class:scala.Range, resolve:false

    DEBUG [main] – Trying to load class:scala.BigDecimal, resolve:false

    DEBUG [main] – Trying to load class:scala.BigDecimal, resolve:false

    DEBUG [main] – Trying to load class:scala.BigInt, resolve:false

    DEBUG [main] – Trying to load class:scala.BigInt, resolve:false

    DEBUG [main] – Trying to load class:scala.Equiv, resolve:false

    DEBUG [main] – Trying to load class:scala.Equiv, resolve:false

    DEBUG [main] – Trying to load class:scala.Fractional, resolve:false

    DEBUG [main] – Trying to load class:scala.Fractional, resolve:false

    DEBUG [main] – Trying to load class:scala.Integral, resolve:false

    DEBUG [main] – Trying to load class:scala.Integral, resolve:false

    DEBUG [main] – Trying to load class:scala.Numeric, resolve:false

    DEBUG [main] – Trying to load class:scala.Numeric, resolve:false

    DEBUG [main] – Trying to load class:scala.Ordered, resolve:false

    DEBUG [main] – Trying to load class:scala.Ordered, resolve:false

    DEBUG [main] – Trying to load class:scala.Ordering, resolve:false

    DEBUG [main] – Trying to load class:scala.Ordering, resolve:false

    DEBUG [main] – Trying to load class:scala.PartialOrdering, resolve:false

    DEBUG [main] – Trying to load class:scala.PartiallyOrdered, resolve:false

    DEBUG [main] – Trying to load class:scala.Either, resolve:false

    DEBUG [main] – Trying to load class:scala.Either, resolve:false

    DEBUG [main] – Trying to load class:scala.Left, resolve:false

    DEBUG [main] – Trying to load class:scala.Left, resolve:false

    DEBUG [main] – Trying to load class:scala.Right, resolve:false

    DEBUG [main] – Trying to load class:scala.Right, resolve:false

    DEBUG [main] – Trying to load class:scala.runtime, resolve:false

    DEBUG [main] – Trying to load class:scala.runtime.package, resolve:false

    DEBUG [main] – Metadata synching is now available.

    DEBUG [main] – Call Message Compiler ….

    DEBUG [main] – The table metadatacounters already exists

    INFO [main] – Definition : {

    \”Container\”:{

    \”NameSpace\”:\”com.ligadata.kamanja.samples.containers\”,

    \”Name\”:\”CoughCodes\”,

    \”Version\”:\”00.01.00\”,

    \”Description\”:\”ContainerforCoughCodes\”,

    \”Fixed\”:\”true\”,

    \”Persist\”:\”true\”,

    \”Fields\”:[

    {

    \”Name\”:\”icd9Code\”,

    \”Type\”:\”System.String\”

    },

    {

    \”Name\”:\”icd9Description\”,

    \”Type\”:\”System.String\”

    }

    ],

    \”PartitionKey\”:[

    \”icd9Code\”

    ]

    }

    }

    INFO [main] – fieldBaseType.implementationName====String

    INFO [main] – field.AttributeTypeInfo keyTypeId====-1

    INFO [main] – field.AttributeTypeInfo valSchemaId====0

    INFO [main] – field.AttributeTypeInfo valTypeId====-1

    INFO [main] – field.AttributeTypeInfo typeCategaryName====STRING

    INFO [main] – fieldBaseType.implementationName====String

    INFO [main] – field.AttributeTypeInfo keyTypeId====-1

    INFO [main] – field.AttributeTypeInfo valSchemaId====0

    INFO [main] – field.AttributeTypeInfo valTypeId====-1

    INFO [main] – field.AttributeTypeInfo typeCategaryName====STRING

    INFO [main] – Field Type system.string

    INFO [main] – fieldTypestr(1).substring(7) string

    INFO [main] – retFldStr  “type” : “string”

    INFO [main] – Field Type system.string

    INFO [main] – fieldTypestr(1).substring(7) string

    INFO [main] – retFldStr  “type” : “string”

    INFO [main] –  msgdefobjs  size 0

    INFO [main] –  msgdefobjs  size 0

    INFO [main] – MsgType: ContainerFactoryInterface

    INFO [main] – ObjectStr: object CoughCodes extends RDDObject[CoughCodes] with ContainerFactoryInterface {

     

    INFO [main] – JarsetList()

    INFO [main] –  msg.NameSpace   com.ligadata.kamanja.samples.containers

    INFO [main] – msg.Name    CoughCodes

    INFO [main] – msg.PhysicalName   com.ligadata.kamanja.samples.containers.V1000000.CoughCodes

    INFO [main] – version    1000000

    INFO [main] – msg.ArgsList   List((system,icd9description,system,string,false,null), (system,icd9code,system,string,false,null))

    INFO [main] – msg.jarset    List()

    INFO [main] – recompile   false

    INFO [main] – msg.Persist    true

    INFO [main] – fieldBaseType.implementationName====String

    INFO [main] – field.AttributeTypeInfo keyTypeId====-1

    INFO [main] – field.AttributeTypeInfo valSchemaId====0

    INFO [main] – field.AttributeTypeInfo valTypeId====-1

    INFO [main] – field.AttributeTypeInfo typeCategaryName====STRING

    INFO [main] – fieldBaseType.implementationName====String

    INFO [main] – field.AttributeTypeInfo keyTypeId====-1

    INFO [main] – field.AttributeTypeInfo valSchemaId====0

    INFO [main] – field.AttributeTypeInfo valTypeId====-1

    INFO [main] – field.AttributeTypeInfo typeCategaryName====STRING

    INFO [main] – Field Type system.string

    INFO [main] – fieldTypestr(1).substring(7) string

    INFO [main] – retFldStr  “type” : “string”

    INFO [main] – Field Type system.string

    INFO [main] – fieldTypestr(1).substring(7) string

    INFO [main] – retFldStr  “type” : “string”

    INFO [main] –  msgdefobjs  size 0

    INFO [main] –  msgdefobjs  size 0

    INFO [main] – MsgType: ContainerFactoryInterface

    INFO [main] – ObjectStr: object CoughCodes extends RDDObject[CoughCodes] with ContainerFactoryInterface {

     

    DEBUG [main] – Message Compilation done ….{“Container”:{“NameSpace”:”com.ligadata.kamanja.samples.containers”,”Name”:”coughcodes”,”FullName”:”com.ligadata.kamanja.samples.containers.coughcodes”,”Version”:”000000000001000000″,”TenantId”:””,”ElementId”:0,”Description”:null,”Comment”:null,”Author”:null,”Tag”:null,”OtherParams”:”{}”,”CreatedTime”:1469127976552,”UpdatedTime”:1469127976552,”SchemaId”:2000005,”AvroSchema”:”{ \”type\”: \”record\”,  \”namespace\” : \”com.ligadata.kamanja.samples.containers\” , \”name\” : \”coughcodes\” , \”fields\”:[{ \”name\” : \”icd9code\” , \”type\” : \”string\”},{ \”name\” : \”icd9description\” , \”type\” : \”string\”}]}”,”JarName”:null,”PhysicalName”:”com.ligadata.kamanja.samples.containers.V1000000.CoughCodes”,”ObjectDefinition”:null,”ObjectFormat”:”JSON”,”DependencyJars”:[],”MsgAttributes”:[{“NameSpace”:”system”,”Name”:”icd9description”,”TypNameSpace”:”system”,”TypName”:”string”,”Version”:1000000,”CollectionType”:”None”},{“NameSpace”:”system”,”Name”:”icd9code”,”TypNameSpace”:”system”,”TypName”:”string”,”Version”:1000000,”CollectionType”:”None”}],”PrimaryKeys”:[],”ForeignKeys”:[],”TransactionId”:0}}

    ERROR [main] – Failed to compile the message definition

    java.io.FileNotFoundException: /home/admin/Kamanja-1.5.0_2.11/workingdir/CoughCodes.scala (No such file or directory)

    at java.io.FileOutputStream.open0(Native Method) ~[?:1.8.0_101]

    at java.io.FileOutputStream.open(FileOutputStream.java:270) ~[?:1.8.0_101]

    at java.io.FileOutputStream.<init>(FileOutputStream.java:213) ~[?:1.8.0_101]

    at java.io.FileOutputStream.<init>(FileOutputStream.java:162) ~[?:1.8.0_101]

    at java.io.FileWriter.<init>(FileWriter.java:90) ~[?:1.8.0_101]

    at com.ligadata.MetadataAPI.CompilerProxy.dumpStrTextToFile(CompilerProxy.scala:1658) ~[KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.CompilerProxy.compileMessageDef(CompilerProxy.scala:409) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MessageAndContainerUtils$.AddContainerOrMessage(MessageAndContainerUtils.scala:263) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MetadataAPIImpl$.AddContainerOrMessage(MetadataAPIImpl.scala:1972) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MetadataAPIImpl$.AddContainer(MetadataAPIImpl.scala:2019) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.Utility.ContainerService$.addContainer(ContainerService.scala:90) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI$.route(StartMetadataAPI.scala:595) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI$.main(StartMetadataAPI.scala:354) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI.main(StartMetadataAPI.scala) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    DEBUG [main] –

    com.ligadata.Exceptions.MsgCompilationFailedException: /home/admin/Kamanja-1.5.0_2.11/workingdir/CoughCodes.scala (No such file or directory)

    at com.ligadata.MetadataAPI.CompilerProxy.compileMessageDef(CompilerProxy.scala:495) ~[KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MessageAndContainerUtils$.AddContainerOrMessage(MessageAndContainerUtils.scala:263) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MetadataAPIImpl$.AddContainerOrMessage(MetadataAPIImpl.scala:1972) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.MetadataAPIImpl$.AddContainer(MetadataAPIImpl.scala:2019) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.Utility.ContainerService$.addContainer(ContainerService.scala:90) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI$.route(StartMetadataAPI.scala:595) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI$.main(StartMetadataAPI.scala:354) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.StartMetadataAPI.main(StartMetadataAPI.scala) [KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    Caused by: java.io.FileNotFoundException: /home/admin/Kamanja-1.5.0_2.11/workingdir/CoughCodes.scala (No such file or directory)

    at java.io.FileOutputStream.open0(Native Method) ~[?:1.8.0_101]

    at java.io.FileOutputStream.open(FileOutputStream.java:270) ~[?:1.8.0_101]

    at java.io.FileOutputStream.<init>(FileOutputStream.java:213) ~[?:1.8.0_101]

    at java.io.FileOutputStream.<init>(FileOutputStream.java:162) ~[?:1.8.0_101]

    at java.io.FileWriter.<init>(FileWriter.java:90) ~[?:1.8.0_101]

    at com.ligadata.MetadataAPI.CompilerProxy.dumpStrTextToFile(CompilerProxy.scala:1658) ~[KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    at com.ligadata.MetadataAPI.CompilerProxy.compileMessageDef(CompilerProxy.scala:409) ~[KamanjaInternalDeps_2.11-1.5.0.jar:0.1-SNAPSHOT]

    … 7 more

    Result: {

    “APIResults” : {

    “Status Code” : -1,

    “Function Name” : “AddContainerOrMessage”,

    “Result Data” : “{\n  \”Container\”: {\n    \”NameSpace\”: \”com.ligadata.kamanja.samples.containers\”,\n    \”Name\”: \”CoughCodes\”,\n    \”Version\”: \”00.01.00\”,\n    \”Description\”: \”Container for Cough Codes\”,\n    \”Fixed\”: \”true\”,\n    \”Persist\”: \”true\”,\n    \”Fields\”: [\n      {\n        \”Name\”: \”icd9Code\”,\n        \”Type\”: \”System.String\”\n      },\n      {\n        \”Name\”: \”icd9Description\”,\n        \”Type\”: \”System.String\”\n      }\n    ],\n    \”PartitionKey\”: [\n      \”icd9Code\”\n    ]\n  }\n}\n”,

    “Result Description” : “Error: com.ligadata.Exceptions.MsgCompilationFailedException: /home/admin/Kamanja-1.5.0_2.11/workingdir/CoughCodes.scala (No such file or directory)Failed to add container/message”

    }

    }

    DEBUG [main] – Closing datastore

    INFO [main] – close the connection pool

    DEBUG [main] – main datastore closed

    admin@mkscoringengine:~/kamanja-1.5.0_2.11/workingdir$

     

  • #19571 Reply

    Jordan Woods
    Participant

    Looking at the error message, it seems that it is having issues with Scala, but if i open a terminal, I can access Scala just fine:

     

    admin@mkscoringengine:~$ clear

    admin@mkscoringengine:~$ scala

    Welcome to Scala version 2.11.7 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_101).

    Type in expressions to have them evaluated.

    Type :help for more information.

     

    scala>

     

  • #19573 Reply

    Could you share your ‘echo $SCALA_HOME’, ‘which scala’ ‘echo $PATH’. It looks like SCALA_HOME is pointing to somewhere else.

  • #19574 Reply

    Jordan Woods
    Participant

    Hi Dhaval. Sure! Below.

     

    admin@mkscoringengine:~$ echo $SCALA_HOME

    /home/admin/scala-2.11.7

    admin@mkscoringengine:~$ which scala

    /home/admin/scala-2.11.7/bin/scala

    admin@mkscoringengine:~$ echo $PATH

    /home/admin/jdk1.8.0_101/bin:/home/admin/scala-2.11.7/bin:/home/admin/kamanja-1.5.0_2.11/bin:/home/admin/zookeeper-3.4.8/bin:/home/admin/kafka_2.11-0.10.0.0/bin:/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/usr/games:/usr/local/games

    admin@mkscoringengine:~$

     

    • This reply was modified 1 year, 4 months ago by  Jordan Woods.
  • #19579 Reply

    Scala path looks fine. Could you install Kamanja in some other location where you have full access and try. A per the error it looks like it is failing at dumpStrTextToFile. Also, could you verify in https://jsonformatter.curiousconcept.com/ if the container json is valid.

    I tried to replicate the issue but it is compiling for me.

    Regards,

    Dhaval Kolapkar

  • #19580 Reply

    Jordan Woods
    Participant

    Hi Dhaval,

    I tried moving Kamanja to some other location. I got to the stage of rerunning “SetPaths.sh”, and I got an error about Kafka…

    admin@mkscoringengine:/opt/Kamanja-1.5.1_2.11/bin$ clear

    admin@mkscoringengine:/opt/Kamanja-1.5.1_2.11/bin$ echo $KAFKA_HOME

    /home/admin/kafka_2.11-0.10.0.0

    admin@mkscoringengine:/opt/Kamanja-1.5.1_2.11/bin$ echo $KafkaRootDir

    /home/admin/kafka_2.11-0.10.0.0

    admin@mkscoringengine:/opt/Kamanja-1.5.1_2.11/bin$ SetPaths.sh

    Setting up paths

    WARN: Not given/found Kafka install directory. Not going to create CreateQueues.sh, WatchOutputQueue.sh, WatchStatusQueue.sh, WatchFailedEventQueue.sh and WatchInputQueue.sh

    admin@mkscoringengine:/opt/Kamanja-1.5.1_2.11/bin$

     

  • #19581 Reply

    Run “SetPaths.sh $KAFKA_HOME”

    • #19582 Reply

      Jordan Woods
      Participant

      Hi Dhaval,

      Thanks for the help. Reinstalling it seems to have done the trick!

      Thanks again,

      -Jordan

  • #19583 Reply

    William
    Keymaster

    We need to have a clearer error message and not an exception for the user to better understand what’s going on. Issue 1355 has been opened regarding this. https://github.com/LigaData/Kamanja/issues/1355

Reply To: Failed to add container/message
Your information: