spark phoenixtableasrdd未获取完整的记录值

ccrfmcuu  于 2021-06-10  发布在  Hbase
关注(0)|答案(0)|浏览(229)

我有一个奇怪的问题,当我使用sparkphoenix从hbase获取数据时

val rdd = sc.phoenixTableAsRDD(tableName, allColumns, zkUrl = Some(hostPort).map(tupleToObject)

我得到了一个rdd与所有的记录,但很少有没有一些非主键字段的价值(拉姆多姆似乎)。如果我用一个简单的phoenix客户机查询这些记录,我发现这些字段实际上是有值的。

Example:
rdd.foreach(x => {
      println("Field A -> " + x._1) //not a primary key value
      println("Field B -> " + x._2) //not a primary key value
 })

Output:
  Field A 2
  Field B 3
  Field A null
  Field B 4
  Field A null  
  Field B null

我错过了什么?ApachePhoenix是否可能不保证数据一致性

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题