Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 3CC39200B44 for ; Thu, 14 Jul 2016 18:49:33 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 3BA98160A63; Thu, 14 Jul 2016 16:49:33 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 5F549160A60 for ; Thu, 14 Jul 2016 18:49:32 +0200 (CEST) Received: (qmail 47697 invoked by uid 500); 14 Jul 2016 16:49:31 -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 47687 invoked by uid 99); 14 Jul 2016 16:49:31 -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; Thu, 14 Jul 2016 16:49:31 +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 1059AC05EF for ; Thu, 14 Jul 2016 16:49:31 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.879 X-Spam-Level: * X-Spam-Status: No, score=1.879 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, 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-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 3MNVTfjBvLH0 for ; Thu, 14 Jul 2016 16:49:29 +0000 (UTC) Received: from mail-yw0-f173.google.com (mail-yw0-f173.google.com [209.85.161.173]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 8FE7D5FC34 for ; Thu, 14 Jul 2016 16:49:29 +0000 (UTC) Received: by mail-yw0-f173.google.com with SMTP id w127so78898290ywf.3 for ; Thu, 14 Jul 2016 09:49:29 -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; bh=+V6h/BWWbpLjMu84Oy0vdPEoqthZW9sw2fizmUhdc3E=; b=UM1wQYpwISv7OxlDS1ul68PQsrbKyK5XIRKwee6qPLQvp3/tCdvgX7SjEgvufu/95Y +dQDKe4S9LYLTy+e2gp6N76wKJ/NE6rydJ/dsHFo7m2Hq9Iy0TJHlojyUfhhmG71JN28 IEZhWjoyEymFg7VRI9brKBHbm5Y4TgCqTevjcDrwAADPvDYXOJiLps801sMaa+ORdLjE WikxZsVwDHaUy0GChREbT96OoGaHy41/N3ugpbMDYcMOCXJzDOCZTbdyaLsYQixLGNOT bk8Qdff6aS3ZQLfTWb+/QUJlo57HksFJ0yNV2NBXkEsRSsNPYKnmAGU0X51DJ8SyTxQX m83g== 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:from:date :message-id:subject:to; bh=+V6h/BWWbpLjMu84Oy0vdPEoqthZW9sw2fizmUhdc3E=; b=Su7Me0C9jZcF850M1PVzzXMXZRD602v9t+kLSMUzuK8b1RLoUis22c8WJKBzrERB4K 3Ie3Jer4dtnu4JxqKKhngN3D0aJKWKH7WQ4e4JVWcGIpDeI7e3Dt2ihBn1MlNgSfbnz0 8EQ6FfP1TkXAYmn9/wl9CiVSCFsRpRMikA41M2XABozlnhIzeXX+gtLeM2SiCyNS8XTG RIlML+pRnWQbx0y/a9g1aTTYJFSvitRvBCe1TIwbUsZKcjYoBn5idlwogUnai93XXlLc P7dGweQ4hTM+xgufMztoc/fQD9+pt0up2gF0OKv8SXJQMxi2U2nNuqZf4VPb3SJre1E6 uRTg== X-Gm-Message-State: ALyK8tKHctg631Ffcd65BDyi7++YOh1UAJgJacRQ9jnCEdnlYXhVu6bXsDoeYwv/cgaazrEoU5dP9YFntyfhTg== X-Received: by 10.37.47.147 with SMTP id v141mr10541914ybv.75.1468514968406; Thu, 14 Jul 2016 09:49:28 -0700 (PDT) MIME-Version: 1.0 Received: by 10.129.160.20 with HTTP; Thu, 14 Jul 2016 09:49:27 -0700 (PDT) In-Reply-To: References: From: "Chawla,Sumit " Date: Thu, 14 Jul 2016 09:49:27 -0700 Message-ID: Subject: Re: Ability to partition logs per pipeline To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a1140b4000a5c2705379b498b archived-at: Thu, 14 Jul 2016 16:49:33 -0000 --001a1140b4000a5c2705379b498b Content-Type: text/plain; charset=UTF-8 Hi Robert I actually mean both. Scenarios where multiple jobs are running on cluster, and same job could be running on multiple task managers. How can we make sure that each job logs to a different file so that Logs are not mixed, and its easy to debug a particular job. Something like Hadoop Yarn, where each attempt of a task produces a different log file. Regards Sumit Chawla On Thu, Jul 14, 2016 at 6:11 AM, Robert Metzger wrote: > Hi Sumit, > > What exactly do you mean by pipeline? > Are you talking about cases were multiple jobs are running concurrently on > the same TaskManager, or are you referring to parallel instances of a Flink > job? > > On Wed, Jul 13, 2016 at 9:49 PM, Chawla,Sumit > wrote: > >> Hi All >> >> Does flink provide any ability to streamline logs being generated from a >> pipeline. How can we keep the logs from two pipelines separate so that >> its easy to debug the pipeline execution (something dynamic to >> automatically partition the logs per pipeline) >> Regards >> Sumit Chawla >> >> > --001a1140b4000a5c2705379b498b Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi Robert

I actually mean both.=C2=A0 S= cenarios where multiple jobs are running on cluster, and same job could =C2= =A0be running on multiple task managers.=C2=A0 How can we make sure that ea= ch job logs to a different file so that Logs are not mixed, and its easy to= debug a particular job.=C2=A0 Something like Hadoop Yarn, where each attem= pt of a task produces a different log file.

Regards
Sumit Chawla


On Thu, Jul 14, 2016 at 6:11 AM, Robert Metz= ger <rmetzger@apache.org> wrote:
Hi Sumit,

What exactly do you = mean by pipeline?
Are you talking about cases were multiple jobs = are running concurrently on the same TaskManager, or are you referring to p= arallel instances of a Flink job?

On Wed,= Jul 13, 2016 at 9:49 PM, Chawla,Sumit <sumitkchawla@gmail.com>= ; wrote:

Hi All

Does flink provide any ability to stream= line logs being generated from a =C2=A0pipeline.=C2=A0 How can we keep the = logs from two pipelines separate so that its easy to debug the pipeline exe= cution (something dynamic to automatically partition the logs per pipeline)= =C2=A0

Regards=
Sumit Chawla



--001a1140b4000a5c2705379b498b--