在db2驱动的sparkshell中运行scala脚本后,我遇到了一个错误。我在网上找不到关于这个错误的太多信息,想知道是否有办法做到这一点。
我尝试对异常执行getnextexception()方法,但它不是可识别的命令。
我试过运行一部分java代码,这些代码在https://www.ibm.com/support/knowledgecenter/ssepgg_11.1.0/com.ibm.db2.luw.apdv.java.doc/src/tpc/imjcc_tjvjdbue.html 类似的数值也没有被确认。
scala> try {
| //Load data into necessary table
| loadNMCview.write.format("jdbc").option("url", s"${sf_url}").option("dbtable", "tableName").option("driver", "com.ibm.db2.jcc.DB2Driver").mode("append").save
| } catch(BatchUpdateException buex) {
| System.err.println("Contents of BatchUpdateException:")
| System.err.println(" Update counts: ")
| System.out.println(buex.getUpdateCounts())
| }
<console>:31: error: not found: value BatchUpdateException
} catch(BatchUpdateException buex) {
^ <console>:34: error: not found: value buex
System.out.println(buex.getUpdateCounts())
代码:
loadNMCview.write.format("jdbc").option("url", s"${sf_url}").option("dbtable", "schemaName.tableName").option("driver", "com.ibm.db2.jcc.DB2Driver").mode("append").save
错误:
2006年7月20日13:37:20警告tasksetmanager:阶段0.0中的任务0.0丢失(tid 0,edclhdpd138.bcbsfl.com,executor 2):com.ibm.db2.jcc.am.batchupdateexception:[jcc][t4][102][10040][4.17.29]批处理失败。已提交该批,但该批的单个成员上至少发生了一个异常。使用getnextexception()检索特定批处理元素的异常。errorcode=-4229,sqlstate=null
暂无答案!
目前还没有任何答案,快来回答吧!