This is an automated email from the ASF dual-hosted git repository.

dongjoon pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 2e04689  [SPARK-32779][SQL][FOLLOW-UP] Delete Unused code
2e04689 is described below

commit 2e04689932b96321012ad9a5acaaf3ac306bba37
Author: sandeep.katta <sandeep.katta2...@gmail.com>
AuthorDate: Sat Sep 12 13:22:54 2020 -0700

    [SPARK-32779][SQL][FOLLOW-UP] Delete Unused code
    
    ### What changes were proposed in this pull request?
    Follow-up PR as per the review comments in 
[29649](https://github.com/apache/spark/pull/29649/files/8d45542e915bea1b321f42988b407091065a2539#r487140171)
    
    ### Why are the changes needed?
    Delete the un used code
    
    ### Does this PR introduce _any_ user-facing change?
    No
    
    ### How was this patch tested?
    Existing UT
    
    Closes #29736 from sandeep-katta/deadlockfollowup.
    
    Authored-by: sandeep.katta <sandeep.katta2...@gmail.com>
    Signed-off-by: Dongjoon Hyun <dongj...@apache.org>
    (cherry picked from commit 2009f953406aa5b4fdcdcd35f4c7c143f34d53e3)
    Signed-off-by: Dongjoon Hyun <dongj...@apache.org>
---
 sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala | 2 --
 1 file changed, 2 deletions(-)

diff --git 
a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala 
b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala
index 8d0a0f6..c7cbf32 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala
@@ -1327,8 +1327,6 @@ private[client] class Shim_v3_0 extends Shim_v2_3 {
       inheritTableSpecs: Boolean,
       isSkewedStoreAsSubdir: Boolean,
       isSrcLocal: Boolean): Unit = {
-    val session = SparkSession.getActiveSession
-    assert(session.nonEmpty)
     val table = hive.getTable(tableName)
     val loadFileType = if (replace) {
       
clazzLoadFileType.getEnumConstants.find(_.toString.equalsIgnoreCase("REPLACE_ALL"))


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org

Reply via email to