Return-Path: X-Original-To: apmail-flume-user-archive@www.apache.org Delivered-To: apmail-flume-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 4433CD110 for ; Mon, 8 Oct 2012 06:16:17 +0000 (UTC) Received: (qmail 24564 invoked by uid 500); 8 Oct 2012 06:16:17 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 24414 invoked by uid 500); 8 Oct 2012 06:16:14 -0000 Mailing-List: contact user-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flume.apache.org Delivered-To: mailing list user@flume.apache.org Received: (qmail 24397 invoked by uid 99); 8 Oct 2012 06:16:14 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 08 Oct 2012 06:16:14 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of iainwrig@gmail.com designates 209.85.214.179 as permitted sender) Received: from [209.85.214.179] (HELO mail-ob0-f179.google.com) (209.85.214.179) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 08 Oct 2012 06:16:08 +0000 Received: by mail-ob0-f179.google.com with SMTP id lz20so3275788obb.38 for ; Sun, 07 Oct 2012 23:15:47 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :content-type; bh=InRxt1N5vbcq1aRsNLyIWxWrswAcwQE0XBF2avuUPkU=; b=RVXo/DchbbH2zVRo+CpT4oihv1nANBUnl4up3h01lUgnI4ch90H5bvzde9pRkAA2du 9KEdiVg6hStWOTLiVgqjOGXx5t9+Yumrth4pKeSOC2xa2ktRRzCFTh+jpp31AZVVR+lv 7+NE8fu6O33mDE9XDu52r4gTYqsqYaNSCc9nJRSwtz57J+/BGQdX45g6Hd+O0TJYeMGz VuUYyI7BBPWTvAj+qJEOYlgpsPmRYTMbF5L1ICak1AbbgYQXDb/3I23CpEKjHOlo1H7h Jc6CVJW/AN/uZIi6oSp2HOoXowd3rQMbnxWOt7MdK/b5xzRieztjf9xxJ1OwojV0P1sR 6BCw== Received: by 10.182.64.14 with SMTP id k14mr12530114obs.72.1349676947369; Sun, 07 Oct 2012 23:15:47 -0700 (PDT) MIME-Version: 1.0 Received: by 10.76.153.40 with HTTP; Sun, 7 Oct 2012 23:15:27 -0700 (PDT) In-Reply-To: References: From: iain wright Date: Sun, 7 Oct 2012 23:15:27 -0700 Message-ID: Subject: Re: Including Hbase dependencies To: user@flume.apache.org Content-Type: multipart/alternative; boundary=14dae93a18f9026e5e04cb8627e6 X-Virus-Checked: Checked by ClamAV on apache.org --14dae93a18f9026e5e04cb8627e6 Content-Type: text/plain; charset=ISO-8859-1 Thanks again Mike - HADOOP_HOME & HBASE_HOME in the env script did the trick. * Now we're getting stuck on the class for the serializer not being found, which i see present, I'm guessing its just another PATH im missing:* [ERROR - org.apache.flume.sink.hbase.HBaseSink.configure(HBaseSink.java:176)] Could not instantiate event serializer. java.lang.ClassNotFoundException: org.apache.flume.sink.hbase.SimpleHBaseEventSerializer at java.net.URLClassLoader$1.run(URLClassLoader.java:366) at java.net.URLClassLoader$1.run(URLClassLoader.java:355) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:354) at java.lang.ClassLoader.loadClass(ClassLoader.java:423) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) at java.lang.ClassLoader.loadClass(ClassLoader.java:356) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:186) at org.apache.flume.sink.hbase.HBaseSink.configure(HBaseSink.java:170) at org.apache.flume.conf.Configurables.configure(Configurables.java:41) at org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.loadSinks(PropertiesFileConfigurationProvider.java:373) at org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.load(PropertiesFileConfigurationProvider.java:223) at org.apache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(AbstractFileConfigurationProvider.java:123) at org.apache.flume.conf.file.AbstractFileConfigurationProvider.access$300(AbstractFileConfigurationProvider.java:38) at org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:202) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:722) *sink exists: * $/app/flume/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase]$ ls -lah total 58 drwxrwxrwx 2 root wheel 11B Oct 3 16:36 . drwxrwxrwx 3 root wheel 3B Oct 3 16:36 .. -rwxrwxrwx 1 root wheel 15k Oct 3 16:36 AsyncHBaseSink.java -rwxrwxrwx 1 root wheel 2.6k Oct 3 16:36 AsyncHbaseEventSerializer.java -rwxrwxrwx 1 root wheel 9.1k Oct 3 16:36 HBaseSink.java -rwxrwxrwx 1 root wheel 1.8k Oct 3 16:36 HBaseSinkConfigurationConstants.java -rwxrwxrwx 1 root wheel 2.2k Oct 3 16:36 HbaseEventSerializer.java -rwxrwxrwx 1 root wheel 5.9k Oct 3 16:36 RegexHbaseEventSerializer.java -rwxrwxrwx 1 root wheel 4.8k Oct 3 16:36 SimpleAsyncHbaseEventSerializer.java -rwxrwxrwx 1 root wheel 4.6k Oct 3 16:36 SimpleHbaseEventSerializer.java -rwxrwxrwx 1 root wheel 1.8k Oct 3 16:36 SimpleRowKeyGenerator.java * Startup used:* $/app/apache-flume-1.3.0-SNAPSHOT/bin/flume-ng agent -n agent1 -c ./conf -f conf/brian.properties -Dflume.root.logger=INFO,console *Relevant config:* $cat conf/brian.properties #example.conf: A single-node Flume configuration # Name the components on this agent agent1.sources = source1 agent1.sinks = sink1 agent1.channels = channel1 # Describe/configure source1 agent1.sources.source1.type = exec agent1.sources.source1.command = tail -F /log.log agent1.sources.source1.batchSize = 1 # Describe sink1 #agent1.sinks.sink1.type = logger agent1.sinks.sink1.type = org.apache.flume.sink.hbase.HBaseSink agent1.sinks.sink1.table = brian_test agent1.sinks.sink1.columnFamily = f1 agent1.sinks.sink1.serializer = org.apache.flume.sink.hbase.SimpleHBaseEventSerializer # Use a channel which buffers events in memory agent1.channels.channel1.type = memory agent1.channels.channel1.capacity = 1000 agent1.channels.channel1.transactionCapactiy = 100 # Bind the source and sink to the channel agent1.sources.source1.channels = channel1 agent1.sinks.sink1.channel = channel1 * flume-env.sh* $ cat flume-env.sh # Licensed to the Apache Software Foundation (ASF) under one # or more contributor license agreements. See the NOTICE file # distributed with this work for additional information # regarding copyright ownership. The ASF licenses this file # to you under the Apache License, Version 2.0 (the # "License"); you may not use this file except in compliance # with the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # If this file is placed at FLUME_CONF_DIR/flume-env.sh, it will be sourced # during Flume startup. # Enviroment variables can be set here. #JAVA_HOME=/usr/lib/jvm/java-6-sun # Give Flume more memory and pre-allocate, enable remote monitoring via JMX #JAVA_OPTS="-Xms100m -Xmx200m -Dcom.sun.management.jmxremote" # Note that the Flume conf directory is always included in the classpath. #FLUME_CLASSPATH="" HBASE_HOME="/app/hbase" HADOOP_HOME="/app/hadoop" I've tried copying the sink from /flume-ng-sinks/blah/blah/hbase-blah.sink to /app/flume/lib/ and setting my CLASSPATH & FLUME_CLASSPATH to /app/flume/lib but same result. Appreciate any help Cheers, -- Iain Wright This email message is confidential, intended only for the recipient(s) named above and may contain information that is privileged, exempt from disclosure under applicable law. If you are not the intended recipient, do not disclose or disseminate the message to anyone except the intended recipient. If you have received this message in error, or are not the named recipient(s), please immediately notify the sender by return email, and delete all copies of this message. On Sat, Oct 6, 2012 at 9:34 PM, Mike Percy wrote: > Iain, you have to set HBASE_HOME in flume-env.sh (which is in the Flume > conf directory) if Flume can't find the HBase classes. > > Regards, > Mike > > > On Fri, Oct 5, 2012 at 11:51 AM, iain wright wrote: > >> Hi guys, >> >> >> May someone please advise on the best way to include the Hbase depencies >> for a brand new install of flume, 1.3.0-SNAPSHOT? We are using HBase >> 0.94.0, r1332822. >> >> >> 2012-10-05 11:38:00,084 (conf-file-poller-0) [ERROR - >> org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:207)] >> Failed to start agent because dependencies were not found in classpath. >> Error follows. >> >> java.lang.NoClassDefFoundError: org/apache/hadoop/conf/Configuration >> >> at java.lang.Class.getDeclaredConstructors0(Native Method) >> >> at java.lang.Class.privateGetDeclaredConstructors(Class.java:2404) >> >> at java.lang.Class.getConstructor0(Class.java:2714) >> >> at java.lang.Class.newInstance0(Class.java:343) >> >> at java.lang.Class.newInstance(Class.java:325) >> >> at >> org.apache.flume.sink.DefaultSinkFactory.create(DefaultSinkFactory.java:103) >> >> at >> org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.loadSinks(PropertiesFileConfigurationProvider.java:371) >> >> at >> org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.load(PropertiesFileConfigurationProvider.java:223) >> >> at >> org.apache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(AbstractFileConfigurationProvider.java:123) >> >> at >> org.apache.flume.conf.file.AbstractFileConfigurationProvider.access$300(AbstractFileConfigurationProvider.java:38) >> >> at >> org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:202) >> >> at >> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) >> >> at >> java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351) >> >> at >> java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178) >> >> at >> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) >> >> at >> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) >> >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) >> >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) >> >> at java.lang.Thread.run(Thread.java:722) >> >> Caused by: java.lang.ClassNotFoundException: >> org.apache.hadoop.conf.Configuration >> >> at java.net.URLClassLoader$1.run(URLClassLoader.java:366) >> >> at java.net.URLClassLoader$1.run(URLClassLoader.java:355) >> >> at java.security.AccessController.doPrivileged(Native Method) >> >> at java.net.URLClassLoader.findClass(URLClassLoader.java:354) >> >> at java.lang.ClassLoader.loadClass(ClassLoader.java:423) >> >> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) >> >> at java.lang.ClassLoader.loadClass(ClassLoader.java:356) >> ... 19 more >> >> Thank you, >> >> -- >> Iain Wright >> >> >> This email message is confidential, intended only for the recipient(s) >> named above and may contain information that is privileged, exempt from >> disclosure under applicable law. If you are not the intended recipient, do >> not disclose or disseminate the message to anyone except the intended >> recipient. If you have received this message in error, or are not the named >> recipient(s), please immediately notify the sender by return email, and >> delete all copies of this message. >> > > --14dae93a18f9026e5e04cb8627e6 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Thanks again Mike -

HADOOP_HOME & HBASE_HOME in the env script d= id the trick.

Now we're getting stuck on the class for the s= erializer not being found, which i see present, I'm guessing its just a= nother PATH im missing:
[ERROR - org.apache.flume.sink.hbase.HBaseS= ink.configure(HBaseSink.java:176)] Could not instantiate event serializer.<= br>java.lang.ClassNotFoundException: org.apache.flume.sink.hbase.SimpleHBas= eEventSerializer
=A0=A0=A0 at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
=A0= =A0=A0 at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
=A0=A0= =A0 at java.security.AccessController.doPrivileged(Native Method)
=A0=A0= =A0 at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
=A0=A0=A0 at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
=A0= =A0=A0 at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
= =A0=A0=A0 at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
=A0= =A0=A0 at java.lang.Class.forName0(Native Method)
=A0=A0=A0 at java.lang.Class.forName(Class.java:186)
=A0=A0=A0 at org.ap= ache.flume.sink.hbase.HBaseSink.configure(HBaseSink.java:170)
=A0=A0=A0 = at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
= =A0=A0=A0 at org.apache.flume.conf.properties.PropertiesFileConfigurationPr= ovider.loadSinks(PropertiesFileConfigurationProvider.java:373)
=A0=A0=A0 at org.apache.flume.conf.properties.PropertiesFileConfigurationPr= ovider.load(PropertiesFileConfigurationProvider.java:223)
=A0=A0=A0 at o= rg.apache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(Abstract= FileConfigurationProvider.java:123)
=A0=A0=A0 at org.apache.flume.conf.file.AbstractFileConfigurationProvider.a= ccess$300(AbstractFileConfigurationProvider.java:38)
=A0=A0=A0 at org.ap= ache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.= run(AbstractFileConfigurationProvider.java:202)
=A0=A0=A0 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.= java:471)
=A0=A0=A0 at java.util.concurrent.FutureTask$Sync.innerRunAndR= eset(FutureTask.java:351)
=A0=A0=A0 at java.util.concurrent.FutureTask.r= unAndReset(FutureTask.java:178)
=A0=A0=A0 at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutu= reTask.access$301(ScheduledThreadPoolExecutor.java:178)
=A0=A0=A0 at jav= a.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Sched= uledThreadPoolExecutor.java:293)
=A0=A0=A0 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolEx= ecutor.java:1110)
=A0=A0=A0 at java.util.concurrent.ThreadPoolExecutor$W= orker.run(ThreadPoolExecutor.java:603)
=A0=A0=A0 at java.lang.Thread.run= (Thread.java:722)

sink exists:

$/app/= flume/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sin= k/hbase]$ ls -lah
total 58
drwxrwxrwx=A0 2 root=A0 wheel=A0=A0=A0 11B= Oct=A0 3 16:36 .
drwxrwxrwx=A0 3 root=A0 wheel=A0=A0=A0=A0 3B Oct=A0 3 16:36 ..
-rwxrwxrw= x=A0 1 root=A0 wheel=A0=A0=A0 15k Oct=A0 3 16:36 AsyncHBaseSink.java
-rw= xrwxrwx=A0 1 root=A0 wheel=A0=A0 2.6k Oct=A0 3 16:36 AsyncHbaseEventSeriali= zer.java
-rwxrwxrwx=A0 1 root=A0 wheel=A0=A0 9.1k Oct=A0 3 16:36 HBaseSi= nk.java
-rwxrwxrwx=A0 1 root=A0 wheel=A0=A0 1.8k Oct=A0 3 16:36 HBaseSinkConfigurat= ionConstants.java
-rwxrwxrwx=A0 1 root=A0 wheel=A0=A0 2.2k Oct=A0 3 16:3= 6 HbaseEventSerializer.java
-rwxrwxrwx=A0 1 root=A0 wheel=A0=A0 5.9k Oct= =A0 3 16:36 RegexHbaseEventSerializer.java
-rwxrwxrwx=A0 1 root=A0 wheel=A0=A0 4.8k Oct=A0 3 16:36 SimpleAsyncHbaseEve= ntSerializer.java
-rwxrwxrwx=A0 1 root=A0 wheel=A0=A0 4.6k Oct=A0 3 16:3= 6 SimpleHbaseEventSerializer.java
-rwxrwxrwx=A0 1 root=A0 wheel=A0=A0 1.= 8k Oct=A0 3 16:36 SimpleRowKeyGenerator.java


Startup used:
=A0$/= app/apache-flume-1.3.0-SNAPSHOT/bin/flume-ng agent -n agent1 -c ./conf -f c= onf/brian.properties=A0 -Dflume.root.logger=3DINFO,console

= Relevant config:
=A0$cat conf/brian.properties
#example.= conf: A single-node Flume configuration

# Name the components on thi= s agent
agent1.sources =3D source1
agent1.sinks =3D sink1
agent1.c= hannels =3D channel1

# Describe/configure source1
agent1.sources.source1.type =3D exec agent1.sources.source1.command =3D tail -F /log.log
agent1.sources.sou= rce1.batchSize =3D 1
# Describe sink1
#agent1.sinks.sink1.type =3D lo= gger
agent1.sinks.sink1.type =3D org.apache.flume.sink.hbase.HBaseSink
agent1= .sinks.sink1.table =3D brian_test
agent1.sinks.sink1.columnFamily =3D f1=
agent1.sinks.sink1.serializer =3D org.apache.flume.sink.hbase.SimpleHB= aseEventSerializer


# Use a channel which buffers events in memory
agent1.channels.c= hannel1.type =3D memory
agent1.channels.channel1.capacity =3D 1000
ag= ent1.channels.channel1.transactionCapactiy =3D 100

# Bind the source= and sink to the channel
agent1.sources.source1.channels =3D channel1
agent1.sinks.sink1.channel = =3D channel1

flume-env.sh

$ cat flume-env.sh

# Licensed to the Apache Software Found= ation (ASF) under one
# or more contributor license agreements.=A0 See the NOTICE file
# distr= ibuted with this work for additional information
# regarding copyright o= wnership.=A0 The ASF licenses this file
# to you under the Apache Licens= e, Version 2.0 (the
# "License"); you may not use this file except in compliance
#= with the License.=A0 You may obtain a copy of the License at
#
#=A0= =A0=A0=A0 http://www= .apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software<= br># distributed under the License is distributed on an "AS IS" B= ASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or = implied.
# See the License for the specific language governing permissions and
# = limitations under the License.

# If this file is placed at FLUME_CON= F_DIR/flume-env.sh, it will be sourced
# during Flume startup.

# Enviroment variables can be set here.

#JAVA_HOME=3D/usr/lib/jvm/ja= va-6-sun

# Give Flume more memory and pre-allocate, enable remote mo= nitoring via JMX
#JAVA_OPTS=3D"-Xms100m -Xmx200m -Dcom.sun.manageme= nt.jmxremote"

# Note that the Flume conf directory is always included in the classpat= h.
#FLUME_CLASSPATH=3D""

HBASE_HOME=3D"/app/hbase&= quot;

HADOOP_HOME=3D"/app/hadoop"

I've tr= ied copying the sink from /flume-ng-sinks/blah/blah/hbase-blah.sink to /app= /flume/lib/ and setting my CLASSPATH & FLUME_CLASSPATH to /app/flume/li= b but same result.

Appreciate any help

Cheers,

--
Iain Wright


This email messa= ge is confidential, intended only for the recipient(s) named above and may = contain information that is privileged, exempt from disclosure under applic= able law. If you are not the intended recipient, do not disclose or dissemi= nate the message to anyone except the intended recipient. If you have recei= ved this message in error, or are not the named recipient(s), please immedi= ately notify the sender by return email, and delete all copies of this mess= age.


On Sat, Oct 6, 2012 at 9:34 PM, Mike Per= cy <mpercy@apache.org> wrote:
Iain, you have to set HBASE_HOME in flume-env.sh (which is in the Flume con= f directory) if Flume can't find the HBase classes.

= Regards,
Mike


On Fri, Oct 5, 2012 at 11:51 AM, iain wright= <iainwrig@gmail.com> wrote:

Hi guys,


May someone please advise on the best way to include the= Hbase depencies for a brand new install of flume, 1.3.0-SNAPSHOT? We are u= sing HBase 0.94.0, r1332822.


2012-10-05 11:38:00,084 (conf-file-poller-0) [ERROR -=20 org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRun= nable.run(AbstractFileConfigurationProvider.java:207)] Failed to start agent because dependencies were not found in classpath. Error follows.

java.lang.NoClassDefFound= Error: org/apache/hadoop/conf/Configuration

=A0=A0=A0=A0=A0=A0=A0 at = java.lang.Class.getDeclaredConstructors0(Native Method)

=A0=A0=A0=A0=A0=A0=A0 at = java.lang.Class.privateGetDeclaredConstructors(Class.java:2404)

=A0=A0=A0=A0=A0=A0=A0 at = java.lang.Class.getConstructor0(Class.java:2714)

=A0=A0=A0=A0=A0=A0=A0 at = java.lang.Class.newInstance0(Class.java:343)

=A0=A0=A0=A0=A0=A0=A0 at = java.lang.Class.newInstance(Class.java:325)

=A0=A0=A0=A0=A0=A0=A0 at = org.apache.flume.sink.DefaultSinkFactory.create(DefaultSinkFactory.java:103= )

=A0=A0=A0=A0=A0=A0=A0 at= =20 org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.loadSi= nks(PropertiesFileConfigurationProvider.java:371)

=A0=A0=A0=A0=A0=A0=A0 at= =20 org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.load(P= ropertiesFileConfigurationProvider.java:223)

=A0=A0=A0=A0=A0=A0=A0 at = org.apache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(Abstrac= tFileConfigurationProvider.java:123)

=A0=A0=A0=A0=A0=A0=A0 at = org.apache.flume.conf.file.AbstractFileConfigurationProvider.access$300(Abs= tractFileConfigurationProvider.java:38)

=A0=A0=A0=A0=A0=A0=A0 at= =20 org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRun= nable.run(AbstractFileConfigurationProvider.java:202)

=A0=A0=A0=A0=A0=A0=A0 at = java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)

=A0=A0=A0=A0=A0=A0=A0 at = java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351)<= /p>

=A0=A0=A0=A0=A0=A0=A0 at = java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178)

=A0=A0=A0=A0=A0=A0=A0 at = java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access= $301(ScheduledThreadPoolExecutor.java:178)

=A0=A0=A0=A0=A0=A0=A0 at = java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Sc= heduledThreadPoolExecutor.java:293)

=A0=A0=A0=A0=A0=A0=A0 at = java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1= 110)

=A0=A0=A0=A0=A0=A0=A0 at = java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:= 603)

=A0=A0=A0=A0=A0=A0=A0 at = java.lang.Thread.run(Thread.java:722)

Caused by: java.lang.Clas= sNotFoundException: org.apache.hadoop.conf.Configuration

=A0=A0=A0=A0=A0=A0=A0 at = java.net.URLClassLoader$1.run(URLClassLoader.java:366)

=A0=A0=A0=A0=A0=A0=A0 at = java.net.URLClassLoader$1.run(URLClassLoader.java:355)

=A0=A0=A0=A0=A0=A0=A0 at = java.security.AccessController.doPrivileged(Native Method)

=A0=A0=A0=A0=A0=A0=A0 at = java.net.URLClassLoader.findClass(URLClassLoader.java:354)

=A0=A0=A0=A0=A0=A0=A0 at = java.lang.ClassLoader.loadClass(ClassLoader.java:423)

=A0=A0=A0=A0=A0=A0=A0 at = sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)

=A0=A0=A0=A0=A0=A0=A0 at = java.lang.ClassLoader.loadClass(ClassLoader.java:356)

=A0=A0=A0=A0=A0=A0=A0 ... 19 more

Thank you,

--
Iain Wright

This email message i= s confidential, intended only for the recipient(s) named above and may cont= ain information that is privileged, exempt from disclosure under applicable= law. If you are not the intended recipient, do not disclose or disseminate= the message to anyone except the intended recipient. If you have received = this message in error, or are not the named recipient(s), please immediatel= y notify the sender by return email, and delete all copies of this message.=


--14dae93a18f9026e5e04cb8627e6--