apache phoenix csvbulkloadtool失败

tzdcorbm  于 2021-06-09  发布在  Hbase
关注(0)|答案(1)|浏览(469)

我正在使用以下linux命令:

hadoop jar phoenix-4.6.0-HBase-0.98-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool --table TT --input /tmp/text.csv

此命令工作成功,但hbase表中没有加载csv文件中的数据,但数据已成功加载到索引表(为tt的索引表导入csv文件)。
环境:
hbase 0.98.9版
hadoop 2.6.0版
Phoenix4.6-hbase-0.98
案例1:索引覆盖所有列
1)

CREATE TABLE example (
    my_pk bigint not null,
    m.first_name varchar(50),
    m.last_name varchar(50)
    CONSTRAINT pk PRIMARY KEY (my_pk))
CREATE INDEX index_example on example(m.last_name ASC) include (m.first_name)
   or create index index_example on example(m.first_name,m.last_name)
hadoop jar phoenix-4.6.0-HBase-0.98-client.jar org.apache.phoenix.mapreduce.CsvBulkLoadTool --table example --input /tmp/text1.csv --index-table INDEX_EXAMPLE
select * from example

成功与有数据

select * from index_example

成功与有数据
测试用例:org.apache.phoenix.mapreduce.csvbulkloadtoolit.testimportwithindex()
案例2:列的索引覆盖部分
1)

CREATE TABLE example (
    my_pk bigint not null,
    m.first_name varchar(50),
    m.last_name varchar(50)
    CONSTRAINT pk PRIMARY KEY (my_pk))
create index index_example on example(m.last_name ASC)
hadoop jar phoenix-4.6.0-HBase-0.98-client.jar 
org.apache.phoenix.mapreduce.CsvBulkLoadTool --table example --input /tmp/text1.csv --index-table INDEX_EXAMPLE
select * from example

成功但没有数据

select * from index_example

成功有数据吗
测试用例:org.apache.phoenix.mapreduce.csvbulkloadtoolit.testimportoneindextable()

ftf50wuq

ftf50wuq1#

这是phoenix中的一个已知错误,当您的表名为小写时。你需要用双引号把它们括起来

hadoop jar phoenix-4.6.0-HBase-0.98-client.jar 
org.apache.phoenix.mapreduce.CsvBulkLoadTool --table \"\"example\"\" --input /tmp/text1.csv --index-table INDEX_EXAMPLE

相关问题