Tried to create a cluster but failed with below error message.
Error Log:
INFO core - Starting 1 nodes for :zookeeper-StormForIntelligentTrafficDemo, os-family null
INFO core - Starting 2 nodes for :supervisor-StormForIntelligentTrafficDemo, os-family null
ERROR futures - Adjust node count exception: No implementation of method: :ensure-os-family of protocol: #'pallet.compute/ComputeService found for class: nil
java.lang.IllegalArgumentException: No implementation of method: :ensure-os-family of protocol: #'pallet.compute/ComputeService found for class: nil
at clojure.core$_cache_protocol_fn.invoke(core_deftype.clj:471)
at pallet.compute$eval1063$fn__1092$G__1046__1099.invoke(compute.clj:49)
at pallet.core$create_nodes$fn__5444.invoke(core.clj:837)
at clojure.lang.AFn.applyToHelper(AFn.java:163)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:542)
at clojure.core$update_in.doInvoke(core.clj:4959)
at clojure.lang.RestFn.invoke(RestFn.java:446)
at pallet.core$create_nodes.invoke(core.clj:836)
at pallet.core$adjust_node_count.invoke(core.clj:912)
at pallet.core$parallel_adjust_node_counts$p_a_n_c_future__5506$fn__5507.invoke(core.clj:1003)
at clojure.lang.AFn.call(AFn.java:18)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
DEBUG futures - Adjust node count exception
java.lang.IllegalArgumentException: No implementation of method: :ensure-os-family of protocol: #'pallet.compute/ComputeService found for class: nil
at clojure.core$_cache_protocol_fn.invoke(core_deftype.clj:471)
at pallet.compute$eval1063$fn__1092$G__1046__1099.invoke(compute.clj:49)
at pallet.core$create_nodes$fn__5444.invoke(core.clj:837)
at clojure.lang.AFn.applyToHelper(AFn.java:163)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:542)
at clojure.core$update_in.doInvoke(core.clj:4959)
at clojure.lang.RestFn.invoke(RestFn.java:446)
at pallet.core$create_nodes.invoke(core.clj:836)
at pallet.core$adjust_node_count.invoke(core.clj:912)
at pallet.core$parallel_adjust_node_counts$p_a_n_c_future__5506$fn__5507.invoke(core.clj:1003)
at clojure.lang.AFn.call(AFn.java:18)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
cluster.yaml:
################################################################################
CLUSTERS CONFIG FILE
################################################################################
nimbus.image: "us-east-1/ami-0747bdcabd34c712a" #64-bit ubuntu
nimbus.hardware: "t2.large"
supervisor.count: 2
supervisor.image: "us-east-1/ami-0747bdcabd34c712a" #64-bit ubuntu on eu-east-1
supervisor.hardware: "t2.large"
#supervisor.spot.price: 1.60
zookeeper.count: 1
zookeeper.image: "us-east-1/ami-0747bdcabd34c712a" #64-bit ubuntu
zookeeper.hardware: "t2.large"
config.clj: saved under /home/ec2-user/.pallet/
(defpallet
:services
{
:default {
:blobstore-provider "aws-s3"
:provider "aws-ec2"
:environment {:user {:username "storm" ; this must be "storm"
:private-key-path "/.ssh/xxx.pem"
:public-key-path "/.ssh/xxx.pem.pub"}
:aws-user-id "xxx"}
:identity "xxx"
:credential "xxx"
:jclouds.regions "us-east-1"
}
})
Tried to create a cluster but failed with below error message.
Error Log:
INFO core - Starting 1 nodes for :zookeeper-StormForIntelligentTrafficDemo, os-family null
INFO core - Starting 2 nodes for :supervisor-StormForIntelligentTrafficDemo, os-family null
ERROR futures - Adjust node count exception: No implementation of method: :ensure-os-family of protocol: #'pallet.compute/ComputeService found for class: nil
java.lang.IllegalArgumentException: No implementation of method: :ensure-os-family of protocol: #'pallet.compute/ComputeService found for class: nil
at clojure.core$_cache_protocol_fn.invoke(core_deftype.clj:471)
at pallet.compute$eval1063$fn__1092$G__1046__1099.invoke(compute.clj:49)
at pallet.core$create_nodes$fn__5444.invoke(core.clj:837)
at clojure.lang.AFn.applyToHelper(AFn.java:163)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:542)
at clojure.core$update_in.doInvoke(core.clj:4959)
at clojure.lang.RestFn.invoke(RestFn.java:446)
at pallet.core$create_nodes.invoke(core.clj:836)
at pallet.core$adjust_node_count.invoke(core.clj:912)
at pallet.core$parallel_adjust_node_counts$p_a_n_c_future__5506$fn__5507.invoke(core.clj:1003)
at clojure.lang.AFn.call(AFn.java:18)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
DEBUG futures - Adjust node count exception
java.lang.IllegalArgumentException: No implementation of method: :ensure-os-family of protocol: #'pallet.compute/ComputeService found for class: nil
at clojure.core$_cache_protocol_fn.invoke(core_deftype.clj:471)
at pallet.compute$eval1063$fn__1092$G__1046__1099.invoke(compute.clj:49)
at pallet.core$create_nodes$fn__5444.invoke(core.clj:837)
at clojure.lang.AFn.applyToHelper(AFn.java:163)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:542)
at clojure.core$update_in.doInvoke(core.clj:4959)
at clojure.lang.RestFn.invoke(RestFn.java:446)
at pallet.core$create_nodes.invoke(core.clj:836)
at pallet.core$adjust_node_count.invoke(core.clj:912)
at pallet.core$parallel_adjust_node_counts$p_a_n_c_future__5506$fn__5507.invoke(core.clj:1003)
at clojure.lang.AFn.call(AFn.java:18)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
cluster.yaml:
################################################################################
CLUSTERS CONFIG FILE
################################################################################
nimbus.image: "us-east-1/ami-0747bdcabd34c712a" #64-bit ubuntu
nimbus.hardware: "t2.large"
supervisor.count: 2
supervisor.image: "us-east-1/ami-0747bdcabd34c712a" #64-bit ubuntu on eu-east-1
supervisor.hardware: "t2.large"
#supervisor.spot.price: 1.60
zookeeper.count: 1
zookeeper.image: "us-east-1/ami-0747bdcabd34c712a" #64-bit ubuntu
zookeeper.hardware: "t2.large"
config.clj: saved under /home/ec2-user/.pallet/
(defpallet
:services
{
:default {
:blobstore-provider "aws-s3"
:provider "aws-ec2"
:environment {:user {:username "storm" ; this must be "storm"
:private-key-path "
/.ssh/xxx.pem"/.ssh/xxx.pem.pub"}:public-key-path "
:aws-user-id "xxx"}
:identity "xxx"
:credential "xxx"
:jclouds.regions "us-east-1"
}
})