出错原因:在添加列族时,禁用和启用了表,但是不同步,导致写不进去

def addFamilys(tableName: String, columnFamilys: String): Unit = {
    val tablename = TableName.valueOf(tableName)
    this.admin.disableTable(tablename)
    val hDescriptor = this.admin.getTableDescriptor(tablename)
    val hColumnDescriptor = new HColumnDescriptor(columnFamilys)
    val descriptor = hDescriptor.getFamily(Bytes.toBytes(columnFamilys))
    if (descriptor == null) {
      hDescriptor.addFamily(hColumnDescriptor)
      this.admin.modifyTable(tablename, hDescriptor)
    }
    this.admin.enableTableAsync(tablename)
  }

可手动开启,但是运行程序后还是报错

hbase(main):020:0> disable '表名'
0 row(s) in 0.0640 seconds

hbase(main):021:0> enable '表名'
0 row(s) in 1.4940 seconds

解决方法:直接不用该方法,而是手动添加列族

1.找到所有的列族

db.getCollection('DetailDic_IBRD_20220420').distinct("ConceptId")

2.手动添加

alter '表名', '列族名'

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐