[ https://issues.apache.org/jira/browse/PHOENIX-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14559643#comment-14559643 ]
Seth Brogan commented on PHOENIX-1999: -------------------------------------- [~maghamraviki...@gmail.com], sorry for the delay in my response. I ran an example in my development environment, here are the steps and results: In Phoenix: [code] CREATE TABLE IF NOT EXISTS "my_table" (rowkey VARCHAR PRIMARY KEY, "a" VARCHAR, "my_id" VARCHAR); CREATE TABLE IF NOT EXISTS "my_other_table" (rowkey VARCHAR PRIMARY KEY, "x" VARCHAR, "my_id" VARCHAR); UPSERT INTO "my_table" ("ROWKEY", "a", "my_id") VALUES ('abc|123', 'abc', '123'); UPSERT INTO "my_other_table" ("ROWKEY", "x", "my_id") VALUES ('xyz|123', 'xyz', '123'); [/code] In a Grunt shell: [code] REGISTER s3n://my_bucket/hadoop/lib/phoenix-4.1.0-client-hadoop2.jar; my_table = LOAD 'hbase://query/SELECT * FROM "my_table"' USING org.apache.phoenix.pig.PhoenixHBaseLoader('localhost:/hbase'); DUMP my_table; (abc|123,abc,123) my_other_table = LOAD 'hbase://query/SELECT * FROM "my_other_table"' USING org.apache.phoenix.pig.PhoenixHBaseLoader('localhost:/hbase'); DUMP my_other_table; (xyz|123,xyz,123) A = LOAD 'hbase://query/SELECT "t1"."a", "t2"."x" FROM "my_table" AS "t1" JOIN "my_other_table" AS "t2" ON "t1"."my_id" = "t2"."my_id"' USING org.apache.phoenix.pig.PhoenixHBaseLoader('localhost:/hbase'); DUMP A; (,) [/code] > Phoenix Pig Loader does not return data when selecting from multiple tables > in a query with a join > -------------------------------------------------------------------------------------------------- > > Key: PHOENIX-1999 > URL: https://issues.apache.org/jira/browse/PHOENIX-1999 > Project: Phoenix > Issue Type: Bug > Affects Versions: 4.1.0 > Environment: Pig 0.14.3, Hadoop 2.5.2 > Reporter: Seth Brogan > Assignee: maghamravikiran > > The Phoenix Pig Loader does not return data in Pig when selecting specific > columns from multiple tables in a join query. > Example: > {code} > DESCRIBE my_table; > my_table: {a: chararray, my_id: chararray} > DUMP my_table; > (abc, 123) > DESCRIBE join_table; > join_table: {x: chararray, my_id: chararray} > DUMP join_table; > (xyz, 123) > A = LOAD 'hbase://query/SELECT "t1"."a", "t2"."x" FROM "my_table" AS "t1" > JOIN "join_table" AS "t2" ON "t1"."my_id" = "t2"."my_id"' using > org.apache.phoenix.pig.PhoenixHBaseLoader('localhost'); > DUMP A; > (,) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)