roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r979762248
##
sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryExecutionErrors.scala:
##
@@ -1932,6 +1932,13 @@ private[sql] object QueryExecutionErrors extends
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r979213153
##
core/src/main/resources/error/error-classes.json:
##
@@ -70,6 +70,11 @@
],
"sqlState" : "22008"
},
+ "DEFAULT_CATALOG_DATABASE_NOT_EXISTS" : {
Review
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r978187565
##
sql/core/src/main/scala/org/apache/spark/sql/internal/SharedState.scala:
##
@@ -148,13 +148,18 @@ private[sql] class SharedState(
val externalCatalog =
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r978187565
##
sql/core/src/main/scala/org/apache/spark/sql/internal/SharedState.scala:
##
@@ -148,13 +148,18 @@ private[sql] class SharedState(
val externalCatalog =
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r978186734
##
sql/core/src/main/scala/org/apache/spark/sql/internal/SharedState.scala:
##
@@ -148,13 +148,18 @@ private[sql] class SharedState(
val externalCatalog =
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r978186527
##
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2SessionCatalog.scala:
##
@@ -43,7 +44,7 @@ class V2SessionCatalog(catalog: SessionCatalog)
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r978186198
##
sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala:
##
@@ -36,7 +36,7 @@ import org.apache.spark.SparkFunSuite
import org.apache.spark.sql._
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r974976617
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala:
##
@@ -48,9 +48,6 @@ import org.apache.spark.sql.types.StructType
import
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r973767185
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala:
##
@@ -286,7 +284,7 @@ class SessionCatalog(
def dropDatabase(db: String,
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r973767185
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala:
##
@@ -286,7 +284,7 @@ class SessionCatalog(
def dropDatabase(db: String,
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r967420952
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala:
##
@@ -286,7 +284,7 @@ class SessionCatalog(
def dropDatabase(db: String,
roczei commented on code in PR #37679:
URL: https://github.com/apache/spark/pull/37679#discussion_r967420952
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala:
##
@@ -286,7 +284,7 @@ class SessionCatalog(
def dropDatabase(db: String,
12 matches
Mail list logo