使用spark从hive往hbase传输数据时报错：row length is 0

这个错误通常是因为你的Hive表没有正确定义列，或者HBase表不允许空行（即行中没有任何值）。请检查你的Hive表和HBase表的定义，确保它们是正确的。

另外，如果你正在使用Spark的API来传输数据，请确保你使用的API是正确的。例如，如果你使用saveAsNewAPIHadoopDataset方法来传输数据，请确保你提供了正确的HBase表的名称和列族。你可以参考以下代码来保存数据到HBase表：

import org.apache.hadoop.hbase.HBaseConfiguration
import org.apache.hadoop.hbase.client.Put
import org.apache.hadoop.hbase.io.ImmutableBytesWritable
import org.apache.hadoop.hbase.mapreduce.TableOutputFormat
import org.apache.hadoop.hbase.util.Bytes
import org.apache.spark.SparkConf
import org.apache.spark.SparkContext

object SaveToHBase {
  def main(args: Array[String]) {
    val sparkConf = new SparkConf().setAppName("SaveToHBase")
    val sc = new SparkContext(sparkConf)

    // Define HBase table configuration
    val conf = HBaseConfiguration.create()
    conf.set(TableOutputFormat.OUTPUT_TABLE, "table_name")
    conf.set("hbase.zookeeper.quorum", "zookeeper_quorum")
    conf.set("hbase.zookeeper.property.clientPort", "2181")

    // Define HBase table columns
    val hbaseColumns = Seq("column_family:column1", "column_family:column2")

    // Define data to be saved to HBase table
    val data = sc.parallelize(Seq(
      ("row1", "value1", "value2"),
      ("row2", "value3", "value4")
    ))

    // Create HBase table row objects
    val hbaseRows = data.map { case (rowKey, col1, col2) =>
      val put = new Put(Bytes.toBytes(rowKey))
      put.addColumn(Bytes.toBytes("column_family"), Bytes.toBytes("column1"), Bytes.toBytes(col1))
      put.addColumn(Bytes.toBytes("column_family"), Bytes.toBytes("column2"), Bytes.toBytes(col2))
      (new ImmutableBytesWritable(Bytes.toBytes(rowKey)), put)
    }

    // Save data to HBase table
    hbaseRows.saveAsNewAPIHadoopDataset(conf)
  }
}

这个例子中，我们定义了一个名为table_name的HBase表，它包含一个名为column_family的列族，其中包含两个列：column1和column2。我们使用saveAsNewAPIHadoopDataset方法将数据保存到HBase表中。