Git Product home page Git Product logo

wasp's Introduction

#Wasp:Megastore&F1-like system#

With the development of NoSQL, HBase gradually become the mainstream of the NoSQL system products. The advantages of HBase is very obvious, but defect is also very obvious. These weaknesses include large data platform business by SQL to NoSQL migration is more complex and application personnel learning cost is quite high, can't support affairs and multidimensional index, eventually making many business can't enjoy from NoSQL system linear development ability. Google internal MegaStore system complements Bigtable,it supports SQL, transactions, indexing, cross-cluster replication in the upper layer of the Bigtable, and became famous applications's storage engine, such as Gmail, APPEngine, and the Android Market.

Therefore, we decided to explore providing cross-row transactions, indexes, SQL function without sacrificing the linear expansion of capacity in the upper layer of the HBase by theoretical model MegaStore. The system provides simple user interface: SQL, the user can do not need to pay attention to the hbase schema design, greatly simplifies the user's data migration and learning costs. To see what's supported, go to our language reference guide, and read more on our wiki.

#Mission#

Become a standard distributed relational database,which's storage engine is nosql system, for example the hbase.

wasp's People

Contributors

alexanderdai avatar haosdent avatar jaywong85 avatar

Stargazers

 avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar

Watchers

 avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar

wasp's Issues

disable failed while one table has a child table which is enabled ,after that,the father table can neither be disabled nor enabled

Disable table fails while this table has a child table which is still enabled ,after that,the father table can neither be disabled nor enabled
i.e.

table user has a child table photo, then i did the following steps:

disable 'user'
there was nothing displayed on the cosole,so i checked the master log ,found following log

2013-09-25 10:11:13,708 INFO com.alibaba.wasp.master.handler.DisableTableHandler: lock table 'user' by DisableTableHandler
2013-09-25 10:11:13,711 INFO com.alibaba.wasp.master.handler.DisableTableHandler: Attempting to disable table user
2013-09-25 10:11:13,719 ERROR com.alibaba.wasp.master.handler.DisableTableHandler: Error trying to disable table user
com.alibaba.wasp.NotAllChildTableDisableException: photo,
at com.alibaba.wasp.master.handler.DisableTableHandler.handleDisableTable(DisableTableHandler.java:140)
at com.alibaba.wasp.master.handler.DisableTableHandler.process(DisableTableHandler.java:108)
at com.alibaba.wasp.executor.EventHandler.run(EventHandler.java:198)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:722)

then do this

disable 'photo'

it's disabled

then i disable 'user' again , i got the following things

wasp(main):016:0> disable 'user'

ERROR: com.alibaba.wasp.TableNotEnabledException: user

Here is some help for this command:
Start disable of named table: e.g. "hbase> disable 't1'"

wasp(main):017:0> enable 'user'

ERROR: com.alibaba.wasp.TableNotDisabledException: user

Here is some help for this command:
Start enable of named table: e.g. "wasp> enable 't1'"

i checked the USER status on master website
http://fmaster:45051/table.jsp?name=USER

Table USER

Table Attributes

Attribute Name Value Description
Enabled true Is the table enabled

so what happened to the table ''user''?

入库的同时,查询报错,无法获取返回的数据

13/08/12 15:17:59 INFO jdbc.JdbcConnection: Connection conn = DriverManager.getConnection("jdbc:wasp:", "", "");
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:host.name=cstor
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:java.version=1.7.0_02
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:java.vendor=Oracle Corporation
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:java.home=C:\Program Files\Java\jre7
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:java.class.path=C:\Users\cstor\workspace\wasp-test\bin;C:\Users\cstor\workspace\wasp-test\lib\activation-1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\aopalliance-1.0.jar;C:\Users\cstor\workspace\wasp-test\lib\asm-3.1.jar;C:\Users\cstor\workspace\wasp-test\lib\avro-1.5.3.jar;C:\Users\cstor\workspace\wasp-test\lib\avro-ipc-1.5.3.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-beanutils-1.7.0.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-beanutils-core-1.8.0.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-cli-1.2.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-codec-1.7.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-collections-3.2.1.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-configuration-1.6.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-digester-1.8.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-el-1.0.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-httpclient-3.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-io-2.4.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-lang-2.6.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-logging-1.1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-math-2.1.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-net-1.4.1.jar;C:\Users\cstor\workspace\wasp-test\lib\core-3.1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\druid-0.2.9.jar;C:\Users\cstor\workspace\wasp-test\lib\ftplet-api-1.0.0.jar;C:\Users\cstor\workspace\wasp-test\lib\ftpserver-core-1.0.0.jar;C:\Users\cstor\workspace\wasp-test\lib\ftpserver-deprecated-1.0.0-M2.jar;C:\Users\cstor\workspace\wasp-test\lib\guava-12.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\hadoop-core-1.0.3.jar;C:\Users\cstor\workspace\wasp-test\lib\hadoop-test-1.0.3.jar;C:\Users\cstor\workspace\wasp-test\lib\hamcrest-core-1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\hbase-0.94.1-tests.jar;C:\Users\cstor\workspace\wasp-test\lib\hbase-0.94.1.jar;C:\Users\cstor\workspace\wasp-test\lib\high-scale-lib-1.1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\hsqldb-1.8.0.10.jar;C:\Users\cstor\workspace\wasp-test\lib\htrace-1.49.jar;C:\Users\cstor\workspace\wasp-test\lib\httpclient-4.1.2.jar;C:\Users\cstor\workspace\wasp-test\lib\httpcore-4.1.3.jar;C:\Users\cstor\workspace\wasp-test\lib\jackson-core-asl-1.8.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jackson-jaxrs-1.8.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jackson-mapper-asl-1.8.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jackson-xc-1.8.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jamon-runtime-2.3.1.jar;C:\Users\cstor\workspace\wasp-test\lib\jasper-compiler-5.5.23.jar;C:\Users\cstor\workspace\wasp-test\lib\jasper-runtime-5.5.23.jar;C:\Users\cstor\workspace\wasp-test\lib\jaxb-api-2.1.jar;C:\Users\cstor\workspace\wasp-test\lib\jaxb-impl-2.2.3-1.jar;C:\Users\cstor\workspace\wasp-test\lib\jersey-core-1.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jersey-json-1.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jersey-server-1.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jets3t-0.7.1.jar;C:\Users\cstor\workspace\wasp-test\lib\jettison-1.3.1.jar;C:\Users\cstor\workspace\wasp-test\lib\jetty-6.1.26.jar;C:\Users\cstor\workspace\wasp-test\lib\jetty-util-6.1.26.jar;C:\Users\cstor\workspace\wasp-test\lib\jruby-complete-1.6.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jsp-2.1-6.1.14.jar;C:\Users\cstor\workspace\wasp-test\lib\jsp-api-2.1-6.1.14.jar;C:\Users\cstor\workspace\wasp-test\lib\jsr305-1.3.9.jar;C:\Users\cstor\workspace\wasp-test\lib\junit-4.10.jar;C:\Users\cstor\workspace\wasp-test\lib\kfs-0.3.jar;C:\Users\cstor\workspace\wasp-test\lib\libthrift-0.8.0.jar;C:\Users\cstor\workspace\wasp-test\lib\log4j-1.2.17.jar;C:\Users\cstor\workspace\wasp-test\lib\metrics-core-2.1.2.jar;C:\Users\cstor\workspace\wasp-test\lib\mina-core-2.0.0-M5.jar;C:\Users\cstor\workspace\wasp-test\lib\mockito-all-1.9.0.jar;C:\Users\cstor\workspace\wasp-test\lib\netty-3.2.4.Final.jar;C:\Users\cstor\workspace\wasp-test\lib\netty-3.5.0.Final.jar;C:\Users\cstor\workspace\wasp-test\lib\oro-2.0.8.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-java-2.4.1.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-java-format-1.2.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-rpc-pro-demo-2.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-rpc-pro-duplex-2.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-streamer-pro-1.2.3.jar;C:\Users\cstor\workspace\wasp-test\lib\servlet-api-2.5-6.1.14.jar;C:\Users\cstor\workspace\wasp-test\lib\slf4j-api-1.4.3.jar;C:\Users\cstor\workspace\wasp-test\lib\slf4j-log4j12-1.4.3.jar;C:\Users\cstor\workspace\wasp-test\lib\snappy-java-1.0.3.2.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-aop-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-asm-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-beans-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-context-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-core-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-expression-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\stax-api-1.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\velocity-1.7.jar;C:\Users\cstor\workspace\wasp-test\lib\wasp-0.10.jar;C:\Users\cstor\workspace\wasp-test\lib\xmlenc-0.52.jar;C:\Users\cstor\workspace\wasp-test\lib\zookeeper-3.4.5.jar
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:java.library.path=C:\Program Files\Java\jre7\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;C:\MinGW\bin;C:\Program Files (x86)\Git\bin;C:\tools\apache-maven-3.0.5\bin;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\AMD APP\bin\x86_64;C:\Program Files (x86)\AMD APP\bin\x86;C:\Windows\system32;C:\Windows;C:\Windows\System32\Wbem;C:\Windows\System32\WindowsPowerShell\v1.0;C:\Program Files (x86)\ATI Technologies\ATI.ACE\Core-Static;C:\Program Files (x86)\Common Files\Ulead Systems\MPEG;C:\Program Files\Common Files\Lenovo;C:\SWTOOLS\ReadyApps;C:\Program Files (x86)\Intel\Services\IPT;C:\Program Files (x86)\Common Files\Lenovo;C:\Program Files\TortoiseSVN\bin;C:\Program Files\MySQL\MySQL Server 5.5\bin;C:\Program Files (x86)\VisualSVN\bin;C:\Program Files (x86)\QuickTime\QTSystem;.
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:java.io.tmpdir=C:\Users\cstor\AppData\Local\Temp
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:java.compiler=
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:os.name=Windows 7
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:os.arch=amd64
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:os.version=6.1
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:user.name=cstor
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:user.home=C:\Users\cstor
13/08/12 15:17:59 INFO zookeeper.ZooKeeper: Client environment:user.dir=C:\Users\cstor\workspace\wasp-test
13/08/12 15:18:00 INFO zookeeper.ZooKeeper: Initiating client connection, connectString=192.168.6.154:2181,192.168.6.152:2181,192.168.6.156:2181,192.168.6.155:2181 sessionTimeout=180000 watcher=fclient:
13/08/12 15:18:00 INFO zookeeper.RecoverableZooKeeper: The identifier of this process is 7276@cstor
13/08/12 15:18:00 INFO zookeeper.ClientCnxn: Opening socket connection to server hx3/192.168.6.154:2181. Will not attempt to authenticate using SASL (unknown error)
13/08/12 15:18:00 INFO zookeeper.ClientCnxn: Socket connection established to hx3/192.168.6.154:2181, initiating session
13/08/12 15:18:00 INFO zookeeper.ClientCnxn: Session establishment complete on server hx3/192.168.6.154:2181, sessionid = 0x2407115b72e0022, negotiated timeout = 180000
1111
13/08/12 15:18:00 INFO ipc.NettyTransceiver: Successfully connected to bookie: hx2/192.168.6.156:50501
13/08/12 15:18:00 INFO client.FClientCallable: withRetries attempt 0 of 10 failed; retrying after sleep of 1000
13/08/12 15:18:01 INFO ipc.NettyTransceiver: Successfully connected to bookie: hx8/192.168.6.158:50501
13/08/12 15:18:02 INFO client.FClientCallable: withRetries attempt 1 of 10 failed; retrying after sleep of 1000
13/08/12 15:18:03 INFO client.FClientCallable: withRetries attempt 2 of 10 failed; retrying after sleep of 1000
13/08/12 15:18:04 INFO ipc.NettyTransceiver: Successfully connected to bookie: hx3/192.168.6.154:50501
13/08/12 15:18:04 INFO client.FClientCallable: withRetries attempt 3 of 10 failed; retrying after sleep of 2000
13/08/12 15:18:06 INFO client.FClientCallable: withRetries attempt 4 of 10 failed; retrying after sleep of 2000
13/08/12 15:18:08 INFO ipc.NettyTransceiver: Successfully connected to bookie: hx5/192.168.6.155:50501
13/08/12 15:18:08 INFO client.FClientCallable: withRetries attempt 5 of 10 failed; retrying after sleep of 4000
13/08/12 15:18:12 INFO client.FClientCallable: withRetries attempt 6 of 10 failed; retrying after sleep of 4000
13/08/12 15:18:16 INFO client.FClientCallable: withRetries attempt 7 of 10 failed; retrying after sleep of 8000
13/08/12 15:18:24 INFO client.FClientCallable: withRetries attempt 8 of 10 failed; retrying after sleep of 16000
13/08/12 15:18:40 INFO client.FClientCallable: withRetries attempt 9 of 10 failed; retrying after sleep of 32000
13/08/12 15:19:12 ERROR result.ResultRemote: FClinet execute sql error
com.alibaba.wasp.client.RetriesExhaustedException: Failed after attempts=10, exceptions:
Mon Aug 12 15:18:00 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:02 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:03 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:04 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:06 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:08 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:12 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:16 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:24 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:40 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException

at com.alibaba.wasp.client.ServerCallable.withRetries(ServerCallable.java:181)
at com.alibaba.wasp.client.FClient.execute(FClient.java:104)
at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:228)
at com.alibaba.wasp.jdbc.result.ResultRemote.<init>(ResultRemote.java:89)
at com.alibaba.wasp.jdbc.command.CommandRemote.executeQuery(CommandRemote.java:119)
at com.alibaba.wasp.jdbc.JdbcStatement.executeQuery(JdbcStatement.java:91)
at com.Select.main(Select.java:32)

Exception in thread "main" java.lang.RuntimeException: com.alibaba.wasp.client.RetriesExhaustedException: Failed after attempts=10, exceptions:
Mon Aug 12 15:18:00 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:02 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:03 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:04 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:06 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:08 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:12 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:16 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:24 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:40 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException

at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:243)
at com.alibaba.wasp.jdbc.result.ResultRemote.<init>(ResultRemote.java:89)
at com.alibaba.wasp.jdbc.command.CommandRemote.executeQuery(CommandRemote.java:119)
at com.alibaba.wasp.jdbc.JdbcStatement.executeQuery(JdbcStatement.java:91)
at com.Select.main(Select.java:32)

Caused by: com.alibaba.wasp.client.RetriesExhaustedException: Failed after attempts=10, exceptions:
Mon Aug 12 15:18:00 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:02 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:03 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:04 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:06 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:08 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:12 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:16 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:24 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException
Mon Aug 12 15:18:40 CST 2013, com.alibaba.wasp.client.FClientCallable@437ef115, java.io.IOException: java.lang.NullPointerException

at com.alibaba.wasp.client.ServerCallable.withRetries(ServerCallable.java:181)
at com.alibaba.wasp.client.FClient.execute(FClient.java:104)
at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:228)
... 4 more

Question about the design

Just curious, where is the code in wasp which related to cross cluster/data center design in megastore paper. Seems to me wasp don't handle this part and all data is reside in one HBase cluster and no replica other than HDFS replica is done?

And if this is true, does this mean that wasp only target at cross row transaction and SQL interface? other part of Megastore design is not included?

connection.close()方法阻塞

名称: main-SendThread(hx2:2181)
状态: RUNNABLE
总阻止数: 5, 总等待数: 0

堆栈跟踪:
sun.nio.ch.WindowsSelectorImpl$SubSelector.poll0(Native Method)
sun.nio.ch.WindowsSelectorImpl$SubSelector.poll(Unknown Source)
sun.nio.ch.WindowsSelectorImpl$SubSelector.access$400(Unknown Source)
sun.nio.ch.WindowsSelectorImpl.doSelect(Unknown Source)
sun.nio.ch.SelectorImpl.lockAndDoSelect(Unknown Source)

  • 已锁定sun.nio.ch.Util$2@74d6041c
  • 已锁定java.util.Collections$UnmodifiableSet@ea80631
  • 已锁定sun.nio.ch.WindowsSelectorImpl@392e827b
    sun.nio.ch.SelectorImpl.select(Unknown Source)
    org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:338)
    org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068)

创建索引问题

问下wasp 创建索引的语法是什么,在wasp shell中测试一直创建不了,命令:

wasp(main):002:0>sql "create index PhotosByTime on Photo(user_id,time desc);"

where clause only support equal condition?

say with following query in wasp shell

query "select * from user where user_id=1" works
+----------+-----------+
| user_id | name |
+----------+-----------+
| 1 | binlijin |
+----------+-----------+

while
query "select * from user where user_id>0"

ERROR: java.sql.SQLException: org.apache.wasp.jdbc.JdbcException: Operate a not supported sql: "Don't get a Index!" [90170-1]

创建索引失败

13/08/05 11:20:46 INFO jdbc.JdbcConnection: Connection conn = DriverManager.getConnection("jdbc:wasp:", "", "");
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:host.name=cstor
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:java.version=1.7.0_02
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:java.vendor=Oracle Corporation
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:java.home=C:\Program Files\Java\jre7
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:java.class.path=C:\Users\cstor\workspace\wasp-test\bin;C:\Users\cstor\workspace\wasp-test\lib\activation-1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\aopalliance-1.0.jar;C:\Users\cstor\workspace\wasp-test\lib\asm-3.1.jar;C:\Users\cstor\workspace\wasp-test\lib\avro-1.5.3.jar;C:\Users\cstor\workspace\wasp-test\lib\avro-ipc-1.5.3.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-beanutils-1.7.0.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-beanutils-core-1.8.0.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-cli-1.2.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-codec-1.7.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-collections-3.2.1.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-configuration-1.6.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-digester-1.8.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-el-1.0.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-httpclient-3.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-io-2.4.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-lang-2.6.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-logging-1.1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-math-2.1.jar;C:\Users\cstor\workspace\wasp-test\lib\commons-net-1.4.1.jar;C:\Users\cstor\workspace\wasp-test\lib\core-3.1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\druid-0.2.9.jar;C:\Users\cstor\workspace\wasp-test\lib\ftplet-api-1.0.0.jar;C:\Users\cstor\workspace\wasp-test\lib\ftpserver-core-1.0.0.jar;C:\Users\cstor\workspace\wasp-test\lib\ftpserver-deprecated-1.0.0-M2.jar;C:\Users\cstor\workspace\wasp-test\lib\guava-12.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\hadoop-core-1.0.3.jar;C:\Users\cstor\workspace\wasp-test\lib\hadoop-test-1.0.3.jar;C:\Users\cstor\workspace\wasp-test\lib\hamcrest-core-1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\hbase-0.94.1-tests.jar;C:\Users\cstor\workspace\wasp-test\lib\hbase-0.94.1.jar;C:\Users\cstor\workspace\wasp-test\lib\high-scale-lib-1.1.1.jar;C:\Users\cstor\workspace\wasp-test\lib\hsqldb-1.8.0.10.jar;C:\Users\cstor\workspace\wasp-test\lib\htrace-1.49.jar;C:\Users\cstor\workspace\wasp-test\lib\httpclient-4.1.2.jar;C:\Users\cstor\workspace\wasp-test\lib\httpcore-4.1.3.jar;C:\Users\cstor\workspace\wasp-test\lib\jackson-core-asl-1.8.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jackson-jaxrs-1.8.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jackson-mapper-asl-1.8.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jackson-xc-1.8.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jamon-runtime-2.3.1.jar;C:\Users\cstor\workspace\wasp-test\lib\jasper-compiler-5.5.23.jar;C:\Users\cstor\workspace\wasp-test\lib\jasper-runtime-5.5.23.jar;C:\Users\cstor\workspace\wasp-test\lib\jaxb-api-2.1.jar;C:\Users\cstor\workspace\wasp-test\lib\jaxb-impl-2.2.3-1.jar;C:\Users\cstor\workspace\wasp-test\lib\jersey-core-1.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jersey-json-1.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jersey-server-1.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jets3t-0.7.1.jar;C:\Users\cstor\workspace\wasp-test\lib\jettison-1.3.1.jar;C:\Users\cstor\workspace\wasp-test\lib\jetty-6.1.26.jar;C:\Users\cstor\workspace\wasp-test\lib\jetty-util-6.1.26.jar;C:\Users\cstor\workspace\wasp-test\lib\jruby-complete-1.6.8.jar;C:\Users\cstor\workspace\wasp-test\lib\jsp-2.1-6.1.14.jar;C:\Users\cstor\workspace\wasp-test\lib\jsp-api-2.1-6.1.14.jar;C:\Users\cstor\workspace\wasp-test\lib\jsr305-1.3.9.jar;C:\Users\cstor\workspace\wasp-test\lib\junit-4.10.jar;C:\Users\cstor\workspace\wasp-test\lib\kfs-0.3.jar;C:\Users\cstor\workspace\wasp-test\lib\libthrift-0.8.0.jar;C:\Users\cstor\workspace\wasp-test\lib\log4j-1.2.17.jar;C:\Users\cstor\workspace\wasp-test\lib\metrics-core-2.1.2.jar;C:\Users\cstor\workspace\wasp-test\lib\mina-core-2.0.0-M5.jar;C:\Users\cstor\workspace\wasp-test\lib\mockito-all-1.9.0.jar;C:\Users\cstor\workspace\wasp-test\lib\netty-3.2.4.Final.jar;C:\Users\cstor\workspace\wasp-test\lib\netty-3.5.0.Final.jar;C:\Users\cstor\workspace\wasp-test\lib\oro-2.0.8.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-java-2.4.1.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-java-format-1.2.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-rpc-pro-demo-2.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-rpc-pro-duplex-2.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\protobuf-streamer-pro-1.2.3.jar;C:\Users\cstor\workspace\wasp-test\lib\servlet-api-2.5-6.1.14.jar;C:\Users\cstor\workspace\wasp-test\lib\slf4j-api-1.4.3.jar;C:\Users\cstor\workspace\wasp-test\lib\slf4j-log4j12-1.4.3.jar;C:\Users\cstor\workspace\wasp-test\lib\snappy-java-1.0.3.2.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-aop-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-asm-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-beans-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-context-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-core-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\spring-expression-3.0.5.RELEASE.jar;C:\Users\cstor\workspace\wasp-test\lib\stax-api-1.0.1.jar;C:\Users\cstor\workspace\wasp-test\lib\velocity-1.7.jar;C:\Users\cstor\workspace\wasp-test\lib\wasp-0.10.jar;C:\Users\cstor\workspace\wasp-test\lib\xmlenc-0.52.jar;C:\Users\cstor\workspace\wasp-test\lib\zookeeper-3.4.5.jar
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:java.library.path=C:\Program Files\Java\jre7\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;C:\MinGW\bin;C:\Program Files (x86)\Git\bin;C:\tools\apache-maven-3.0.5\bin;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\AMD APP\bin\x86_64;C:\Program Files (x86)\AMD APP\bin\x86;C:\Windows\system32;C:\Windows;C:\Windows\System32\Wbem;C:\Windows\System32\WindowsPowerShell\v1.0;C:\Program Files (x86)\ATI Technologies\ATI.ACE\Core-Static;C:\Program Files (x86)\Common Files\Ulead Systems\MPEG;C:\Program Files\Common Files\Lenovo;C:\SWTOOLS\ReadyApps;C:\Program Files (x86)\Intel\Services\IPT;C:\Program Files (x86)\Common Files\Lenovo;C:\Program Files\TortoiseSVN\bin;C:\Program Files\MySQL\MySQL Server 5.5\bin;C:\Program Files (x86)\VisualSVN\bin;C:\Program Files (x86)\QuickTime\QTSystem;.
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:java.io.tmpdir=C:\Users\cstor\AppData\Local\Temp
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:java.compiler=
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:os.name=Windows 7
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:os.arch=amd64
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:os.version=6.1
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:user.name=cstor
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:user.home=C:\Users\cstor
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Client environment:user.dir=C:\Users\cstor\workspace\wasp-test
13/08/05 11:20:46 INFO zookeeper.ZooKeeper: Initiating client connection, connectString=192.168.226.100:2181 sessionTimeout=180000 watcher=fclient:
13/08/05 11:20:46 INFO zookeeper.RecoverableZooKeeper: The identifier of this process is 10528@cstor
13/08/05 11:20:46 INFO zookeeper.ClientCnxn: Opening socket connection to server master/192.168.226.100:2181. Will not attempt to authenticate using SASL (unknown error)
13/08/05 11:20:46 INFO zookeeper.ClientCnxn: Socket connection established to master/192.168.226.100:2181, initiating session
13/08/05 11:20:46 INFO zookeeper.ClientCnxn: Session establishment complete on server master/192.168.226.100:2181, sessionid = 0x1404c63e0e5002d, negotiated timeout = 180000
13/08/05 11:20:47 INFO ipc.NettyTransceiver: Successfully connected to bookie: slave1/192.168.226.101:50501
13/08/05 11:20:47 ERROR result.ResultRemote: FClinet execute sql error
com.alibaba.wasp.TableNotDisabledException: demo
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Unknown Source)
at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:95)
at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:79)
at com.alibaba.wasp.ipc.NettyTransceiver.processResponse(NettyTransceiver.java:536)
at com.alibaba.wasp.ipc.NettyTransceiver.call(NettyTransceiver.java:496)
at com.alibaba.wasp.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:162)
at $Proxy4.execute(Unknown Source)
at com.alibaba.wasp.client.FClientCallable.call(FClientCallable.java:91)
at com.alibaba.wasp.client.FClientCallable.call(FClientCallable.java:34)
at com.alibaba.wasp.client.ServerCallable.withRetries(ServerCallable.java:150)
at com.alibaba.wasp.client.FClient.execute(FClient.java:104)
at com.alibaba.wasp.client.FClient.execute(FClient.java:128)
at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:233)
at com.alibaba.wasp.jdbc.result.ResultRemote.(ResultRemote.java:89)
at com.alibaba.wasp.jdbc.result.ResultRemote.(ResultRemote.java:95)
at com.alibaba.wasp.jdbc.command.CommandRemote.executeUpdate(CommandRemote.java:153)
at com.alibaba.wasp.jdbc.JdbcStatement.executeUpdateInternal(JdbcStatement.java:723)
at com.alibaba.wasp.jdbc.JdbcStatement.executeUpdate(JdbcStatement.java:120)
at com.Test.main(Test.java:37)
Caused by: org.apache.hadoop.ipc.RemoteException: demo
at com.alibaba.wasp.ipc.NettyTransceiver.processResponse(NettyTransceiver.java:533)
... 15 more
Exception in thread "main" java.lang.RuntimeException: com.alibaba.wasp.TableNotDisabledException: demo
at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:243)
at com.alibaba.wasp.jdbc.result.ResultRemote.(ResultRemote.java:89)
at com.alibaba.wasp.jdbc.result.ResultRemote.(ResultRemote.java:95)
at com.alibaba.wasp.jdbc.command.CommandRemote.executeUpdate(CommandRemote.java:153)
at com.alibaba.wasp.jdbc.JdbcStatement.executeUpdateInternal(JdbcStatement.java:723)
at com.alibaba.wasp.jdbc.JdbcStatement.executeUpdate(JdbcStatement.java:120)
at com.Test.main(Test.java:37)
Caused by: com.alibaba.wasp.TableNotDisabledException: demo
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Unknown Source)
at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:95)
at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:79)
at com.alibaba.wasp.ipc.NettyTransceiver.processResponse(NettyTransceiver.java:536)
at com.alibaba.wasp.ipc.NettyTransceiver.call(NettyTransceiver.java:496)
at com.alibaba.wasp.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:162)
at $Proxy4.execute(Unknown Source)
at com.alibaba.wasp.client.FClientCallable.call(FClientCallable.java:91)
at com.alibaba.wasp.client.FClientCallable.call(FClientCallable.java:34)
at com.alibaba.wasp.client.ServerCallable.withRetries(ServerCallable.java:150)
at com.alibaba.wasp.client.FClient.execute(FClient.java:104)
at com.alibaba.wasp.client.FClient.execute(FClient.java:128)
at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:233)
... 6 more
Caused by: org.apache.hadoop.ipc.RemoteException: demo
at com.alibaba.wasp.ipc.NettyTransceiver.processResponse(NettyTransceiver.java:533)
... 15 more

compare condition not working right

" > acting as >= "
" and <= acting as <"

As following:

wasp(main):044:0> query "select * from Photo where user_id>3"
+----------+-----------+-----------+-----------+----------------+-------+
| user_id | photo_id | time | full_url | thumbnail_url | tag |
+----------+-----------+-----------+-----------+----------------+-------+
| 5 | 501 | 20130728 | fullurl2 | thumburl2 | tag2 |
| 6 | 601 | 20130728 | fullurl2 | thumburl2 | tag2 |
+----------+-----------+-----------+-----------+----------------+-------+

wasp(main):045:0> query "select * from Photo where user_id<=6"
+----------+-----------+-----------+-----------+----------------+-------+
| user_id | photo_id | time | full_url | thumbnail_url | tag |
+----------+-----------+-----------+-----------+----------------+-------+
| 5 | 501 | 20130728 | fullurl2 | thumburl2 | tag2 |
+----------+-----------+-----------+-----------+----------------+-------+

wasp(main):046:0> query "select * from Photo where user_id>5"
+----------+-----------+-----------+-----------+----------------+-------+
| user_id | photo_id | time | full_url | thumbnail_url | tag |
+----------+-----------+-----------+-----------+----------------+-------+
| 5 | 501 | 20130728 | fullurl2 | thumburl2 | tag2 |
| 6 | 601 | 20130728 | fullurl2 | thumburl2 | tag2 |
+----------+-----------+-----------+-----------+----------------+-------+

现在最新版本的wasp支持多个范围条件的查询吗?

在《海量数据分布式数据库的探索》资料中看到,wasp的二级索引描述中有一项:受限的的范围条件(where条件中同时最多支 持一个范围条件),我想知道最新版本的wasp最多支持几个范围条件的查询?
如果当前版本不支持多个范围条件的查询,那么在wasp的roadmap中对于这方面的计划是什么?
另外,当前wasp是一个实验室版本还是达到产品化要求的版本?

以上,这些决定了我们要不要选择wasp作为我们的技术解决方案。

谢谢!

fserver web ui port 50030?

by wiki, Wasp fserver基于WEB的UI服务端口默认为50030

while, in the config file, wasp-default.xml, the wasp.fserver.info.port is set to 5051

are these the same thing? or some of them should be fmaster's web ui port? any way I am confused.

And , then, 50030 is map reduce jobtracker's default port, shouldn't we pick another port number to avoid conflict?

finally, what is the web page looks like ?

in my set up. no mater 5051 or 60080 port, the page show only :

Directory: /

WEB-INF/ 4096 bytes Jul 29, 2013 9:04:33 AM

nothing else. though I do have created table through wasp shell.

wasp目前有批量导入功能么

目前wasp提供批量导入数据接口么,像phonix一样提供一个批量导入的脚本psql.sh;毕竟做性能测试需要导入大量数据,难道目前只能循环调用insert么?

sql "create table tabname(userid INT32)" failed

wasp(main):001:0> status
3 servers, 0 dead, 0.0000 average load
wasp(main):002:0> sql "create table tabname(userid INT32)"

13/07/30 14:08:29 ERROR result.ResultRemote: FClinet execute sql error
org.apache.hadoop.hbase.DoNotRetryIOException: syntax error, expect RPAREN, actual IDENTIFIER userid
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:525)
at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:95)
at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:79)
at com.alibaba.wasp.ipc.NettyTransceiver.processResponse(NettyTransceiver.java:536)
at com.alibaba.wasp.ipc.NettyTransceiver.call(NettyTransceiver.java:496)
at com.alibaba.wasp.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:162)
at com.sun.proxy.$Proxy12.execute(Unknown Source)
at com.alibaba.wasp.client.FClientCallable.call(FClientCallable.java:91)
at com.alibaba.wasp.client.FClientCallable.call(FClientCallable.java:34)
at com.alibaba.wasp.client.ServerCallable.withRetries(ServerCallable.java:150)
at com.alibaba.wasp.client.FClient.execute(FClient.java:104)
at com.alibaba.wasp.client.FClient.execute(FClient.java:128)
at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:233)
at com.alibaba.wasp.jdbc.result.ResultRemote.(ResultRemote.java:89)
at com.alibaba.wasp.jdbc.result.ResultRemote.(ResultRemote.java:95)
at com.alibaba.wasp.jdbc.command.CommandRemote.executeUpdate(CommandRemote.java:153)
at com.alibaba.wasp.jdbc.JdbcStatement.executeInternal(JdbcStatement.java:774)
at com.alibaba.wasp.jdbc.JdbcStatement.execute(JdbcStatement.java:139)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(JavaMethod.java:450)
at org.jruby.javasupport.JavaMethod.invokeDirect(JavaMethod.java:311)
at org.jruby.java.invokers.InstanceMethodInvoker.call(InstanceMethodInvoker.java:59)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:312)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:169)
at org.jruby.ast.CallOneArgNode.interpret(CallOneArgNode.java:57)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:233)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:215)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:332)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:203)
at org.jruby.ast.CallTwoArgNode.interpret(CallTwoArgNode.java:59)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:190)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:199)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:312)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:169)
at org.jruby.ast.FCallSpecialArgNode.interpret(FCallSpecialArgNode.java:39)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:295)
at org.jruby.runtime.InterpretedBlock.yieldSpecific(InterpretedBlock.java:229)
at org.jruby.runtime.Block.yieldSpecific(Block.java:99)
at org.jruby.ast.ZYieldNode.interpret(ZYieldNode.java:25)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.RescueNode.executeBody(RescueNode.java:216)
at org.jruby.ast.RescueNode.interpretWithJavaExceptions(RescueNode.java:120)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:110)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:212)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:207)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:322)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:178)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:187)
at org.jruby.ast.FCallSpecialArgBlockNode.interpret(FCallSpecialArgBlockNode.java:36)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.RescueNode.executeBody(RescueNode.java:216)
at org.jruby.ast.RescueNode.interpretWithJavaExceptions(RescueNode.java:120)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:110)
at org.jruby.ast.EnsureNode.interpret(EnsureNode.java:96)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:233)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:215)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:332)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:203)
at org.jruby.ast.CallSpecialArgNode.interpret(CallSpecialArgNode.java:69)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:233)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:215)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:332)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:203)
at org.jruby.ast.CallSpecialArgNode.interpret(CallSpecialArgNode.java:69)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:190)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:199)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:312)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:169)
at org.jruby.ast.FCallOneArgNode.interpret(FCallOneArgNode.java:36)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.RootNode.interpret(RootNode.java:129)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_EVAL(ASTInterpreter.java:95)
at org.jruby.evaluator.ASTInterpreter.evalWithBinding(ASTInterpreter.java:166)
at org.jruby.RubyKernel.evalCommon(RubyKernel.java:1155)
at org.jruby.RubyKernel.eval(RubyKernel.java:1112)
at org.jruby.RubyKernel$s$0$3$eval.call(RubyKernel$s$0$3$eval.gen:65535)
at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:181)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:69)
at org.jruby.ast.FCallManyArgsNode.interpret(FCallManyArgsNode.java:60)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:120)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:134)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:174)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:69)
at org.jruby.ast.CallManyArgsNode.interpret(CallManyArgsNode.java:59)
at org.jruby.ast.FCallOneArgNode.interpret(FCallOneArgNode.java:36)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:233)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:215)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:201)
at org.jruby.ast.CallTwoArgNode.interpret(CallTwoArgNode.java:59)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.ast.RescueNode.executeBody(RescueNode.java:216)
at org.jruby.ast.RescueNode.interpretWithJavaExceptions(RescueNode.java:120)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:110)
at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:295)
at org.jruby.runtime.InterpretedBlock.yieldSpecific(InterpretedBlock.java:229)
at org.jruby.runtime.Block.yieldSpecific(Block.java:99)
at org.jruby.ast.ZYieldNode.interpret(ZYieldNode.java:25)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.EnsureNode.interpret(EnsureNode.java:96)
at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:212)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:207)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:176)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:187)
at org.jruby.ast.FCallOneArgBlockNode.interpret(FCallOneArgBlockNode.java:34)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yieldSpecific(InterpretedBlock.java:260)
at org.jruby.runtime.Block.yieldSpecific(Block.java:117)
at org.jruby.ast.YieldTwoNode.interpret(YieldTwoNode.java:31)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.IfNode.interpret(IfNode.java:117)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.ast.RescueNode.executeBody(RescueNode.java:216)
at org.jruby.ast.RescueNode.interpretWithJavaExceptions(RescueNode.java:120)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:110)
at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:295)
at org.jruby.runtime.InterpretedBlock.yieldSpecific(InterpretedBlock.java:229)
at org.jruby.runtime.Block.yieldSpecific(Block.java:99)
at org.jruby.RubyKernel.loop(RubyKernel.java:1439)
at org.jruby.RubyKernel$s$0$0$loop.call(RubyKernel$s$0$0$loop.gen:65535)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:302)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:144)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:153)
at org.jruby.ast.FCallNoArgBlockNode.interpret(FCallNoArgBlockNode.java:32)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:347)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:304)
at org.jruby.runtime.Block.yield(Block.java:130)
at org.jruby.RubyContinuation.enter(RubyContinuation.java:106)
at org.jruby.RubyKernel.rbCatch(RubyKernel.java:1212)
at org.jruby.RubyKernel$s$1$0$rbCatch.call(RubyKernel$s$1$0$rbCatch.gen:65535)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:322)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:178)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:187)
at org.jruby.ast.FCallOneArgBlockNode.interpret(FCallOneArgBlockNode.java:34)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:169)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:191)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:302)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:144)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:153)
at org.jruby.ast.CallNoArgBlockNode.interpret(CallNoArgBlockNode.java:64)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:147)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:183)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:292)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:135)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.block_2$RUBY$start(/home/hadoopj/wasp-master/bin/../bin/wirb.rb:192)
at home$hadoopj$wasp_minus_master$bin$$dot_dot$bin$wirb$block_2$RUBY$start.call(home$hadoopj$wasp_minus_master$bin$$dot_dot$bin$wirb$block_2$RUBY$start:65535)
at org.jruby.runtime.CompiledBlock.yield(CompiledBlock.java:112)
at org.jruby.runtime.CompiledBlock.yield(CompiledBlock.java:95)
at org.jruby.runtime.Block.yield(Block.java:130)
at org.jruby.RubyContinuation.enter(RubyContinuation.java:106)
at org.jruby.RubyKernel.rbCatch(RubyKernel.java:1212)
at org.jruby.RubyKernel$s$1$0$rbCatch.call(RubyKernel$s$1$0$rbCatch.gen:65535)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:322)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:178)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:187)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.chained_7_ensure_1$RUBY$ensure(/home/hadoopj/wasp-master/bin/../bin/wirb.rb:191)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.method__6$RUBY$start(/home/hadoopj/wasp-master/bin/../bin/wirb.rb:191)
at home$hadoopj$wasp_minus_master$bin$$dot_dot$bin$wirb$method__6$RUBY$start.call(home$hadoopj$wasp_minus_master$bin$$dot_dot$bin$wirb$method__6$RUBY$start:65535)
at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:203)
at org.jruby.internal.runtime.methods.CompiledMethod.call(CompiledMethod.java:255)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:292)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:135)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.file(/home/hadoopj/wasp-master/bin/../bin/wirb.rb:200)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.load(/home/hadoopj/wasp-master/bin/../bin/wirb.rb)
at org.jruby.Ruby.runScript(Ruby.java:697)
at org.jruby.Ruby.runScript(Ruby.java:690)
at org.jruby.Ruby.runNormally(Ruby.java:597)
at org.jruby.Ruby.runFromMain(Ruby.java:446)
at org.jruby.Main.doRunFromMain(Main.java:369)
at org.jruby.Main.internalRun(Main.java:258)
at org.jruby.Main.run(Main.java:224)
at org.jruby.Main.run(Main.java:208)
at org.jruby.Main.main(Main.java:188)
Caused by: org.apache.hadoop.ipc.RemoteException: syntax error, expect RPAREN, actual IDENTIFIER userid
at com.alibaba.wasp.ipc.NettyTransceiver.processResponse(NettyTransceiver.java:533)
... 216 more
13/07/30 14:08:29 ERROR jdbc.JdbcStatement: exception
com.alibaba.wasp.jdbc.JdbcSQLException: General error: "java.lang.RuntimeException: org.apache.hadoop.hbase.DoNotRetryIOException: syntax error, expect RPAREN, actual IDENTIFIER userid" [50000-1]
at com.alibaba.wasp.jdbc.JdbcException.getJdbcSQLException(JdbcException.java:111)
at com.alibaba.wasp.jdbc.JdbcException.get(JdbcException.java:176)
at com.alibaba.wasp.jdbc.JdbcException.convert(JdbcException.java:160)
at com.alibaba.wasp.jdbc.JdbcException.toSQLException(JdbcException.java:226)
at com.alibaba.wasp.jdbc.Logger.logAndConvert(Logger.java:35)
at com.alibaba.wasp.jdbc.JdbcStatement.execute(JdbcStatement.java:141)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(JavaMethod.java:450)
at org.jruby.javasupport.JavaMethod.invokeDirect(JavaMethod.java:311)
at org.jruby.java.invokers.InstanceMethodInvoker.call(InstanceMethodInvoker.java:59)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:312)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:169)
at org.jruby.ast.CallOneArgNode.interpret(CallOneArgNode.java:57)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:233)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:215)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:332)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:203)
at org.jruby.ast.CallTwoArgNode.interpret(CallTwoArgNode.java:59)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:190)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:199)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:312)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:169)
at org.jruby.ast.FCallSpecialArgNode.interpret(FCallSpecialArgNode.java:39)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:295)
at org.jruby.runtime.InterpretedBlock.yieldSpecific(InterpretedBlock.java:229)
at org.jruby.runtime.Block.yieldSpecific(Block.java:99)
at org.jruby.ast.ZYieldNode.interpret(ZYieldNode.java:25)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.RescueNode.executeBody(RescueNode.java:216)
at org.jruby.ast.RescueNode.interpretWithJavaExceptions(RescueNode.java:120)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:110)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:212)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:207)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:322)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:178)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:187)
at org.jruby.ast.FCallSpecialArgBlockNode.interpret(FCallSpecialArgBlockNode.java:36)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.RescueNode.executeBody(RescueNode.java:216)
at org.jruby.ast.RescueNode.interpretWithJavaExceptions(RescueNode.java:120)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:110)
at org.jruby.ast.EnsureNode.interpret(EnsureNode.java:96)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:233)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:215)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:332)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:203)
at org.jruby.ast.CallSpecialArgNode.interpret(CallSpecialArgNode.java:69)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:233)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:215)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:332)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:203)
at org.jruby.ast.CallSpecialArgNode.interpret(CallSpecialArgNode.java:69)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:190)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:199)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:312)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:169)
at org.jruby.ast.FCallOneArgNode.interpret(FCallOneArgNode.java:36)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.RootNode.interpret(RootNode.java:129)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_EVAL(ASTInterpreter.java:95)
at org.jruby.evaluator.ASTInterpreter.evalWithBinding(ASTInterpreter.java:166)
at org.jruby.RubyKernel.evalCommon(RubyKernel.java:1155)
at org.jruby.RubyKernel.eval(RubyKernel.java:1112)
at org.jruby.RubyKernel$s$0$3$eval.call(RubyKernel$s$0$3$eval.gen:65535)
at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:181)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:69)
at org.jruby.ast.FCallManyArgsNode.interpret(FCallManyArgsNode.java:60)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:120)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:134)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:174)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:69)
at org.jruby.ast.CallManyArgsNode.interpret(CallManyArgsNode.java:59)
at org.jruby.ast.FCallOneArgNode.interpret(FCallOneArgNode.java:36)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:233)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:215)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:201)
at org.jruby.ast.CallTwoArgNode.interpret(CallTwoArgNode.java:59)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.ast.RescueNode.executeBody(RescueNode.java:216)
at org.jruby.ast.RescueNode.interpretWithJavaExceptions(RescueNode.java:120)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:110)
at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:295)
at org.jruby.runtime.InterpretedBlock.yieldSpecific(InterpretedBlock.java:229)
at org.jruby.runtime.Block.yieldSpecific(Block.java:99)
at org.jruby.ast.ZYieldNode.interpret(ZYieldNode.java:25)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.EnsureNode.interpret(EnsureNode.java:96)
at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:212)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:207)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:176)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:187)
at org.jruby.ast.FCallOneArgBlockNode.interpret(FCallOneArgBlockNode.java:34)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yieldSpecific(InterpretedBlock.java:260)
at org.jruby.runtime.Block.yieldSpecific(Block.java:117)
at org.jruby.ast.YieldTwoNode.interpret(YieldTwoNode.java:31)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.IfNode.interpret(IfNode.java:117)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.ast.RescueNode.executeBody(RescueNode.java:216)
at org.jruby.ast.RescueNode.interpretWithJavaExceptions(RescueNode.java:120)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:110)
at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:295)
at org.jruby.runtime.InterpretedBlock.yieldSpecific(InterpretedBlock.java:229)
at org.jruby.runtime.Block.yieldSpecific(Block.java:99)
at org.jruby.RubyKernel.loop(RubyKernel.java:1439)
at org.jruby.RubyKernel$s$0$0$loop.call(RubyKernel$s$0$0$loop.gen:65535)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:302)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:144)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:153)
at org.jruby.ast.FCallNoArgBlockNode.interpret(FCallNoArgBlockNode.java:32)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:111)
at org.jruby.runtime.InterpretedBlock.evalBlockBody(InterpretedBlock.java:374)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:347)
at org.jruby.runtime.InterpretedBlock.yield(InterpretedBlock.java:304)
at org.jruby.runtime.Block.yield(Block.java:130)
at org.jruby.RubyContinuation.enter(RubyContinuation.java:106)
at org.jruby.RubyKernel.rbCatch(RubyKernel.java:1212)
at org.jruby.RubyKernel$s$1$0$rbCatch.call(RubyKernel$s$1$0$rbCatch.gen:65535)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:322)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:178)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:187)
at org.jruby.ast.FCallOneArgBlockNode.interpret(FCallOneArgBlockNode.java:34)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:169)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:191)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:302)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:144)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:153)
at org.jruby.ast.CallNoArgBlockNode.interpret(CallNoArgBlockNode.java:64)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:104)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:147)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:183)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:292)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:135)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.block_2$RUBY$start(/home/hadoopj/wasp-master/bin/../bin/wirb.rb:192)
at home$hadoopj$wasp_minus_master$bin$$dot_dot$bin$wirb$block_2$RUBY$start.call(home$hadoopj$wasp_minus_master$bin$$dot_dot$bin$wirb$block_2$RUBY$start:65535)
at org.jruby.runtime.CompiledBlock.yield(CompiledBlock.java:112)
at org.jruby.runtime.CompiledBlock.yield(CompiledBlock.java:95)
at org.jruby.runtime.Block.yield(Block.java:130)
at org.jruby.RubyContinuation.enter(RubyContinuation.java:106)
at org.jruby.RubyKernel.rbCatch(RubyKernel.java:1212)
at org.jruby.RubyKernel$s$1$0$rbCatch.call(RubyKernel$s$1$0$rbCatch.gen:65535)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:322)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:178)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:187)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.chained_7_ensure_1$RUBY$ensure(/home/hadoopj/wasp-master/bin/../bin/wirb.rb:191)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.method__6$RUBY$start(/home/hadoopj/wasp-master/bin/../bin/wirb.rb:191)
at home$hadoopj$wasp_minus_master$bin$$dot_dot$bin$wirb$method__6$RUBY$start.call(home$hadoopj$wasp_minus_master$bin$$dot_dot$bin$wirb$method__6$RUBY$start:65535)
at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:203)
at org.jruby.internal.runtime.methods.CompiledMethod.call(CompiledMethod.java:255)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:292)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:135)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.file(/home/hadoopj/wasp-master/bin/../bin/wirb.rb:200)
at home.hadoopj.wasp_minus_master.bin.$dot_dot.bin.wirb.load(/home/hadoopj/wasp-master/bin/../bin/wirb.rb)
at org.jruby.Ruby.runScript(Ruby.java:697)
at org.jruby.Ruby.runScript(Ruby.java:690)
at org.jruby.Ruby.runNormally(Ruby.java:597)
at org.jruby.Ruby.runFromMain(Ruby.java:446)
at org.jruby.Main.doRunFromMain(Main.java:369)
at org.jruby.Main.internalRun(Main.java:258)
at org.jruby.Main.run(Main.java:224)
at org.jruby.Main.run(Main.java:208)
at org.jruby.Main.main(Main.java:188)
Caused by: java.lang.RuntimeException: org.apache.hadoop.hbase.DoNotRetryIOException: syntax error, expect RPAREN, actual IDENTIFIER userid
at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:243)
at com.alibaba.wasp.jdbc.result.ResultRemote.(ResultRemote.java:89)
at com.alibaba.wasp.jdbc.result.ResultRemote.(ResultRemote.java:95)
at com.alibaba.wasp.jdbc.command.CommandRemote.executeUpdate(CommandRemote.java:153)
at com.alibaba.wasp.jdbc.JdbcStatement.executeInternal(JdbcStatement.java:774)
at com.alibaba.wasp.jdbc.JdbcStatement.execute(JdbcStatement.java:139)
... 202 more
Caused by: org.apache.hadoop.hbase.DoNotRetryIOException: syntax error, expect RPAREN, actual IDENTIFIER userid
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:525)
at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:95)
at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:79)
at com.alibaba.wasp.ipc.NettyTransceiver.processResponse(NettyTransceiver.java:536)
at com.alibaba.wasp.ipc.NettyTransceiver.call(NettyTransceiver.java:496)
at com.alibaba.wasp.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:162)
at com.sun.proxy.$Proxy12.execute(Unknown Source)
at com.alibaba.wasp.client.FClientCallable.call(FClientCallable.java:91)
at com.alibaba.wasp.client.FClientCallable.call(FClientCallable.java:34)
at com.alibaba.wasp.client.ServerCallable.withRetries(ServerCallable.java:150)
at com.alibaba.wasp.client.FClient.execute(FClient.java:104)
at com.alibaba.wasp.client.FClient.execute(FClient.java:128)
at com.alibaba.wasp.jdbc.result.ResultRemote.fetchRows(ResultRemote.java:233)
... 207 more
Caused by: org.apache.hadoop.ipc.RemoteException: syntax error, expect RPAREN, actual IDENTIFIER userid
at com.alibaba.wasp.ipc.NettyTransceiver.processResponse(NettyTransceiver.java:533)
... 216 more

ERROR: com.alibaba.wasp.jdbc.JdbcSQLException: General error: "java.lang.RuntimeException: org.apache.hadoop.hbase.DoNotRetryIOException: syntax error, expect RPAREN, actual IDENTIFIER userid" [50000-1]

Wiki的文档有问题 ?

https://github.com/alibaba/wasp/wiki/DDL%E6%93%8D%E4%BD%9C 这里的文档操作,第一个create table user的例子显示解析错误,然后shell就退出了。

wasp(main):001:0> CREATE TABLE user {REQUIRED INT64 user_id; REQUIRED STRING name;} PRIMARY KEY(user_id), ENTITY GROUP ROOT,ENTITY GROUP KEY(user_id);
SyntaxError: (wasp):1: syntax error, unexpected tCONSTANT

CREATE TABLE user {REQUIRED INT64 user_id; REQUIRED STRING name;} PRIMARY KEY(user_id), ENTITY GROUP ROOT
^

Error: Your application used more stack memory than the default safety cap.
Specify -J-Xss####k to increase it (#### = cap size in KB).
Specify -w for full StackOverflowError stack trace

Index not working on existing data

I can see that when index is created, the index table is empty. the existing data's index won't be created. I can understand this is due to the routing that you create and put index data into index table upon data insert. But this is not a user will expect and you have no way to populate the index table later either. with this condition, the index is really hard to be use.

fserver没有理会wasp.zookeeper.quorum的配置

fserver所在的机器并没有zk,所以一直在尝试localhost:2181


2013-07-25 17:45:02,119 INFO org.apache.zookeeper.ZooKeeper: Initiating client connection, connectString=localhost:2181 sessionTimeout=180000 watcher=hconnection
2013-07-25 17:45:02,143 INFO org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper: The identifier of this process is 18477@data1
2013-07-25 17:45:02,149 INFO org.apache.zookeeper.ClientCnxn: Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (Unable to locate a login configuration)
2013-07-25 17:45:02,157 WARN org.apache.zookeeper.ClientCnxn: Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068)
2013-07-25 17:45:02,269 INFO org.apache.zookeeper.ClientCnxn: Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (Unable to locate a login configuration)
2013-07-25 17:45:02,270 WARN org.apache.zookeeper.ClientCnxn: Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068)
2013-07-25 17:45:02,276 WARN org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper: Possibly transient ZooKeeper exception: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /hbase/master
2013-07-25 17:45:02,277 INFO org.apache.hadoop.hbase.util.RetryCounter: Sleeping 2000ms before retry #1...
2013-07-25 17:45:03,375 INFO org.apache.zookeeper.ClientCnxn: Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (Unable to locate a login configuration)
2013-07-25 17:45:03,375 WARN org.apache.zookeeper.ClientCnxn: Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068)
2013-07-25 17:45:03,477 INFO org.apache.zookeeper.ClientCnxn: Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (Unable to locate a login configuration)
2013-07-25 17:45:03,477 WARN org.apache.zookeeper.ClientCnxn: Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068)


create index的一个问题

创建索引sql如下

create index trackerCar_YYYY_MM on WP_T_PASSCAR_YYYY_MM (WK_KKID,WP_CAPTIME) STORING (WP_CARPLATE)

查询的sql:

select WP_CARPLATE from WP_T_PASSCAR_YYYY_MM where WK_KKID='1398000004' AND WP_CAPTIME>1 and WP_CAPTIME<1376292466807
查询的时候报错如下:

13/08/12 16:39:10 ERROR result.JdbcResultSet: exception
com.alibaba.wasp.jdbc.JdbcSQLException: Column "WP_CARPLATE" not found [42122-1]
at com.alibaba.wasp.jdbc.JdbcException.getJdbcSQLException(JdbcException.java:111)
at com.alibaba.wasp.jdbc.JdbcException.get(JdbcException.java:93)
at com.alibaba.wasp.jdbc.JdbcException.get(JdbcException.java:80)
at com.alibaba.wasp.jdbc.result.JdbcResultSet.getColumnIndex(JdbcResultSet.java:2938)
at com.alibaba.wasp.jdbc.result.JdbcResultSet.get(JdbcResultSet.java:2993)
at com.alibaba.wasp.jdbc.result.JdbcResultSet.getString(JdbcResultSet.java:297)
at com.Select.main(Select.java:37)
Exception in thread "main" com.alibaba.wasp.jdbc.JdbcSQLException: Column "WP_CARPLATE" not found [42122-1]
at com.alibaba.wasp.jdbc.JdbcException.getJdbcSQLException(JdbcException.java:111)
at com.alibaba.wasp.jdbc.JdbcException.get(JdbcException.java:93)
at com.alibaba.wasp.jdbc.JdbcException.get(JdbcException.java:80)
at com.alibaba.wasp.jdbc.result.JdbcResultSet.getColumnIndex(JdbcResultSet.java:2938)
at com.alibaba.wasp.jdbc.result.JdbcResultSet.get(JdbcResultSet.java:2993)
at com.alibaba.wasp.jdbc.result.JdbcResultSet.getString(JdbcResultSet.java:297)
at com.Select.main(Select.java:37)

直接scan 索引表:
MM_139800000301000595169098
1398000003\x00\x01\x00\x00\x014\x column=s:WP_CARPLATE, timestamp=1376294153484, value=\xE5\x86\x80A850TH
97\x01%\xD0\x00WP_T_PASSCAR_YYYY_
MM_139800000301000595169115
1398000003\x00\x01\x00\x00\x014\x column=s:rowkey, timestamp=1376294153484, value=WP_T_PASSCAR_YYYY_MM_139800000301000595169115
97\x01%\xD0\x00WP_T_PASSCAR_YYYY_
MM_139800000301000595169115
1398000003\x00\x01\x00\x00\x014\x column=s:WP_CARPLATE, timestamp=1376294125092, value=\xE5\x86\x80A81359
97\x01X\x98\x00WP_T_PASSCAR_YYYY_
MM_139800000301000595169234
1398000003\x00\x01\x00\x00\x014\x column=s:rowkey, timestamp=1376294125092, value=WP_T_PASSCAR_YYYY_MM_139800000301000595169234
97\x01X\x98\x00WP_T_PASSCAR_YYYY_
MM_139800000301000595169234
^C 1398000003\x00\x01\x00\x00\x014\x column=s:WP_CARPLATE, timestamp=1376294131542, value=\xE5\x86\x80O10009
97\x01h\x00WP_T_PASSCAR_YYYY_MM_ 139800000301000595169276 1398000003\x00\x01\x00\x00\x014\x column=s:rowkey, timestamp=1376294131542, value=WP_T_PASSCAR_YYYY_MM_139800000301000595169276 97\x01h\x00WP_T_PASSCAR_YYYY_MM_
139800000301000595169276

其实是保存了这个字段的

stack overflow upon shell cmd exit

Encounter the following issue every time.

wasp(main):003:0> exit

Error: Your application used more stack memory than the default safety cap.
Specify -J-Xss####k to increase it (#### = cap size in KB).
Specify -w for full StackOverflowError stack trace

Won;t work even I enlarge Xss from default 1024K to say 8192K etc. seems to me there must be something wrong.

the wiki page is out of date.

Hi

I can see that the wiki page is some how out of date and not sync with current code?

e.g. to do a select * from user where user_id=1

you won't be able to use
sql "select * from user where user_id=1"
you must use
query "select * from user where user_id=1"

And btw. why need to use sql/query etc? if must, why two keywords....

And some DDL need to be run with sql, say create table, while some DDL could not , and need to be run directly in shell cmd interface, say disalbe/drop table etc.

And, then the cmd line help is a little bit too simple ? say select won't support a query without "where" clause. etc.

It seems to be a little bit of annoying when I follow the wiki and it don't give the right result, and I had to figure out what is the right thing to do by myself with a lot of guess and try...

A complete grammer is needed if it is really intended to be try out by other peoples I guess.

condition won't work on negative number

I can see that when stored in index table, the negative number is stored as it is. (say with the flip flag solution, thus the bytes representation of negative number is large than the positive number)

Thus, hbase will sort the row - key with positive number ahead of negative number

And I not yet read code to find out how you fetch index out of index table, but assuming that you will use hbase's row order directly, under this condition, the condition clause won't work right. e.g.

wasp(main):055:0> query "select * from Photo where user_id=-2"
+----------+-----------+------------+-----------+----------------+-------+
| user_id | photo_id | time | full_url | thumbnail_url | tag |
+----------+-----------+------------+-----------+----------------+-------+
| -2 | -502 | -20130728 | fullurl2 | thumburl2 | tag2 |
+----------+-----------+------------+-----------+----------------+-------+

wasp(main):054:0> query "select * from Photo where user_id<5"
+--+
| |
+--+
+--+

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.