Return-Path: X-Original-To: apmail-nifi-users-archive@minotaur.apache.org Delivered-To: apmail-nifi-users-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 4F07418BC6 for ; Wed, 7 Oct 2015 06:50:32 +0000 (UTC) Received: (qmail 11568 invoked by uid 500); 7 Oct 2015 06:50:32 -0000 Delivered-To: apmail-nifi-users-archive@nifi.apache.org Received: (qmail 11538 invoked by uid 500); 7 Oct 2015 06:50:32 -0000 Mailing-List: contact users-help@nifi.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@nifi.apache.org Delivered-To: mailing list users@nifi.apache.org Received: (qmail 11528 invoked by uid 99); 7 Oct 2015 06:50:32 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Oct 2015 06:50:32 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id A22A7C0419 for ; Wed, 7 Oct 2015 06:50:31 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.129 X-Spam-Level: *** X-Spam-Status: No, score=3.129 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-us-west.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id hqeteCB3t0Rj for ; Wed, 7 Oct 2015 06:50:30 +0000 (UTC) Received: from mail-yk0-f177.google.com (mail-yk0-f177.google.com [209.85.160.177]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with ESMTPS id 488EB20756 for ; Wed, 7 Oct 2015 06:50:30 +0000 (UTC) Received: by ykba192 with SMTP id a192so4124626ykb.3 for ; Tue, 06 Oct 2015 23:50:23 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=vMo/3SJ3qiRNzJaVkN+4CiqxhbijOw3mZCPYqe+d8mg=; b=KHvbsoFFkE4cr9kESLxM0aS29p4uVidPu/TuUU8EqT4Pxannlua02zUeg6oUGU3oCp 7Q6ZT+midReqNIHT+dh+huQdALCpvvhaBC8gyZDqW0zS7FkXI0RgDzDnHsmUCxKsWAFr sD8zYT4BRtXOP/QZh2cZZMiqQyg5+lHKB/A0nHmV8WD8G7j/+CA7gFuy5X1IIyL2Q5+r 086jgYAA/HUuwB1tWVCCgLr7arA4aZRDJisfUZFX6sho81DkIP1QE2KHBCvR6tNVA0w8 bXp5c4ukClJzly2axgdRIZvQOSC6QL/7gJidlox+OeeTSJ/22+jJotlmRHxmgp7sP2w5 INGQ== MIME-Version: 1.0 X-Received: by 10.129.147.134 with SMTP id k128mr4733431ywg.307.1444200623581; Tue, 06 Oct 2015 23:50:23 -0700 (PDT) Received: by 10.129.46.193 with HTTP; Tue, 6 Oct 2015 23:50:23 -0700 (PDT) Date: Wed, 7 Oct 2015 12:20:23 +0530 Message-ID: Subject: Need help in nifi- flume processor From: Parul Agrawal To: users@nifi.apache.org Content-Type: multipart/alternative; boundary=94eb2c07d2b02734b305217e29e6 --94eb2c07d2b02734b305217e29e6 Content-Type: text/plain; charset=UTF-8 Hi, I was trying to run Nifi Flume processor with the below mentioned details but not could bring it up. I already started flume with the sample configuration file ============================================= # example.conf: A single-node Flume configuration # Name the components on this agent a1.sources = r1 a1.sinks = k1 a1.channels = c1 # Describe/configure the source a1.sources.r1.type = netcat a1.sources.r1.bind = localhost a1.sources.r1.port = 44444 # Describe the sink a1.sinks.k1.type = logger # Use a channel which buffers events in memory a1.channels.c1.type = memory a1.channels.c1.capacity = 1000 a1.channels.c1.transactionCapacity = 100 # Bind the source and sink to the channel a1.sources.r1.channels = c1 a1.sinks.k1.channel = c1 ============================================= Command used to start flume : $ bin/flume-ng agent --conf conf --conf-file example.conf --name a1 -Dflume.root.logger=INFO,console In the Nifi browser of ExecuteFlumeSink following configuration was done: Property Value Sink Type logger Agent Name a1 Sink Name k1. Event is sent to the flume using: $ telnet localhost 44444 Trying 127.0.0.1... Connected to localhost.localdomain (127.0.0.1). Escape character is '^]'. Hello world! OK But I could not get any data in the nifi flume processor. Request your help in this. Do i need to change the example.conf file of flume so that Nifi Flume Sink should get the data. Thanks and Regards, Parul --94eb2c07d2b02734b305217e29e6 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,

I was trying to run Nifi Flume processor with the below mentioned
details b= ut not could bring it up.

I already started flume= with the sample configuration file
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
# example.conf: A si= ngle-node Flume configuration

# Name the componen= ts on this agent
a1.sources =3D r1
a1.sinks =3D k1
a1.channels =3D c1

# Describe/configure the source
= a1.sources.r1.type =3D netcat
a1.sources.r1.bin= d =3D localhost
a1.sources.r1.port =3D 44444

# Describ= e the sink
a1.sinks.k1.type =3D logger

# Use a channel= which buffers events in memory
a1.channels.c1.type =3D memory
a1.channels.c1.capac= ity =3D 1000
a1.channels.c1.transactionC= apacity =3D 100

# Bind the source and sink to the= channel
a1.sources.r1.channels =3D c1
a1.sinks.k1.channel =3D c1
=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D

Command used to start flume : $ bin/flume-ng = agent --conf conf
--conf-file example.conf --name a1 -Dflume.root.logger=3DINFO,= console

I= n the Nifi browser of ExecuteFlumeSink following configuration was done:
Propert= y=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0Value
Sink Type=C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0logger
Agent Name=C2=A0 =C2=A0 =C2=A0 a1
Sink Name=C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0k1.

Event is sent to the flume using= :
$ t= elnet localhost 44444
Trying 127.0.0.1...
<= span style=3D"font-size:12.8px">Connected to localhost.localdomain (127.0.0= .1).
= Escape character is '^]'.
Hello world! <ENTER>
OK

But I could not get any data in the nifi flume processor. Request your=
help= in this.
Do i need to change the example.conf file of flume so that Nifi Flume<= /span>
Sink = should get the data.

Thanks and Regards,Parul<= br>
--94eb2c07d2b02734b305217e29e6--