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 679BD200CDC for ; Sat, 22 Jul 2017 16:10:07 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 6644616501D; Sat, 22 Jul 2017 14:10:07 +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 AC033165018 for ; Sat, 22 Jul 2017 16:10:06 +0200 (CEST) Received: (qmail 69060 invoked by uid 500); 22 Jul 2017 14:10:04 -0000 Mailing-List: contact reviews-help@spark.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list reviews@spark.apache.org Received: (qmail 69049 invoked by uid 99); 22 Jul 2017 14:10:04 -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; Sat, 22 Jul 2017 14:10:04 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id ECCFCE5E44; Sat, 22 Jul 2017 14:10:03 +0000 (UTC) From: viirya To: reviews@spark.apache.org Reply-To: reviews@spark.apache.org References: In-Reply-To: Subject: [GitHub] spark issue #18687: [SPARK-21484][SQL] Fix inconsistent query plans of Datas... Content-Type: text/plain Message-Id: <20170722141003.ECCFCE5E44@git1-us-west.apache.org> Date: Sat, 22 Jul 2017 14:10:03 +0000 (UTC) archived-at: Sat, 22 Jul 2017 14:10:07 -0000 Github user viirya commented on the issue: https://github.com/apache/spark/pull/18687 There is another case we should fix. You can see the storage level of ds2 is StorageLevel.NONE, but its executed plan is still cached version. scala> Seq("1", "2").toDF().write.saveAsTable("t") scala> val ds1 = spark.table("t") ds1: org.apache.spark.sql.DataFrame = [value: string] scala> val ds2 = spark.table("t") ds2: org.apache.spark.sql.DataFrame = [value: string] scala> ds1.persist() res1: ds1.type = [value: string] scala> ds2.queryExecution.executedPlan res2: org.apache.spark.sql.execution.SparkPlan = InMemoryTableScan [value#11] +- InMemoryRelation [value#11], true, 10000, StorageLevel(disk, memory, deserialized, 1 replicas) +- *FileScan parquet default.t[value#7] Batched: true, Format: Parquet, Location: InMemoryFileIndex[file:/root/repos/spark-1/spark-warehouse/t], PartitionFilters: [], PushedFilters: [], ReadSchema: struct scala> ds1.unpersist() res3: ds1.type = [value: string] scala> ds2.queryExecution.executedPlan res4: org.apache.spark.sql.execution.SparkPlan = InMemoryTableScan [value#11] +- InMemoryRelation [value#11], true, 10000, StorageLevel(disk, memory, deserialized, 1 replicas) +- *FileScan parquet default.t[value#7] Batched: true, Format: Parquet, Location: InMemoryFileIndex[file:/root/repos/spark-1/spark-warehouse/t], PartitionFilters: [], PushedFilters: [], ReadSchema: struct scala> ds2.storageLevel res5: org.apache.spark.storage.StorageLevel = StorageLevel(1 replicas) --- 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. --- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org For additional commands, e-mail: reviews-help@spark.apache.org