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 A57A0200BD5 for ; Thu, 24 Nov 2016 03:10:42 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id A3F1F160B0A; Thu, 24 Nov 2016 02:10:42 +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 1DEFA160AFD for ; Thu, 24 Nov 2016 03:10:41 +0100 (CET) Received: (qmail 25589 invoked by uid 500); 24 Nov 2016 02:10:41 -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 25571 invoked by uid 99); 24 Nov 2016 02:10:41 -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; Thu, 24 Nov 2016 02:10:41 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D3E8EDFCC8; Thu, 24 Nov 2016 02:10:40 +0000 (UTC) From: cloud-fan To: reviews@spark.apache.org Reply-To: reviews@spark.apache.org References: In-Reply-To: Subject: [GitHub] spark pull request #15993: [SPARK-18050][SQL] do not create default database... Content-Type: text/plain Message-Id: <20161124021040.D3E8EDFCC8@git1-us-west.apache.org> Date: Thu, 24 Nov 2016 02:10:40 +0000 (UTC) archived-at: Thu, 24 Nov 2016 02:10:42 -0000 Github user cloud-fan commented on a diff in the pull request: https://github.com/apache/spark/pull/15993#discussion_r89426408 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/internal/SharedState.scala --- @@ -92,8 +92,12 @@ private[sql] class SharedState(val sparkContext: SparkContext) extends Logging { { val defaultDbDefinition = CatalogDatabase( SessionCatalog.DEFAULT_DATABASE, "default database", warehousePath, Map()) - // Initialize default database if it doesn't already exist - externalCatalog.createDatabase(defaultDbDefinition, ignoreIfExists = true) + // Initialize default database if it doesn't exist + if (!externalCatalog.databaseExists(SessionCatalog.DEFAULT_DATABASE)) { --- End diff -- checking existence and then creating database is not atomic. It's ok here because we can't drop default database, but it may not work for general `createDatabase` --- 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