You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hbase.apache.org by "Balazs Meszaros (Jira)" <ji...@apache.org> on 2020/04/28 19:55:00 UTC

[jira] [Resolved] (HBASE-24276) hbase spark connector doesn't support writing to table not in default namespace

     [ https://issues.apache.org/jira/browse/HBASE-24276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Balazs Meszaros resolved HBASE-24276.
-------------------------------------
    Fix Version/s: connector-1.0.1
       Resolution: Fixed

> hbase spark connector doesn't support writing to table not in default namespace
> -------------------------------------------------------------------------------
>
>                 Key: HBASE-24276
>                 URL: https://issues.apache.org/jira/browse/HBASE-24276
>             Project: HBase
>          Issue Type: Bug
>          Components: hbase-connectors, spark
>    Affects Versions: connector-1.0.0
>         Environment: - HBase 2.2.4
> - Hadoop 2.10.0
> - Spark 2.4.5
>            Reporter: Naitree Zhu
>            Priority: Major
>             Fix For: connector-1.0.1
>
>
> Defining the following table catalog:
> {code:java}
> val catalog = """{
>   |"table": {"namespace": "ns1", "name": "test1"},
>   |"rowkey": "id",
>   |"columns": {
>     |"id": {"cf": "rowkey", "col": "id", "type": "string"}, 
>     |"x": {"cf": "d", "col": "xxx", "type": "int"}
>   |}
> |}""".stripMargin
> {code}
> Try to write some test data to {{ns1:test1}} table using spark:
> {code:java}
> val df = Seq(("abc", 1), ("def", 2)).toDF("id", "x")
> df.write.options(Map(HBaseTableCatalog.tableCatalog -> catalog, "hbase.spark.use.hbasecontext" -> "false", HBaseTableCatalog.newTable-> "5")).format("org.apache.hadoop.hbase.spark").save()
> {code}
> After executing the code above, I found out that the test data was written to {{default:test1}}, rather than {{ns1:test1}}.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)