Kamanja-1.2.2 : Running Telecom Sample App

14 views
Skip to first unread message

Haitham Bjanthala

unread,
Jan 19, 2016, 4:41:30 AM1/19/16
to kamanja
Hello,

I'm trying to run the Telecom app (SubscriberUsageApp.sh) on a cluster running Kamanja-1.2.2 with Hbase as a meta store.
i am able to add the model and containers , but when i run ( InitKvStores_Telecom.sh ) i get the following error for all containers:

 WARN [main] - DATABASE_SCHEMA remains unset
 WARN [main] - DO_AUTH remains unset
 WARN [main] - MODEL_EXEC_LOG remains unset
 WARN [main] - JAR_TARGET_DIR remains unset
 WARN [main] - ADAPTER_SPECIFIC_CONFIG remains unset
 WARN [main] - AUDIT_PARMS remains unset
 WARN [main] - ZOOKEEPER_CONNECT_STRING remains unset
 WARN [main] - SECURITY_IMPL_CLASS remains unset
 WARN [main] - DATABASE remains unset
 WARN [main] - AUDIT_IMPL_JAR remains unset
 WARN [main] - SECURITY_IMPL_JAR remains unset
 WARN [main] - FUNCTION_FILES_DIR remains unset
 WARN [main] - MESSAGE_FILES_DIR remains unset
 WARN [main] - COMPILER_WORK_DIR remains unset
 WARN [main] - CONTAINER_FILES_DIR remains unset
 WARN [main] - ZNODE_PATH remains unset
 WARN [main] - NOTIFY_ENGINE remains unset
 WARN [main] - DATABASE_HOST remains unset
 WARN [main] - SCALA_HOME remains unset
 WARN [main] - SERVICE_PORT remains unset
 WARN [main] - CLASSPATH remains unset
 WARN [main] - AUDIT_IMPL_CLASS remains unset
 WARN [main] - SSL_PASSWD remains unset
 WARN [main] - SSL_CERTIFICATE remains unset
 WARN [main] - SERVICE_HOST remains unset
 WARN [main] - CONCEPT_FILES_DIR remains unset
 WARN [main] - DATABASE_LOCATION remains unset
 WARN [main] - JAVA_HOME remains unset
 WARN [main] - MANIFEST_PATH remains unset
 WARN [main] - TYPE_FILES_DIR remains unset
 WARN [main] - MODEL_FILES_DIR remains unset
 WARN [main] - DO_AUDIT remains unset
 WARN [main] - JAR_PATHS remains unset
 WARN [main] - GIT_ROOT remains unset
 WARN [main] - CONFIG_FILES_DIR remains unset
 WARN [main] - ROOT_DIR remains unset
ERROR [main] - Not found valid type for com.ligadata.kamanja.samples.containers.accountaggregatedusage


... When i run the command ( kamanja get all containers ) i get the following result:

Using default configuration /opt/kamanja-1.2.2/config/MetadataAPIConfig.properties
 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
log4j:WARN No appenders could be found for logger (org.apache.curator.framework.imps.CuratorFrameworkImpl).
log4j:WARN Please initialize the log4j system properly.
ERROR [main] - Node {NodeId} not found in metadata
Result: {
  "APIResults" : {
    "Status Code" : 0,
    "Function Name" : "ContainerService",
    "Result Data" : "com.ligadata.kamanja.samples.containers.dyspnoeacodes.000000000001000000, system.context.000000000000000001, com.ligadata.kamanja.samples.containers.subscriberinfo.000000000001000000, system.messagecontainerbase.000000000000000001, com.ligadata.kamanja.samples.containers.subscriberglobalpreferences.000000000001000000, system.basecontainer.000000000000000001, com.ligadata.kamanja.samples.containers.sputumcodes.000000000001000000, com.ligadata.kamanja.samples.containers.smokecodes.000000000001000000, system.envcontext.000000000000000001, system.basemsg.000000000000000001, com.ligadata.kamanja.samples.containers.coughcodes.000000000001000000, com.ligadata.kamanja.samples.containers.envcodes.000000000001000000, com.ligadata.kamanja.samples.containers.accountinfo.000000000001000000, com.ligadata.kamanja.samples.containers.subscriberaggregatedusage.000000000001000000, com.ligadata.kamanja.samples.containers.accountaggregatedusage.000000000001000000, com.ligadata.kamanja.samples.containers.subscriberplans.000000000001000000",
    "Result Description" : "Successfully retrieved all the messages"
  }
}

-------------
P.S : some files that might be needed are attached.
Java version : Java(TM) SE Runtime Environment (build 1.8.0_65-b17)





--

Regards,
Haitham
ClusterConfig.json
MetadataAPIConfig.properties
InitKvStores_Telecom.sh
SubscriberUsageApp.sh

Haitham Bjanthala

unread,
Jan 19, 2016, 5:47:47 AM1/19/16
to kamanja
i tried the same thing on a single node Kamanja-1.2.2 and got a different error : 

.
.
.
 WARN [main] - ROOT_DIR remains unset
log4j:WARN No appenders could be found for logger (org.apache.curator.framework.imps.CuratorFrameworkImpl).
log4j:WARN Please initialize the log4j system properly.
ERROR [main] - Failed to connect to Datastore. Reason:null. Message:scala.reflect.api.JavaUniverse.runtimeMirror(Ljava/lang/ClassLoader;)Lscala/reflect/api/JavaUniverse$JavaMirror;
Cause:
java.lang.NoSuchMethodError: scala.reflect.api.JavaUniverse.runtimeMirror(Ljava/lang/ClassLoader;)Lscala/reflect/api/JavaUniverse$JavaMirror;
at com.ligadata.kamanja.samples.containers.V1000000.AccountAggregatedUsage.getWithReflection(AccountAggregatedUsage.scala:196)
at com.ligadata.kamanja.samples.containers.V1000000.AccountAggregatedUsage.get(AccountAggregatedUsage.scala:165)
at com.ligadata.tools.kvinit.KVInit$$anonfun$com$ligadata$tools$kvinit$KVInit$$buildContainerOrMessage$1$$anonfun$apply$9$$anonfun$17.apply(KVInit.scala:868)
at com.ligadata.tools.kvinit.KVInit$$anonfun$com$ligadata$tools$kvinit$KVInit$$buildContainerOrMessage$1$$anonfun$apply$9$$anonfun$17.apply(KVInit.scala:865)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
at scala.collection.mutable.ArrayOps$ofRef.map(ArrayOps.scala:108)
at com.ligadata.tools.kvinit.KVInit$$anonfun$com$ligadata$tools$kvinit$KVInit$$buildContainerOrMessage$1$$anonfun$apply$9.apply(KVInit.scala:865)
at com.ligadata.tools.kvinit.KVInit$$anonfun$com$ligadata$tools$kvinit$KVInit$$buildContainerOrMessage$1$$anonfun$apply$9.apply(KVInit.scala:826)
at scala.collection.immutable.List.foreach(List.scala:318)
at com.ligadata.tools.kvinit.KVInit$$anonfun$com$ligadata$tools$kvinit$KVInit$$buildContainerOrMessage$1.apply(KVInit.scala:826)
at com.ligadata.tools.kvinit.KVInit$$anonfun$com$ligadata$tools$kvinit$KVInit$$buildContainerOrMessage$1.apply(KVInit.scala:819)
at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)
at com.ligadata.tools.kvinit.KVInit.com$ligadata$tools$kvinit$KVInit$$buildContainerOrMessage(KVInit.scala:819)
at com.ligadata.tools.kvinit.KVInit$.main(KVInit.scala:202)
at com.ligadata.tools.kvinit.KVInit.main(KVInit.scala)

--

Regards,
Haitham

Ahmad Ahed Abu Dayyah

unread,
Jan 19, 2016, 1:24:27 PM1/19/16
to kamanja
Hi Haitham , 

InitKv Stores script and start engine on one node use  Engine1Config.properties to connect to data store . please make sure that  the MetadataDataStore property inside  Engine1Config.properties file  point to hbase not to hashmap. 


Thanks,
Ahmed

Haitham Bjanthalah

unread,
Jan 19, 2016, 2:28:03 PM1/19/16
to 'LinkedIn Security' via kamanja, Ahmad Ahed Abu Dayyah

For single node im using hashmap, but for cluster we r using Hbase. I should have made that clear.

Sent from my Sony Xperia™ smartphone



---- Ahmad Ahed Abu Dayyah wrote ----
--
You received this message because you are subscribed to the Google Groups "kamanja" group.
To unsubscribe from this group and stop receiving emails from it, send an email to kamanja+u...@ligadata.com.
To post to this group, send email to kam...@ligadata.com.
Visit this group at https://groups.google.com/a/ligadata.com/group/kamanja/.
Reply all
Reply to author
Forward
0 new messages