【原创】大叔问题定位分享（16）spark写数据到hive外部表报错ClassCastException: org.apache.hadoop.hive.hbase.HiveHBaseTableOut

时间 2019-11-21

标签原创问题定位分享 spark 数据 hive 外部表报 classcastexception org.apache.hadoop.hive.hbase.hivehbasetableout org apache hadoop hbase hivehbasetableout 栏目系统网络繁體版

原文原文链接

spark 2.1.1html

spark在写数据到hive外部表（底层数据在hbase中）时会报错java

Caused by: java.lang.ClassCastException: org.apache.hadoop.hive.hbase.HiveHBaseTableOutputFormat cannot be cast to org.apache.hadoop.hive.ql.io.HiveOutputFormat
at org.apache.spark.sql.hive.SparkHiveWriterContainer.outputFormat$lzycompute(hiveWriterContainers.scala:82)sql

org.apache.spark.sql.hive.SparkHiveWriterContainerapache

org.apache.spark.sql.hive.SparkHiveWriterContainer
  @transient private lazy val outputFormat = conf.value.getOutputFormat.asInstanceOf[HiveOutputFormat[AnyRef, Writable]]

报错的是这一句，查看代码发现此时这个变量并无什么用处，能够在不能cast时置为nulloop

  @transient private lazy val outputFormat =
    // conf.value.getOutputFormat.asInstanceOf[HiveOutputFormat[AnyRef, Writable]]
    conf.value.getOutputFormat match {
      case format if format.isInstanceOf[HiveOutputFormat[AnyRef, Writable]] => format.asInstanceOf[HiveOutputFormat[AnyRef, Writable]]
      case _ => null
    }

问题解决，官方讨论以下： https://issues.apache.org/jira/browse/SPARK-6628post