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

Unable Start Flume


Unable Start Flume

I have added flume service to my cluster and I have changed agent configurations as follows


tier1.sources = r1
tier1.channels = k1
tier1.sinks = c1
tier1.sources.r1.type = exec
tier1.sources.r1.command = /usr/local/bin/machinedata
tier1.channels.k1.type = file
tier1.channels.k1.transactionCapacity = 1000000
tier1.channels.k1.checkpointInterval = 100000
tier1.channels.k1.capacity = 10000000
tier1.sinks.c1.type = hdfs
tier1.sinks.c1.hdfs.path = hdfs:/data/incoming
tier1.sinks.c1.hdfs.filePrefix = machinedata
tier1.sinks.c1.hdfs.rollCount = 0
tier1.sinks.c1.hdfs.roliInterval 30
tier1.sinks.c1.hdfs.rollSize = 4000000
tier1.sinks.c1.hdfs.batchSize = 10000
tier1.sinks.c1.hdfs.useLocalTimeStamp = true
tier1.sinks.c1.hdfs.minBlockReplicas = 1
tier1.sources.r1.channels = k1 = k1

When I start flume agent I was uanble to start showing following error in log file


3:59:10.514 PM ERROR NetcatSource
Unable to bind to socket. Exception follows. Address already in use
	at Method)
	at org.apache.flume.source.NetcatSource.start(
	at org.apache.flume.source.EventDrivenSourceRunner.start(
	at org.apache.flume.lifecycle.LifecycleSupervisor$
	at java.util.concurrent.Executors$
	at java.util.concurrent.FutureTask.runAndReset(
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(
	at java.util.concurrent.ScheduledThreadPoolExecutor$
	at java.util.concurrent.ThreadPoolExecutor.runWorker(
	at java.util.concurrent.ThreadPoolExecutor$
3:59:10.515 PM INFO NetcatSource
Source stopping


I was saying that the address is already  is in use

Can you give me solution?

Thanks & Regards


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