無法在Spark中打印堆棧跟蹤

我正在下面的代碼中運行，在Failure部分中，我將異常堆棧跟蹤作爲INFO在紗線日誌中打印。我的代碼在sql中有語法錯誤，因此會生成異常。但是，當我看到紗線日誌時，它顯示了一些意想不到的事情，如下所示，「停止的SparkContext上的調用方法」。需要幫助，如果我做錯了什麼。無法在Spark中打印堆棧跟蹤

一小段代碼片段： -

var ret:String= Try { 
    DbUtil.dropTable("cls_mkt_tracker_split_rownum", batchDatabase) 
    SparkEnvironment.hiveContext.sql(
     s"""CREATE TABLE ${batchDatabase}.CLS_MKT_TRACKER_SPLIT_ROWNUM 
     AS SELECT ROW_NUMBER() OVER(PARTITION BY XREF_IMS_PAT_NBR,MOLECULE ORER BY IMS_DSPNSD_DT) AS ROWNUM,* 
     FROM ${batchDatabase}.CLS_MKT_TRACKER_SPLIT 
    """) 
    true 
    } match { 
    case Success (b:Boolean) => "" 
    case Failure (t :Throwable) => logger.info("I am in failure" + t.getMessage + t.getStackTraceString) ; "failure return" 
    }

紗日誌： -

16/12/13 11:19:42 INFO SessionState: No Tez session required at this point. hive.execution.engine=mr. 
16/12/13 11:19:43 INFO DateAdjustment: I am in failureCannot call methods on a stopped SparkContext. 
This stopped SparkContext was created at: 

org.apache.spark.SparkContext.<init>(SparkContext.scala:83) 
SparkEnvironment$.<init>(SparkEnvironment.scala:12) 
SparkEnvironment$.<clinit>(SparkEnvironment.scala) 
DbUtil$.dropTable(DbUtil.scala:8) 
DateAdjustment$$anonfun$1.apply$mcZ$sp(DateAdjustment.scala:126) 
DateAdjustment$$anonfun$1.apply(DateAdjustment.scala:125) 
DateAdjustment$$anonfun$1.apply(DateAdjustment.scala:125) 
scala.util.Try$.apply(Try.scala:161) 
DateAdjustment$delayedInit$body.apply(DateAdjustment.scala:125) 
scala.Function0$class.apply$mcV$sp(Function0.scala:40) 
scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12) 
scala.App$$anonfun$main$1.apply(App.scala:71) 
scala.App$$anonfun$main$1.apply(App.scala:71) 
scala.collection.immutable.List.foreach(List.scala:318) 
scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:32) 
scala.App$class.main(App.scala:71) 
DateAdjustment$.main(DateAdjustment.scala:14) 
DateAdjustment.main(DateAdjustment.scala) 
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 

The currently active SparkContext was created at: 

(No active SparkContext.) 
     org.apache.spark.SparkContext.org$apache$spark$SparkContext$$assertNotStopped(SparkContext.scala:107)

來源

2016-12-13 Priyaranjan Swain

[this]的可能重複（http://stackoverflow.com/questions/36084589/could-you-give-me-any-clue-why-cannot-call-methods-on-a-stopped-sparkcontext）請參閱@TzachZohar的答案 –

也看到[this]（http://stackoverflow.com/questions/33606403/why-is-cannot-call-methods-on-a-stopped-sparkcontext-thrown-when-connecting-to） –

我調查發現，在一個地方我的申請，SC.stop（）被調用這是造成這個問題。

來源

2016-12-14 03:39:48

無法在Spark中打印堆棧跟蹤

回答

相關問題