Yes, a MR option would be great. I filed PHOENIX-3125 for this. Give our MR support, this would be a good initial contribution for someone.
Thanks, James On Thu, Jul 28, 2016 at 11:16 AM, Simon Wang <simon.w...@airbnb.com> wrote: > This isn’t a solution but I have encountered this problem before. It also > seemed that the table becomes available in Phoenix even if the creation > dies to an error. I am also interested in a workaround! (Maybe a MR job? > > - Simon > > > On Jul 28, 2016, at 1:49 AM, Parveen Jain <parveenj...@live.com> wrote: > > Hi All, > Just starting out with Phoenix and facing issues regarding time out.First > Timeout I am getting is while creating table in phoenix which for an > existing table in Hbase. > > My HBase table has almost 100M rows and split across two nodes having two > region servers. One server is octa core and another is 16 core.I am using > only default settings of HBase and some time out settings for phoenix > before starting it out. Can Anyone suggest from where I can start looking > into ? > > Regards, > Parveen Jain > > Following is the error: > CREATE TABLE "DATA_FOR_PHOENIX1"(pk VARCHAR PRIMARY > KEY,"PARSED_DATA_COLUMN1".NAME0 VARCHAR,"PARSED_DATA_COLUMN1".NAME1 > VARCHAR,"PARSED_DATA_COLUMN1".NAME2 > VARCHAR,"VARCHAR,"PARSED_DATA_COLUMN1".NAME3 > VARCHAR,"PARSED_DATA_COLUMN1".NAME4 VARCHAR,"PARSED_DATA_COLUMN1".NAME5 > VARCHAR,"PARSED_DATA_COLUMN1".NAME6 VARCHAR) SALT_BUCKETS=16; > > Error: Operation timed out (state=TIM01,code=6000) > java.sql.SQLTimeoutException: Operation timed out > at > org.apache.phoenix.exception.SQLExceptionCode$14.newException(SQLExceptionCode.java:332) > at > org.apache.phoenix.exception.SQLExceptionInfo.buildException(SQLExceptionInfo.java:145) > at > org.apache.phoenix.iterate.BaseResultIterators.getIterators(BaseResultIterators.java:573) > at > org.apache.phoenix.iterate.BaseResultIterators.getIterators(BaseResultIterators.java:562) > at > org.apache.phoenix.iterate.BaseResultIterators.getIterators(BaseResultIterators.java:516) > at > org.apache.phoenix.iterate.ConcatResultIterator.getIterators(ConcatResultIterator.java:50) > at > org.apache.phoenix.iterate.ConcatResultIterator.currentIterator(ConcatResultIterator.java:97) > at > org.apache.phoenix.iterate.ConcatResultIterator.next(ConcatResultIterator.java:117) > at > org.apache.phoenix.iterate.BaseGroupedAggregatingResultIterator.next(BaseGroupedAggregatingResultIterator.java:64) > at > org.apache.phoenix.iterate.UngroupedAggregatingResultIterator.next(UngroupedAggregatingResultIterator.java:39) > at > org.apache.phoenix.compile.PostDDLCompiler$1.execute(PostDDLCompiler.java:228) > at > org.apache.phoenix.query.ConnectionQueryServicesImpl.updateData(ConnectionQueryServicesImpl.java:2013) > at > org.apache.phoenix.schema.MetaDataClient.createTable(MetaDataClient.java:787) > at > org.apache.phoenix.compile.CreateTableCompiler$2.execute(CreateTableCompiler.java:186) > at > org.apache.phoenix.jdbc.PhoenixStatement$2.call(PhoenixStatement.java:305) > at > org.apache.phoenix.jdbc.PhoenixStatement$2.call(PhoenixStatement.java:297) > at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53) > at > org.apache.phoenix.jdbc.PhoenixStatement.executeMutation(PhoenixStatement.java:295) > at > org.apache.phoenix.jdbc.PhoenixStatement.execute(PhoenixStatement.java:1255) > at sqlline.Commands.execute(Commands.java:822) > at sqlline.Commands.sql(Commands.java:732) > at sqlline.SqlLine.dispatch(SqlLine.java:808) > at sqlline.SqlLine.begin(SqlLine.java:681) > at sqlline.SqlLine.start(SqlLine.java:398) > at sqlline.SqlLine.main(SqlLine.java:292) > > >
