0

在 db2 驱动的 spark-shell 中运行 scala 脚本后出现错误。我在网上找不到太多关于错误的信息,想知道是否有办法做到这一点。

我已尝试对异常执行 getNextException() 方法,但它不是可识别的命令。

我已经尝试运行在https://www.ibm.com/support/knowledgecenter/SSEPGG_11.1.0/com.ibm.db2.luw.apdv.java.doc/src/tpc上作为示例列出的部分 java 代码/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

错误:

20/07/06 13:37:20 WARN TaskSetManager:在阶段 0.0 中丢失任务 0.0(TID 0,edclhdpd138.bcbsfl.com,执行程序 2):com.ibm.db2.jcc.am.BatchUpdateException:[jcc][t4 ][102][10040][4.17.29] 批处理失败。该批次已提交,但该批次的单个成员至少发生了一次异常。使用 getNextException() 检索特定批处理元素的异常。错误代码=-4229,SQLSTATE=null

4

0 回答 0