2017-01-10 13 views
2

geomesa/Accumuloをクエリする際に問題を理解するのに役立ちますか?データが存在しても、Geomesaのエクスポート結果が返されない

問題:

  1. 我々はgeomesa export -u A -p B -c catalog1 -f d1-json -F csvですべてのフィールドを照会するとき、それはデータを返します(サンプルについては以下を参照のこと)。

  2. 我々は-a "short_text_field"、あるいは簡単な-q "short_text_field='Cow'"と列のサブセットを追加すると、それが存在しているデータにもかかわらず、0の機能を返します。 geomesa export -u A -p B -c catalog1 -f d1-json -F csv -a "short_text_field" INFOエクスポート0機能 ID、short_text_field:文字列、* GEOM:ポイント:SRID = 4326 INFO機能の輸出(1)から2077ms

サンプル・データで標準出力への完全な:

id、geom:Point:srid = 4326、short_text_field:String、long_text_field_1:String、long_text_field_2:String e9c756ef-06d6-42dd-84a9-c774ec9086ec、POINT(-117.830256 -76.799443)、597Fish、 "Cow Car?カウフィッシュマウス猫車魚馬マウス魚「」诶迪伊迎益伊迎诶迎诶伊」)

質問:?際ログからこの

抜粋をデバッグするための最良の方法の誰もが認識していますクエリは、-aで実行されます。

2017-01-10 14:36:04,921 WARN [org.apache.hadoop.util.NativeCodeLoader] Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 
2017-01-10 14:36:06,448 WARN [org.apache.accumulo.server.fs.VolumeManagerImpl] dfs.datanode.synconclose set to false in hdfs-site.xml: data loss is possible on hard system reset or power loss 
2017-01-10 14:36:09,943 WARN [org.locationtech.geomesa.accumulo.data.AccumuloDataStore] Configured server-side iterators do not match client version - client version: 1.2.7, server version: unavailable 
2017-01-10 14:36:10,329 WARN [org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator] Error on server testmisc-w-0.c.geobench-146409.internal:9997 
org.apache.accumulo.core.client.impl.AccumuloServerException: Error on server testmisc-w-0.c.geobench-146409.internal:9997 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:695) 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:349) 
     at org.apache.htrace.wrappers.TraceRunnable.run(TraceRunnable.java:57) 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
     at org.apache.accumulo.fate.util.LoggingRunnable.run(LoggingRunnable.java:35) 
     at java.lang.Thread.run(Thread.java:745) 
Caused by: org.apache.thrift.TApplicationException: Internal error processing startMultiScan 
     at org.apache.thrift.TApplicationException.read(TApplicationException.java:111) 
     at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:71) 
     at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.recv_startMultiScan(TabletClientService.java:317) 
     at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.startMultiScan(TabletClientService.java:297) 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:634) 
     ... 6 more 
2017-01-10 14:36:10,342 WARN [org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator] Error on server testmisc-w-1.c.geobench-146409.internal:9997 
org.apache.accumulo.core.client.impl.AccumuloServerException: Error on server testmisc-w-1.c.geobench-146409.internal:9997 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:695) 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:349) 
     at org.apache.htrace.wrappers.TraceRunnable.run(TraceRunnable.java:57) 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
     at org.apache.accumulo.fate.util.LoggingRunnable.run(LoggingRunnable.java:35) 
     at java.lang.Thread.run(Thread.java:745) 
Caused by: org.apache.thrift.TApplicationException: Internal error processing startMultiScan 
     at org.apache.thrift.TApplicationException.read(TApplicationException.java:111) 
     at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:71) 
     at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.recv_startMultiScan(TabletClientService.java:317) 
     at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.startMultiScan(TabletClientService.java:297) 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:634) 
     ... 6 more 
2017-01-10 14:36:10,344 WARN [org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator] Error on server testmisc-w-1.c.geobench-146409.internal:9997 
org.apache.accumulo.core.client.impl.AccumuloServerException: Error on server testmisc-w-1.c.geobench-146409.internal:9997 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:695) 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:349) 
     at org.apache.htrace.wrappers.TraceRunnable.run(TraceRunnable.java:57) 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
     at org.apache.accumulo.fate.util.LoggingRunnable.run(LoggingRunnable.java:35) 
     at java.lang.Thread.run(Thread.java:745) 
Caused by: org.apache.thrift.TApplicationException: Internal error processing startMultiScan 
     at org.apache.thrift.TApplicationException.read(TApplicationException.java:111) 
     at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:71) 
     at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.recv_startMultiScan(TabletClientService.java:317) 
     at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.startMultiScan(TabletClientService.java:297) 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:634) 
     ... 6 more 
2017-01-10 14:36:10,351 WARN [org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator] Error on server testmisc-m.c.geobench-146409.internal:9997 
rg.apache.accumulo.core.client.impl.AccumuloServerException: Error on server testmisc-m.c.geobench-146409.internal:9997 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:695) 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:349) 
     at org.apache.htrace.wrappers.TraceRunnable.run(TraceRunnable.java:57) 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
     at org.apache.accumulo.fate.util.LoggingRunnable.run(LoggingRunnable.java:35) 
     at java.lang.Thread.run(Thread.java:745) 
Caused by: org.apache.thrift.TApplicationException: Internal error processing startMultiScan 
     at org.apache.thrift.TApplicationException.read(TApplicationException.java:111) 
     at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:71) 
     at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.recv_startMultiScan(TabletClientService.java:317) 
     at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.startMultiScan(TabletClientService.java:297) 
     at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:634) 
     ... 6 more 
2017-01-10 14:36:10,430 INFO [org.locationtech.geomesa.tools.accumulo.DelimitedExport] Exported 0 features 
2017-01-10 14:36:10,433 INFO [org.locationtech.geomesa.tools.accumulo.commands.ExportCommand] Feature export complete to standard out in 3049ms 

答えて

1

ソリューションは、単純に取り込み、輸出へのプレフィックスとして名前空間を追加することですが、カタログのパラメータをコマンド

namespace.catalognameを指定してください摂取

同様に、クエリを実行するときに同じ操作を行う必要があります。

+0

これは疑問に答えたようではありません。 '-c catalog1'は、成功したコマンドと失敗したコマンドの両方で使用されます。 – vpipkt

+0

キーポイントは、エクスポートコマンドに-aまたは-qを追加する場合に、カタログパラメータの前に必ずネームスペースを付けてください。 – mds91

関連する問題