Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 0A3E719FAF for ; Wed, 13 Apr 2016 12:57:30 +0000 (UTC) Received: (qmail 34164 invoked by uid 500); 13 Apr 2016 12:57:29 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 34091 invoked by uid 500); 13 Apr 2016 12:57:29 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 34079 invoked by uid 99); 13 Apr 2016 12:57:29 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Apr 2016 12:57:29 +0000 Received: from mail-wm0-f51.google.com (mail-wm0-f51.google.com [74.125.82.51]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 1EBE31A031E for ; Wed, 13 Apr 2016 12:57:29 +0000 (UTC) Received: by mail-wm0-f51.google.com with SMTP id n3so76499419wmn.0 for ; Wed, 13 Apr 2016 05:57:29 -0700 (PDT) X-Gm-Message-State: AOPr4FV5ZDymV31pQZqH2g32Wtn5CI2Asx6JY0Le+HwGwYIsc2zRLtqsBXShwZcTapHuNtYnrUw9TzEJ+Y70SQ== MIME-Version: 1.0 X-Received: by 10.194.116.9 with SMTP id js9mr10856345wjb.112.1460552247680; Wed, 13 Apr 2016 05:57:27 -0700 (PDT) Received: by 10.194.234.67 with HTTP; Wed, 13 Apr 2016 05:57:27 -0700 (PDT) In-Reply-To: References: <570E3D00.7040608@apache.org> <1694482917.3656993.1460551240581.JavaMail.yahoo@mail.yahoo.com> Date: Wed, 13 Apr 2016 14:57:27 +0200 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Issue deploying a topology to flink with a java api From: Till Rohrmann To: dev@flink.apache.org, star jlong Content-Type: multipart/alternative; boundary=001a1130d218e65d7605305d51c4 --001a1130d218e65d7605305d51c4 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable I've updated the master. Could you check it out and run your program with the latest master? I would expect to see a ClassNotFoundException. On Wed, Apr 13, 2016 at 2:54 PM, Till Rohrmann wrote= : > Yes that is true. I'll commit a hotfix for that. > > My suspicion is that we use the wrong class loader in the > FlinkTopology.copyObject method to load the RandomSentenceSpout class. We > can see that once I removed the exception swallowing in the current maste= r. > > On Wed, Apr 13, 2016 at 2:40 PM, star jlong > wrote: > >> Hi Schepler, >> >> Thanks for the concerned. Yes I'm actaully having the same issue as >> indicated on that post because I'm the one that posted that issue. >> >> Le Mercredi 13 avril 2016 13h35, Chesnay Schepler >> a =C3=A9crit : >> >> >> >> http://stackoverflow.com/questions/36584784/issues-while-submitting-a-to= pology-to-apache-flink-using-the-flink-api >> >> On 13.04.2016 14:28, Till Rohrmann wrote: >> > Hi jstar, >> > >> > what's exactly the problem you're observing? >> > >> > Cheers, >> > Till >> > >> > On Wed, Apr 13, 2016 at 2:23 PM, star jlong > > >> > wrote: >> > >> >> Hi there, >> >> >> >> I'm jstar. I have been playing around with flink. I'm very much >> interested >> >> in submitting a topoloy to flink using its api. As indicated >> >> on stackoverflow, that is the try that I have given. But I was stuck >> with >> >> some exception. Please any help will be welcoming. >> >> >> >> >> >> Thanks. >> >> jstar >> >> >> >> >> > > --001a1130d218e65d7605305d51c4--