Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 24EB117894 for ; Tue, 24 Feb 2015 10:22:14 +0000 (UTC) Received: (qmail 67365 invoked by uid 500); 24 Feb 2015 10:22:11 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 67293 invoked by uid 500); 24 Feb 2015 10:22:11 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 67284 invoked by uid 99); 24 Feb 2015 10:22:11 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 24 Feb 2015 10:22:11 +0000 Received: from mail-lb0-f178.google.com (mail-lb0-f178.google.com [209.85.217.178]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 593C61A0421 for ; Tue, 24 Feb 2015 10:22:10 +0000 (UTC) Received: by lbiw7 with SMTP id w7so23928548lbi.9 for ; Tue, 24 Feb 2015 02:22:08 -0800 (PST) X-Received: by 10.152.245.38 with SMTP id xl6mr13775246lac.68.1424773328745; Tue, 24 Feb 2015 02:22:08 -0800 (PST) MIME-Version: 1.0 Received: by 10.25.155.129 with HTTP; Tue, 24 Feb 2015 02:21:48 -0800 (PST) In-Reply-To: References: From: =?UTF-8?Q?M=C3=A1rton_Balassi?= Date: Tue, 24 Feb 2015 11:21:48 +0100 Message-ID: Subject: Re: HDFS Clustering To: user@flink.apache.org, giacomo.licari@gmail.com Content-Type: multipart/alternative; boundary=001a113459f6253ba7050fd2e4ee --001a113459f6253ba7050fd2e4ee Content-Type: text/plain; charset=UTF-8 Hey, Just add the the right prefix pointing to your hdfs filepath: bin/flink run -v flink-java-examples-*-WordCount.jar hdfs://hostname:port/PATH/TO/INPUT hdfs://hostname:port/PATH/TO/OUTPUT Best, Marton On Tue, Feb 24, 2015 at 11:13 AM, Giacomo Licari wrote: > Hi guys, > I'm Giacomo from Italy, I'm newbie with Flink. > > I setted up a cluster with Hadoop 1.2 and Flink. > > I would like to ask to you how to run the WordCount example taking the > input file from hdfs (example myuser/testWordCount/hamlet. > txt) and put the output also inside hdfs (example > myuser/testWordCount/output.txt). > > I successfully run the example on my local filesystem, I would like to > test it with HDSF. > > Thanks a lot guys, > Giacomo > --001a113459f6253ba7050fd2e4ee Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable

Hey,

Just add the the right prefix poin= ting to your hdfs filepath:

bin/flink run -v flink= -java-examples-*-WordCount.jar hdfs://hostname:port/PATH/TO/INPUT hdfs://ho= stname:port/PATH/TO/OUTPUT

Best,

Marton

On Tue, Feb 24, 2015 at 11:13 AM, Giacomo Licari <giacomo.= licari@gmail.com> wrote:

Hi guys,
I'm Giacomo from Italy, I'm newbie with = Flink.

I setted up a cluster with Hadoop 1.2 and Flink.

I would like to ask to you how to run the WordCount example taking the=20 input file from hdfs (example myuser/testWordCount/hamlet.
= txt) and put the output also inside hdfs (example myuser/testWordCount/outp= ut.txt).

I successfully run the example on my local filesystem, I wo= uld like to test it with HDSF.

Thanks a lot guys,
Giacomo

--001a113459f6253ba7050fd2e4ee--