[ https://issues.apache.org/jira/browse/PHOENIX-7090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
chaijunjie updated PHOENIX-7090: -------------------------------- Description: {code:java} create table t1 (id varchar not null primary key, v1 varchar, v2 varchar); create table t2 (id varchar not null primary key, v3 varchar, v4 varchar); upsert into t1 values('1','2','3'); upsert into t2 values('1','4','5'); select * from t1 where id = (select id from t2 where v3='x' limit 1);{code} {code:java} 0: jdbc:phoenix:> select * from t1 where id = (select id from t2 where v3='x' limit 1); Error: Encountered exception in sub plan [0] execution. (state=,code=0) java.sql.SQLException: Encountered exception in sub plan [0] execution. at org.apache.phoenix.execute.HashJoinPlan.iterator(HashJoinPlan.java:220) at org.apache.phoenix.execute.DelegateQueryPlan.iterator(DelegateQueryPlan.java:144) at org.apache.phoenix.execute.DelegateQueryPlan.iterator(DelegateQueryPlan.java:139) at org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:320) at org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:299) at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53) at org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:298) at org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:291) at org.apache.phoenix.jdbc.PhoenixStatement.execute(PhoenixStatement.java:1994) at sqlline.Commands.executeSingleQuery(Commands.java:1054) at sqlline.Commands.execute(Commands.java:1003) at sqlline.Commands.sql(Commands.java:967) at sqlline.SqlLine.dispatch(SqlLine.java:734) at sqlline.SqlLine.begin(SqlLine.java:541) at sqlline.SqlLine.start(SqlLine.java:267) at sqlline.SqlLine.main(SqlLine.java:206) Caused by: java.lang.NullPointerException at java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1011) at java.util.concurrent.ConcurrentHashMap.put(ConcurrentHashMap.java:1006) at org.apache.phoenix.compile.StatementContext.setSubqueryResult(StatementContext.java:305) at org.apache.phoenix.execute.HashJoinPlan$WhereClauseSubPlan.execute(HashJoinPlan.java:467) at org.apache.phoenix.execute.HashJoinPlan$1.call(HashJoinPlan.java:188) at org.apache.phoenix.execute.HashJoinPlan$1.call(HashJoinPlan.java:184) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at org.apache.phoenix.job.JobManager$InstrumentedJobFutureTask.run(JobManager.java:185) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) {code} {code:java} 0: jdbc:phoenix:> select * from t1 where id = (select id from t2 where v3='4' limit 1); +----+----+----+ | ID | V1 | V2 | +----+----+----+ | 1 | 2 | 3 | +----+----+----+ 1 row selected (0.082 seconds) {code} was: {code:java} create table t1 (id varchar not null primary key, v1 varchar, v2 varchar); create table t2 (id varchar not null primary key, v3 varchar, v4 varchar); upsert into t1 values('1','2','3'); upsert into t2 values('1','4','5'); select * from t1 where id = (select id from t2 where v3='x' limit 1);{code} 0: jdbc:phoenix:> select * from t1 where id = (select id from t2 where v3='x' limit 1); Error: Encountered exception in sub plan [0] execution. (state=,code=0) java.sql.SQLException: Encountered exception in sub plan [0] execution. at org.apache.phoenix.execute.HashJoinPlan.iterator(HashJoinPlan.java:220) at org.apache.phoenix.execute.DelegateQueryPlan.iterator(DelegateQueryPlan.java:144) at org.apache.phoenix.execute.DelegateQueryPlan.iterator(DelegateQueryPlan.java:139) at org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:320) at org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:299) at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53) at org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:298) at org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:291) at org.apache.phoenix.jdbc.PhoenixStatement.execute(PhoenixStatement.java:1994) at sqlline.Commands.executeSingleQuery(Commands.java:1054) at sqlline.Commands.execute(Commands.java:1003) at sqlline.Commands.sql(Commands.java:967) at sqlline.SqlLine.dispatch(SqlLine.java:734) at sqlline.SqlLine.begin(SqlLine.java:541) at sqlline.SqlLine.start(SqlLine.java:267) at sqlline.SqlLine.main(SqlLine.java:206) Caused by: java.lang.NullPointerException at java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1011) at java.util.concurrent.ConcurrentHashMap.put(ConcurrentHashMap.java:1006) at org.apache.phoenix.compile.StatementContext.setSubqueryResult(StatementContext.java:305) at org.apache.phoenix.execute.HashJoinPlan$WhereClauseSubPlan.execute(HashJoinPlan.java:467) at org.apache.phoenix.execute.HashJoinPlan$1.call(HashJoinPlan.java:188) at org.apache.phoenix.execute.HashJoinPlan$1.call(HashJoinPlan.java:184) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at org.apache.phoenix.job.JobManager$InstrumentedJobFutureTask.run(JobManager.java:185) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) > Hash join throw NullPointerException when use Subquery > ------------------------------------------------------ > > Key: PHOENIX-7090 > URL: https://issues.apache.org/jira/browse/PHOENIX-7090 > Project: Phoenix > Issue Type: Bug > Affects Versions: 5.1.2 > Reporter: chaijunjie > Priority: Major > > {code:java} > create table t1 (id varchar not null primary key, v1 varchar, v2 varchar); > create table t2 (id varchar not null primary key, v3 varchar, v4 varchar); > upsert into t1 values('1','2','3'); > upsert into t2 values('1','4','5'); > select * from t1 where id = (select id from t2 where v3='x' limit 1);{code} > > {code:java} > 0: jdbc:phoenix:> select * from t1 where id = (select id from t2 where v3='x' > limit 1); > Error: Encountered exception in sub plan [0] execution. (state=,code=0) > java.sql.SQLException: Encountered exception in sub plan [0] execution. > at org.apache.phoenix.execute.HashJoinPlan.iterator(HashJoinPlan.java:220) > at > org.apache.phoenix.execute.DelegateQueryPlan.iterator(DelegateQueryPlan.java:144) > at > org.apache.phoenix.execute.DelegateQueryPlan.iterator(DelegateQueryPlan.java:139) > at > org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:320) > at > org.apache.phoenix.jdbc.PhoenixStatement$1.call(PhoenixStatement.java:299) > at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53) > at > org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:298) > at > org.apache.phoenix.jdbc.PhoenixStatement.executeQuery(PhoenixStatement.java:291) > at > org.apache.phoenix.jdbc.PhoenixStatement.execute(PhoenixStatement.java:1994) > at sqlline.Commands.executeSingleQuery(Commands.java:1054) > at sqlline.Commands.execute(Commands.java:1003) > at sqlline.Commands.sql(Commands.java:967) > at sqlline.SqlLine.dispatch(SqlLine.java:734) > at sqlline.SqlLine.begin(SqlLine.java:541) > at sqlline.SqlLine.start(SqlLine.java:267) > at sqlline.SqlLine.main(SqlLine.java:206) > Caused by: java.lang.NullPointerException > at > java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1011) > at java.util.concurrent.ConcurrentHashMap.put(ConcurrentHashMap.java:1006) > at > org.apache.phoenix.compile.StatementContext.setSubqueryResult(StatementContext.java:305) > at > org.apache.phoenix.execute.HashJoinPlan$WhereClauseSubPlan.execute(HashJoinPlan.java:467) > at org.apache.phoenix.execute.HashJoinPlan$1.call(HashJoinPlan.java:188) > at org.apache.phoenix.execute.HashJoinPlan$1.call(HashJoinPlan.java:184) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > org.apache.phoenix.job.JobManager$InstrumentedJobFutureTask.run(JobManager.java:185) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:750) > {code} > {code:java} > 0: jdbc:phoenix:> select * from t1 where id = (select id from t2 where v3='4' > limit 1); > +----+----+----+ > | ID | V1 | V2 | > +----+----+----+ > | 1 | 2 | 3 | > +----+----+----+ > 1 row selected (0.082 seconds) > {code} > > -- This message was sent by Atlassian Jira (v8.20.10#820010)