Tukukkk

I am trying to deploy my samza job in yarn cluster but getting following error:

Logs:

2018-11-11 04:59:53,110 INFO [AsyncDispatcher event handler] rmapp.RMAppImpl (RMAppImpl.java:transition(1369)) - The number of failed attempts is 2. The max attempts is 2


2018-11-11 04:59:53,110 INFO [AsyncDispatcher event handler] rmapp.RMAppImpl (RMAppImpl.java:rememberTargetTransitionsAndStoreState(1136)) - Updating application application_1541910009112_0003 with final state: FAILED


2018-11-11 04:59:53,146 INFO [AsyncDispatcher event handler] recovery.RMStateStore (RMStateStore.java:transition(239)) - Updating info for app: application_1541910009112_0003


2018-11-11 04:59:53,147 INFO [AsyncDispatcher event handler] rmapp.RMAppImpl (RMAppImpl.java:handle(815)) - application_1541910009112_0003 State change from ACCEPTED to FINAL_SAVING on event=ATTEMPT_FAILED


2018-11-11 04:59:53,147 INFO [AsyncDispatcher event handler] rmapp.RMAppImpl (RMAppImpl.java:transition(1076)) - Application application_1541910009112_0003 failed 2 times due to AM Container for appattempt_1541910009112_0003_000002 exited with exitCode: -1000

Error Details:

Failing this attempt.Diagnostics: org/apache/commons/httpclient/HttpMethod

java.lang.NoClassDefFoundError: org/apache/commons/httpclient/HttpMethod

at java.lang.Class.forName0(Native Method)

at java.lang.Class.forName(Class.java:348)

at org.apache.hadoop.conf.Configuration.getClassByNameOrNull(Configuration.java:2306)

at org.apache.hadoop.conf.Configuration.getClassByName(Configuration.java:2271)

at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2367)

at org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2793)

I can see commons-httpclient-3.1.jar packaged inside samzajobs-0.0.1-SNAPSHOT-dist.tar.gz

This is the source code of the samza job :

package jobs.samzajobs;



import org.apache.samza.config.Config;

import org.apache.samza.system.IncomingMessageEnvelope;

import org.apache.samza.task.InitableTask;

import org.apache.samza.task.MessageCollector;

import org.apache.samza.task.StreamTask;

import org.apache.samza.task.TaskContext;

import org.apache.samza.task.TaskCoordinator;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;



public class TestJob implements StreamTask,InitableTask{

    private static final Logger logger = LoggerFactory.getLogger(TestJob.class);



    public void process(IncomingMessageEnvelope envelope, MessageCollector collector, TaskCoordinator coordinator)

            throws Exception {

       logger.debug("inside process....");

    }



    public void init(Config config, TaskContext context) throws Exception {

        logger.debug("initializing task..");

    }



}

Can someone please tell, what could be wrong with the deployment?