Is there a way to let Tajo take the hostname that i put in the workers file, instead of the worker's network name? Also yeah, on hdfs, it worked fine, but i had a table related to a txt file, when i executed the query, the worker didn't find the file, so, i copied the file to the worker directory and all just fine. I guess i need to move it to hdfs too. Thanks!
2015-09-29 4:40 GMT-05:00 Jihoon Son <[email protected]>: > Great! you went to the next step. > Tajo is just a query execution engine, and has a support of a wide range > of data sources. > If you want to use Tajo with the distributed mode, you first need to put > your data on some distributed file systems like HDFS or S3. > > Thanks, > Jihoon > > 2015년 9월 29일 (화) 오전 7:18, Odin Guillermo Caudillo Gallegos < > [email protected]>님이 작성: > >> Ok, just lo let you know, i added the name of the node that showed on the >> log and worked, i wonder why it doesn't just take the other name that i >> gave it, now, if i had some tables on the master node, how can i replicate >> it to the worker node? like the replication master - > datanode that hadoop >> have? >> Thank you for your help! >> >> 2015-09-28 17:02 GMT-05:00 Odin Guillermo Caudillo Gallegos < >> [email protected]>: >> >>> I put the replica of the tajo-site.xml master into the worker config. >>> The strange thing here, is that when the QueryMaster is trying to >>> connect to the worker node, it doesn't follow the host name, it try by the >>> name of the node instead. I'll add that name on the hosts file of the >>> master node. >>> Thanks >>> >>> 2015-09-28 15:52 GMT-05:00 Jihoon Son <[email protected]>: >>> >>>> Hi Odin, I checked your tajo-site files. >>>> First, you need to enable tajo.catalog.client-rpc.address configuration. >>>> In addition, the tajo-site.xml file of tajo workers must be identical >>>> to that of tajo master. >>>> >>>> However, the above error message means that 'worker1' cannot be >>>> resolved. So, maybe there are some problems in resolving this address. >>>> >>>> Thanks, >>>> Jihoon >>>> >>>> 2015년 9월 29일 (화) 오전 2:19, Odin Guillermo Caudillo Gallegos < >>>> [email protected]>님이 작성: >>>> >>>>> Ok, i'll take a look with the hosts. >>>>> Thank you >>>>> >>>>> 2015-09-28 12:17 GMT-05:00 Jihoon Son <[email protected]>: >>>>> >>>>>> Hi Odin, sorry for late response. >>>>>> I'm participating in ApacheCon now, so couldn't check your >>>>>> configurations yet. >>>>>> However, some addresses of the machines in your cluster cannot be >>>>>> resolved. Would you please check it? >>>>>> I'll also check your configuration soon. >>>>>> >>>>>> Thank, >>>>>> Jihoon >>>>>> 2015년 9월 28일 (월) 오후 4:37, Odin Guillermo Caudillo Gallegos < >>>>>> [email protected]>님이 작성: >>>>>> >>>>>>> hi, can you help me with this please? or can you give me a proper >>>>>>> example on how need to be configured? >>>>>>> Thanks. >>>>>>> >>>>>>> 2015-09-25 9:56 GMT-05:00 Odin Guillermo Caudillo Gallegos < >>>>>>> [email protected]>: >>>>>>> >>>>>>>> Hi. >>>>>>>> Here's both, worker and master tajo-site.xml >>>>>>>> >>>>>>>> 2015-09-24 21:49 GMT-05:00 Hyunsik Choi <[email protected]>: >>>>>>>> >>>>>>>>> Hi, >>>>>>>>> >>>>>>>>> Could you share your conf/tajo-site.xml? I suspect >>>>>>>>> misconfiguration. >>>>>>>>> >>>>>>>>> Best regards, >>>>>>>>> Hyunsik >>>>>>>>> >>>>>>>>> On Thu, Sep 24, 2015 at 8:00 AM, Odin Guillermo Caudillo Gallegos >>>>>>>>> <[email protected]> wrote: >>>>>>>>> > Hi, i'm getting the following trace when i execute a query over >>>>>>>>> tsql. >>>>>>>>> > I get telnet connection between the Master and the worker. >>>>>>>>> > Did i miss something in the worker config? >>>>>>>>> > Thanks >>>>>>>>> > >>>>>>>>> > 2015-09-23 17:43:46,307 INFO >>>>>>>>> org.apache.tajo.master.QueryInProgress: >>>>>>>>> > Initializing QueryInProgress for QueryID=q_1443048215415_0001 >>>>>>>>> > 2015-09-23 17:43:46,308 INFO >>>>>>>>> org.apache.tajo.master.exec.QueryExecutor: >>>>>>>>> > Query q_1443048215415_0001,SELECT ac.* FROM ac, ip WHERE ac.ip = >>>>>>>>> ip.ips, is >>>>>>>>> > forwarded to :0 >>>>>>>>> > 2015-09-23 17:43:46,539 INFO >>>>>>>>> org.apache.tajo.master.QueryInProgress: Connect >>>>>>>>> > to QueryMaster:worker1:28093 >>>>>>>>> > 2015-09-23 17:43:46,574 WARN >>>>>>>>> org.apache.tajo.rpc.NettyClientBase: null Try >>>>>>>>> > to reconnect >>>>>>>>> > 2015-09-23 17:43:47,578 WARN >>>>>>>>> org.apache.tajo.rpc.NettyClientBase: null Try >>>>>>>>> > to reconnect >>>>>>>>> > 2015-09-23 17:43:48,581 WARN >>>>>>>>> org.apache.tajo.rpc.NettyClientBase: null Try >>>>>>>>> > to reconnect >>>>>>>>> > 2015-09-23 17:43:49,585 ERROR >>>>>>>>> org.apache.tajo.master.QueryInProgress: Failed >>>>>>>>> > to submit query q_1443048215415_0001 to master by exception >>>>>>>>> > io.netty.channel.ConnectTimeoutException: Max retry count has >>>>>>>>> been exceeded. >>>>>>>>> > attempts=3 caused by: >>>>>>>>> java.nio.channels.UnresolvedAddressException >>>>>>>>> > io.netty.channel.ConnectTimeoutException: Max retry count has >>>>>>>>> been exceeded. >>>>>>>>> > attempts=3 caused by: >>>>>>>>> java.nio.channels.UnresolvedAddressException >>>>>>>>> > at >>>>>>>>> org.apache.tajo.rpc.NettyClientBase.doReconnect(NettyClientBase.java:139) >>>>>>>>> > at >>>>>>>>> org.apache.tajo.rpc.NettyClientBase.connect(NettyClientBase.java:118) >>>>>>>>> > at >>>>>>>>> org.apache.tajo.rpc.RpcClientManager.getClient(RpcClientManager.java:96) >>>>>>>>> > at >>>>>>>>> > >>>>>>>>> org.apache.tajo.master.QueryInProgress.connectQueryMaster(QueryInProgress.java:159) >>>>>>>>> > at >>>>>>>>> > >>>>>>>>> org.apache.tajo.master.QueryInProgress.submitQueryToMaster(QueryInProgress.java:178) >>>>>>>>> > at >>>>>>>>> > >>>>>>>>> org.apache.tajo.master.QueryManager$QueryJobManagerEventHandler.handle(QueryManager.java:224) >>>>>>>>> > at >>>>>>>>> > >>>>>>>>> org.apache.tajo.master.QueryManager$QueryJobManagerEventHandler.handle(QueryManager.java:212) >>>>>>>>> > at >>>>>>>>> > >>>>>>>>> org.apache.hadoop.yarn.event.AsyncDispatcher.dispatch(AsyncDispatcher.java:173) >>>>>>>>> > at >>>>>>>>> > >>>>>>>>> org.apache.hadoop.yarn.event.AsyncDispatcher$1.run(AsyncDispatcher.java:106) >>>>>>>>> > at java.lang.Thread.run(Thread.java:745) >>>>>>>>> > >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>> >>>>> >>> >>
