There is a mistake. I would like to replace 'select into' with 'insert into'. Both are definitely different. 'select into' is used only when a target table is not created.
On Fri, Mar 29, 2013 at 9:02 PM, Hyunsik Choi <[email protected]>wrote: > Hi Tanujit, > > The current Tajo cannot create an empty table. You can only create a table > with an external dataset. Like the section 'Query Execution' in Getting > Started (http://tajo.incubator.apache.org/getting_started.html), you > firstly prepare an table data, and then you can create a table with some > parameters as follows: > > create external table table1 (id int, name string, score float, type > string) using csv with ('csvfile.delimiter'='|') location > 'hdfs:/home/x/table1' > > However, the 'select into' statement and the feature for creating an empty > table are must-have features. I'll create these features to Tajo Jira. > > Best regards, > Hyunsik > > > > On Fri, Mar 29, 2013 at 8:48 PM, Tanujit Ghosh <[email protected]>wrote: > >> Hi, >> >> I have build tajo and installed the build and trying to run a simple >> create >> table statement, but i get the following expception. >> >> I have turned on debug logging in log4j. >> >> [tanujit@garfield logs]$ tail -f tajo-tanujit-master-garfield.out >> 2013-03-29 17:02:56,933 DEBUG ipc.Client (Client.java:run(899)) - IPC >> Client (2719739) connection to garfield/192.168.0.103:8020 from tanujit >> sending #1 >> 2013-03-29 17:02:56,935 DEBUG ipc.Client >> (Client.java:receiveResponse(954)) >> - IPC Client (2719739) connection to garfield/192.168.0.103:8020 from >> tanujit got value #1 >> 2013-03-29 17:02:56,936 DEBUG ipc.ProtobufRpcEngine >> (ProtobufRpcEngine.java:invoke(217)) - Call: getFileInfo took 3ms >> 2013-03-29 17:02:56,938 DEBUG ipc.YarnRPC (YarnRPC.java:create(57)) - >> Creating YarnRPC for org.apache.hadoop.yarn.ipc.HadoopYarnProtoRPC >> 2013-03-29 17:02:56,961 INFO master.TajoMaster >> (TajoMaster.java:init(144)) >> - Enabled Distributed Mode >> 2013-03-29 17:02:57,110 INFO event.AsyncDispatcher >> (AsyncDispatcher.java:register(153)) - Registering class >> tajo.master.event.QueryEventType for class >> tajo.master.TajoMaster$QueryEventDispatcher >> 2013-03-29 17:02:57,129 INFO service.AbstractService >> (AbstractService.java:init(81)) - Service:Dispatcher is inited. >> 2013-03-29 17:02:57,136 INFO catalog.CatalogServer >> (CatalogServer.java:init(102)) - Catalog Store Class: >> tajo.catalog.store.DBStore >> 2013-03-29 17:02:57,804 INFO store.DBStore (DBStore.java:<init>(76)) - >> Loaded the JDBC driver (org.apache.derby.jdbc.EmbeddedDriver) >> 2013-03-29 17:02:57,805 INFO store.DBStore (DBStore.java:<init>(82)) - >> Trying to connect database (jdbc:derby:/home/tanujit/tajo/catalog_data/db) >> 2013-03-29 17:02:59,576 INFO store.DBStore (DBStore.java:<init>(84)) - >> Connected to database (jdbc:derby:/home/tanujit/tajo/catalog_data/db) >> 2013-03-29 17:03:00,135 INFO store.DBStore (DBStore.java:<init>(95)) - >> The >> base tables of CatalogServer already is initialized. >> 2013-03-29 17:03:00,395 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function sum(INT) is >> registered. >> 2013-03-29 17:03:00,396 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function sum(LONG) is >> registered. >> 2013-03-29 17:03:00,396 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function sum(FLOAT) is >> registered. >> 2013-03-29 17:03:00,396 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function sum(DOUBLE) is >> registered. >> 2013-03-29 17:03:00,397 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function max(INT) is >> registered. >> 2013-03-29 17:03:00,397 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function max(LONG) is >> registered. >> 2013-03-29 17:03:00,397 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function max(FLOAT) is >> registered. >> 2013-03-29 17:03:00,397 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function max(DOUBLE) is >> registered. >> 2013-03-29 17:03:00,398 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function min(INT) is >> registered. >> 2013-03-29 17:03:00,398 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function min(LONG) is >> registered. >> 2013-03-29 17:03:00,398 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function min(FLOAT) is >> registered. >> 2013-03-29 17:03:00,398 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function min(DOUBLE) is >> registered. >> 2013-03-29 17:03:00,398 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function min(STRING) is >> registered. >> 2013-03-29 17:03:00,399 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function avg(INT) is >> registered. >> 2013-03-29 17:03:00,400 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function avg(LONG) is >> registered. >> 2013-03-29 17:03:00,400 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function avg(FLOAT) is >> registered. >> 2013-03-29 17:03:00,400 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function avg(DOUBLE) is >> registered. >> 2013-03-29 17:03:00,400 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function count(ANY) is >> registered. >> 2013-03-29 17:03:00,401 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function count() is >> registered. >> 2013-03-29 17:03:00,401 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function >> in_country(STRING,STRING) is registered. >> 2013-03-29 17:03:00,401 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function country(STRING) is >> registered. >> 2013-03-29 17:03:00,401 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function date(STRING) is >> registered. >> 2013-03-29 17:03:00,402 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function today() is >> registered. >> 2013-03-29 17:03:00,402 INFO catalog.CatalogServer >> (CatalogServer.java:registerFunction(407)) - Function random(INT) is >> registered. >> 2013-03-29 17:03:00,402 INFO service.AbstractService >> (AbstractService.java:init(81)) - Service:tajo.catalog.CatalogServer is >> inited. >> 2013-03-29 17:03:00,402 INFO service.AbstractService >> (AbstractService.java:init(81)) - Service:tajo.master.GlobalEngine is >> inited. >> 2013-03-29 17:03:00,403 INFO service.AbstractService >> (AbstractService.java:init(81)) - Service:tajo.master.ClientService is >> inited. >> 2013-03-29 17:03:00,403 INFO service.AbstractService >> (AbstractService.java:init(81)) - Service:tajo.master.TajoMaster is >> inited. >> 2013-03-29 17:03:00,403 INFO master.TajoMaster >> (TajoMaster.java:start(296)) - TajoMaster startup >> 2013-03-29 17:03:00,403 INFO service.AbstractService >> (AbstractService.java:start(94)) - Service:Dispatcher is started. >> 2013-03-29 17:03:00,782 INFO rpc.NettyServerBase >> (NettyServerBase.java:start(84)) - RpcServer on /127.0.0.1:9002 >> 2013-03-29 17:03:00,782 INFO catalog.CatalogServer >> (CatalogServer.java:start(142)) - Catalog Server startup (127.0.0.1:9002) >> 2013-03-29 17:03:00,783 INFO service.AbstractService >> (AbstractService.java:start(94)) - Service:tajo.catalog.CatalogServer is >> started. >> 2013-03-29 17:03:00,787 DEBUG ipc.HadoopYarnProtoRPC >> (HadoopYarnProtoRPC.java:getProxy(45)) - Creating a HadoopYarnProtoRpc >> proxy for protocol interface org.apache.hadoop.yarn.api.ClientRMProtocol >> 2013-03-29 17:03:00,996 DEBUG master.GlobalEngine >> (GlobalEngine.java:connectRMClient(274)) - Connecting to ResourceManager >> at >> /0.0.0.0:8032 >> 2013-03-29 17:03:01,076 INFO service.AbstractService >> (AbstractService.java:start(94)) - Service:tajo.master.GlobalEngine is >> started. >> 2013-03-29 17:03:01,120 INFO rpc.NettyServerBase >> (NettyServerBase.java:start(84)) - RpcServer on /0:0:0:0:0:0:0:0:9004 >> 2013-03-29 17:03:01,121 INFO master.ClientService >> (ClientService.java:start(93)) - Instantiated ClientService at >> /0:0:0:0:0:0:0:0:9004 >> 2013-03-29 17:03:01,121 INFO service.AbstractService >> (AbstractService.java:start(94)) - Service:tajo.master.ClientService is >> started. >> 2013-03-29 17:03:01,121 INFO service.AbstractService >> (AbstractService.java:start(94)) - Service:tajo.master.TajoMaster is >> started. >> 2013-03-29 17:03:06,933 DEBUG ipc.Client (Client.java:close(1025)) - IPC >> Client (2719739) connection to garfield/192.168.0.103:8020 from tanujit: >> closed >> 2013-03-29 17:03:06,935 DEBUG ipc.Client (Client.java:run(857)) - IPC >> Client (2719739) connection to garfield/192.168.0.103:8020 from tanujit: >> stopped, remaining connections 0 >> 2013-03-29 17:03:38,775 DEBUG store.DBStore >> (DBStore.java:getAllTableNames(745)) - SELECT TABLE_ID from TABLES >> 2013-03-29 17:03:59,233 INFO master.GlobalEngine >> (GlobalEngine.java:executeQuery(146)) - TQL: create table test(x string) >> 2013-03-29 17:03:59,488 DEBUG parser.QueryAnalyzer >> (QueryAnalyzer.java:parse(78)) - Analyzer: (CREATE_TABLE test (TABLE_DEF >> (FIELD_DEF x string))) >> 2013-03-29 17:03:59,489 INFO planner.LogicalPlanner >> (LogicalPlanner.java:createPlanInternal(109)) - Planning store statement >> Mar 29, 2013 5:03:59 PM org.jboss.netty.channel.DefaultChannelPipeline >> WARNING: An exception was thrown by a user handler while handling an >> exception event ([id: 0x0194df96, /192.168.0.103:48058 => / >> 192.168.0.103:9004] EXCEPTION: tajo.rpc.RemoteCallException: Remote call >> error occurs when ClientProtocolService.submitQueryis called:) >> tajo.rpc.RemoteException: tajo.rpc.RemoteCallException: Remote call error >> occurs when ClientProtocolService.submitQueryis called: >> at >> >> tajo.rpc.ProtoBlockingRpcServer$ServerHandler.exceptionCaught(ProtoBlockingRpcServer.java:121) >> at >> >> org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:66) >> at >> >> org.jboss.netty.handler.codec.frame.FrameDecoder.exceptionCaught(FrameDecoder.java:238) >> at org.jboss.netty.channel.Channels.fireExceptionCaught(Channels.java:432) >> at >> >> org.jboss.netty.channel.AbstractChannelSink.exceptionCaught(AbstractChannelSink.java:52) >> at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302) >> at >> >> org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:76) >> at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302) >> at >> >> org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:317) >> at >> >> org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:299) >> at >> >> org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:216) >> at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:274) >> at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:261) >> at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:349) >> at >> >> org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:280) >> at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:200) >> at >> >> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) >> at >> >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) >> at java.lang.Thread.run(Thread.java:662) >> Caused by: tajo.rpc.RemoteCallException: Remote call error occurs when >> ClientProtocolService.submitQueryis called: >> at >> >> tajo.rpc.ProtoBlockingRpcServer$ServerHandler.messageReceived(ProtoBlockingRpcServer.java:97) >> ... 14 more >> Caused by: java.lang.NullPointerException >> at >> >> tajo.client.ClientProtocol$SubmitQueryRespose$Builder.setErrorMessage(ClientProtocol.java:2932) >> at >> >> tajo.master.ClientService$ClientProtocolHandler.submitQuery(ClientService.java:135) >> at >> >> tajo.client.ClientProtocol$ClientProtocolService$2.callBlockingMethod(ClientProtocol.java:11912) >> at >> >> tajo.rpc.ProtoBlockingRpcServer$ServerHandler.messageReceived(ProtoBlockingRpcServer.java:94) >> ... 14 more >> >> >> Is there some setting that i have done wrong ? >> I cant quite figure it out. >> >> >> Regards, >> Tanujit >> > >
