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 B957F186B4 for ; Mon, 14 Mar 2016 14:00:54 +0000 (UTC) Received: (qmail 52035 invoked by uid 500); 14 Mar 2016 14:00:54 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 51941 invoked by uid 500); 14 Mar 2016 14:00:54 -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 51931 invoked by uid 99); 14 Mar 2016 14:00:54 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 14 Mar 2016 14:00:54 +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 93913C0057 for ; Mon, 14 Mar 2016 14:00:53 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.28 X-Spam-Level: * X-Spam-Status: No, score=1.28 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=radicalbit-io.20150623.gappssmtp.com Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 0XSS5BW2VyoW for ; Mon, 14 Mar 2016 14:00:51 +0000 (UTC) Received: from mail-wm0-f53.google.com (mail-wm0-f53.google.com [74.125.82.53]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with ESMTPS id DA5325FB99 for ; Mon, 14 Mar 2016 14:00:50 +0000 (UTC) Received: by mail-wm0-f53.google.com with SMTP id n186so108920021wmn.1 for ; Mon, 14 Mar 2016 07:00:50 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=radicalbit-io.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:date:message-id:subject:from:to; bh=M5Kaol8z8//qtfaf1NGrOLMaDNZNSqWCI4+oTq0QY6E=; b=InmS/jr32m1I29gNAUy4LKGrNMkflzNK6OaHo3Px8I+u75LkY3ysrMcAGdsmPr3kha cclh+MY5ucueeKup8I4LSrgRt+emIccgvxQE16egn5ImnZnO8EQvA6SW5A5B4NmYD+J+ 8Fx3/698wZgqWE0wKdtFw9m+5YVTvXQHTTsZtvYjrsca5TqA0y2m2poaCHRlwgV1MLim BPKtBDeSgS5z+KBlt6uiwlLPkX7oeWjWqRQJ/nu7vzkSrA8jDYC5wM52f+Q6gqdDXWyW LYVAPkoXAMplrI0TTBh7Yt/IOYRo6pWsfLxRrRpAWBAB0w34EfTFOxi0Pl5fwxMor67I r9xg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:date :message-id:subject:from:to; bh=M5Kaol8z8//qtfaf1NGrOLMaDNZNSqWCI4+oTq0QY6E=; b=IfqCj+aYqq4CB4yz+L+Dufnw6GVEnljOSH8JWNG5hlMbMBKUoA6I3k03L0/1twQzv6 GInYtQKIR7AKQobxNDnXitZ9wbTvcVvpoEWIjv/2dI3/Z5uKGvkIHWNQsov+N8OdXixV Qx+4LzxhTCIBHGseyfi43qT/wlQFxyGvkvG7mODrLVgD19xjV304tn7mBXPorLJ7o7ge Nny7gbO4e6b1Ko5ZgmVhznmv40VpOcBGLd4cjz97nk1Mz6BucNYkq0UU9rMlDqHzb0VF g/K03B+zoK8Ybl21Dp6DXcRRcTGrD32y9Dv8Wb6GE8cNIi14h+XIYyBLROzZ9QiYTYco FREA== X-Gm-Message-State: AD7BkJJSXLO0xRTq4m7/RpjsD5VN0nln8P2VZ8pRrNuTGaGSuWu2Hg/3qmTBw39svhHapcH4lkFDn+OLmVyvcbp6 MIME-Version: 1.0 X-Received: by 10.194.116.9 with SMTP id js9mr28514576wjb.112.1457964050522; Mon, 14 Mar 2016 07:00:50 -0700 (PDT) Received: by 10.28.171.9 with HTTP; Mon, 14 Mar 2016 07:00:50 -0700 (PDT) In-Reply-To: References: Date: Mon, 14 Mar 2016 15:00:50 +0100 Message-ID: Subject: Re: Flink and YARN ship folder From: Andrea Sella To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a1130d21853bf3d052e02b5e4 --001a1130d21853bf3d052e02b5e4 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi Robert, Ok, thank you. 2016-03-14 11:13 GMT+01:00 Robert Metzger : > Hi Andrea, > > You don't have to manually replicate any operations on the slaves. All > files in the lib/ folder are transferred to all containers (Jobmanagers a= nd > TaskManagers). > > > On Sat, Mar 12, 2016 at 3:25 PM, Andrea Sella > wrote: > >> Hi Ufuk, >> >> I'm trying to execute the WordCount batch example with input and output >> on Alluxio, i followed Running Flink on Alluxio >> = and >> added the library to lib folder. Have I to replicate this operation on t= he >> slaves or YARN manage that and I must have the library just where I laun= ch >> the job? >> >> Thanks, >> Andrea >> >> 2016-03-11 19:23 GMT+01:00 Ufuk Celebi : >> >>> Everything in the lib folder should be added to the classpath. Can you >>> check the YARN client logs that the files are uploaded? Furthermore, >>> you can check the classpath of the JVM in the YARN logs of the >>> JobManager/TaskManager processes. >>> >>> =E2=80=93 Ufuk >>> >>> >>> On Fri, Mar 11, 2016 at 5:33 PM, Andrea Sella >>> wrote: >>> > Hi, >>> > >>> > There is a way to add external dependencies to Flink Job, running on >>> YARN, >>> > not using HADOOP_CLASSPATH? >>> > I am looking for a similar idea to standalone mode using lib folder. >>> > >>> > BR, >>> > Andrea >>> >> >> > --001a1130d21853bf3d052e02b5e4 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi Robert,

Ok, thank you.

2016-03-14 11:13 GMT+01:00 Robert= Metzger <rmetzger@apache.org>:
Hi Andrea,

You don't have t= o manually replicate any operations on the slaves. All files in the lib/ fo= lder are transferred to all containers (Jobmanagers and TaskManagers).


On Sat, Mar 12, 2016 at 3:25 P= M, Andrea Sella <andrea.sella@radicalbit.io> wrote:=
Hi Ufuk,

I'm= trying to execute the WordCount batch example with input and output on All= uxio, i followed=C2=A0Running Flink on Alluxio= =C2=A0and added the library to lib folder. Have I to replicate this operati= on on the slaves or YARN manage that and I must have the library just where= I launch the job?

Thanks,
Andrea

2016-03-11 19:23 GMT+01:00 Ufuk C= elebi <uce@apache.org>:
Every= thing in the lib folder should be added to the classpath. Can you
check the YARN client logs that the files are uploaded? Furthermore,
you can check the classpath of the JVM in the YARN logs of the
JobManager/TaskManager processes.

=E2=80=93 Ufuk


On Fri, Mar 11, 2016 at 5:33 PM, Andrea Sella
<andrea.= sella@radicalbit.io> wrote:
> Hi,
>
> There is a way to add external dependencies to Flink Job,=C2=A0 runnin= g on YARN,
> not using HADOOP_CLASSPATH?
> I am looking for a similar idea to standalone mode using lib folder. >
> BR,
> Andrea



--001a1130d21853bf3d052e02b5e4--