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 98C38200CB4 for ; Tue, 27 Jun 2017 11:24:06 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 97918160BE9; Tue, 27 Jun 2017 09:24:06 +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 DE8F2160BDC for ; Tue, 27 Jun 2017 11:24:05 +0200 (CEST) Received: (qmail 24065 invoked by uid 500); 27 Jun 2017 09:24:05 -0000 Mailing-List: contact issues-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 issues@flink.apache.org Received: (qmail 24056 invoked by uid 99); 27 Jun 2017 09:24:05 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 27 Jun 2017 09:24:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id AD92918060B for ; Tue, 27 Jun 2017 09:24:04 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.02 X-Spam-Level: X-Spam-Status: No, score=-4.02 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id 1-HLkIYuK-G8 for ; Tue, 27 Jun 2017 09:24:04 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id EC6425FBC6 for ; Tue, 27 Jun 2017 09:24:02 +0000 (UTC) Received: (qmail 23722 invoked by uid 99); 27 Jun 2017 09:24:02 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 27 Jun 2017 09:24:02 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 0C2C3DFB0D; Tue, 27 Jun 2017 09:24:02 +0000 (UTC) From: zentol To: issues@flink.incubator.apache.org Reply-To: issues@flink.incubator.apache.org References: In-Reply-To: Subject: [GitHub] flink pull request #4168: [FLINK-6987] Fix erroneous when path containing sp... Content-Type: text/plain Message-Id: <20170627092402.0C2C3DFB0D@git1-us-west.apache.org> Date: Tue, 27 Jun 2017 09:24:02 +0000 (UTC) archived-at: Tue, 27 Jun 2017 09:24:06 -0000 Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4168#discussion_r124223192 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java --- @@ -461,8 +463,9 @@ public LocatableInputSplitAssigner getInputSplitAssigner(FileInputSplit[] splits // take the desired number of splits into account minNumSplits = Math.max(minNumSplits, this.numSplits); - - final Path path = this.filePath; + + final Path path = new Path(URLDecoder.decode(this.filePath.toString(), Charset.defaultCharset().name())); --- End diff -- That#s a problem of URI, not of the path class. URI#toString escapes certain characters (like spaces) but they aren't escaped internally. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastructure@apache.org or file a JIRA ticket with INFRA. ---