From user-return-20405-archive-asf-public=cust-asf.ponee.io@flink.apache.org Tue Jun 5 17:32:52 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 0E618180625 for ; Tue, 5 Jun 2018 17:32:51 +0200 (CEST) Received: (qmail 51524 invoked by uid 500); 5 Jun 2018 15:32:50 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 51514 invoked by uid 99); 5 Jun 2018 15:32:50 -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; Tue, 05 Jun 2018 15:32:50 +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 69E1CC0101 for ; Tue, 5 Jun 2018 15:32:50 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.485 X-Spam-Level: *** X-Spam-Status: No, score=3.485 tagged_above=-999 required=6.31 tests=[DKIM_ADSP_CUSTOM_MED=0.001, NML_ADSP_CUSTOM_MED=1.2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_HELO_PASS=-0.001, SPF_SOFTFAIL=0.972, URI_HEX=1.313] autolearn=disabled Received: from mx1-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 LobYUbsNztIr for ; Tue, 5 Jun 2018 15:32:47 +0000 (UTC) Received: from n4.nabble.com (n4.nabble.com [162.253.133.72]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 452A65F1EE for ; Tue, 5 Jun 2018 15:32:47 +0000 (UTC) Received: from mben.nabble.com (localhost [127.0.0.1]) by n4.nabble.com (Postfix) with ESMTP id DDEA91B652971 for ; Tue, 5 Jun 2018 08:32:44 -0700 (MST) Date: Tue, 5 Jun 2018 08:32:44 -0700 (MST) From: rakeshchalasani To: user@flink.apache.org Message-ID: <1528212764906-0.post@n4.nabble.com> In-Reply-To: <9ce10ddc-af07-c4de-7a3a-eb3b631e7f0d@apache.org> References: <1528145259526-0.post@n4.nabble.com> <9ce10ddc-af07-c4de-7a3a-eb3b631e7f0d@apache.org> Subject: Re: Cannot determine simple type name - [FLINK-7490] MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit Thanks for the response, the issue does look similar to FLINK-9220. The code is part of our application, so I have to come up with an example. But following are the steps that will likely reproduce the issue. 1. Define UDF in module, say in com.udf 2. Create a topology using the above UDF in another module, say in org.test, and start execution in org.test. That should reproduce the issue. Please also note that I have only tested this using Local environment. May be diverging from this issue, but to work around this, I refactored my code to put the UDF in the same module but still have some reference to another module. This didn't work locally either, but worked on the cluster. Looking at the code, user class loader is using the path from the jar as well, which is able to resolve package on the cluster, but locally it is not able to get those class paths. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/