Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

SAM ( Streaming Analytics Manager ) Deploy Problem

SAM ( Streaming Analytics Manager ) Deploy Problem

New Contributor

Hi everybody :)

I'm new in SAM and try to deploy basic application. Application basically control flow temperature value and sent to anotker Kafka Queue if temperature is higher than 50 celcius. When I try to deploy application I'm getting error shown below. Does anyone get this error ? Or does anyone have idea about fixing this problem.

Thanks :)

Application Topology

KAFKA ( Source - M2MSDPLANT1 ) > Rule ( temperature >= 50 ) > KAFKA ( Sink - M2MSDPLANT1 )

/var/log/streamline/streamline.log file

ERROR [2018-07-30 10:53:20.694] [ForkJoinPool-4-worker-5] c.h.s.s.a.t.s.TopologyStates - Error while trying to deploy the topology in the streaming engine java.lang.Exception: Topology could not be deployed successfully: storm deploy command failed with Exception in thread "main" java.lang.IllegalArgumentException: Couldn't find a suitable constructor for class 'org.apache.storm.kafka.spout.KafkaSpoutConfig$Builder' with arguments '[hbizsl83.xxx.com:6667, [M2MSDPLANT2]]'. at com.hortonworks.streamline.streams.actions.storm.topology.StormTopologyActionsImpl.deploy(StormTopologyActionsImpl.java:276) at com.hortonworks.streamline.streams.actions.topology.state.TopologyStates$5.deploy(TopologyStates.java:123) at com.hortonworks.streamline.streams.actions.topology.state.TopologyContext.deploy(TopologyContext.java:87) at com.hortonworks.streamline.streams.actions.topology.service.TopologyActionsService.lambda$deployTopology$1(TopologyActionsService.java:123) at com.hortonworks.registries.storage.transaction.ManagedTransaction.lambda$executeConsumer$7(ManagedTransaction.java:165) at com.hortonworks.registries.storage.transaction.ManagedTransaction.executeTransactionBlockInternal(ManagedTransaction.java:243) at com.hortonworks.registries.storage.transaction.ManagedTransaction.executeConsumer(ManagedTransaction.java:164) at com.hortonworks.streamline.streams.actions.topology.service.TopologyActionsService.deployTopology(TopologyActionsService.java:121) at com.hortonworks.streamline.streams.service.TopologyActionResource.lambda$deploy$0(TopologyActionResource.java:161) at com.hortonworks.streamline.common.util.ParallelStreamUtil.lambda$runAsync$0(ParallelStreamUtil.java:56) at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) at java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1582) at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) ERROR [2018-07-30 10:53:20.694] [ForkJoinPool-4-worker-5] c.h.s.s.a.t.s.TopologyStates - Trying to kill any running instance of topology 'M2M_Sensor_Stream' ERROR [2018-07-30 10:53:20.707] [ForkJoinPool-4-worker-5] c.h.s.c.u.ParallelStreamUtil - Got exception while running async task java.lang.RuntimeException: java.lang.Exception: Topology could not be deployed successfully: storm deploy command failed with Exception in thread "main" java.lang.IllegalArgumentException: Couldn't find a suitable constructor for class 'org.apache.storm.kafka.spout.KafkaSpoutConfig$Builder' with arguments '[hbizsl83.xxx.com:6667, [M2MSDPLANT2]]'. at com.hortonworks.streamline.common.util.ParallelStreamUtil.lambda$runAsync$0(ParallelStreamUtil.java:58) at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) at java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1582) at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) Caused by: java.lang.Exception: Topology could not be deployed successfully: storm deploy command failed with Exception in thread "main" java.lang.IllegalArgumentException: Couldn't find a suitable constructor for class 'org.apache.storm.kafka.spout.KafkaSpoutConfig$Builder' with arguments '[hbizsl83.xxx.com:6667, [M2MSDPLANT2]]'. at com.hortonworks.streamline.streams.actions.storm.topology.StormTopologyActionsImpl.deploy(StormTopologyActionsImpl.java:276) at com.hortonworks.streamline.streams.actions.topology.state.TopologyStates$5.deploy(TopologyStates.java:123) at com.hortonworks.streamline.streams.actions.topology.state.TopologyContext.deploy(TopologyContext.java:87) at com.hortonworks.streamline.streams.actions.topology.service.TopologyActionsService.lambda$deployTopology$1(TopologyActionsService.java:123) at com.hortonworks.registries.storage.transaction.ManagedTransaction.lambda$executeConsumer$7(ManagedTransaction.java:165) at com.hortonworks.registries.storage.transaction.ManagedTransaction.executeTransactionBlockInternal(ManagedTransaction.java:243) at com.hortonworks.registries.storage.transaction.ManagedTransaction.executeConsumer(ManagedTransaction.java:164) at com.hortonworks.streamline.streams.actions.topology.service.TopologyActionsService.deployTopology(TopologyActionsService.java:121) at com.hortonworks.streamline.streams.service.TopologyActionResource.lambda$deploy$0(TopologyActionResource.java:161) at com.hortonworks.streamline.common.util.ParallelStreamUtil.lambda$runAsync$0(ParallelStreamUtil.java:56) ... 6 common frames omitted

Don't have an account?
Coming from Hortonworks? Activate your account here