3

geomesa/Accumulo にクエリを実行する際の問題について、ご理解いただけると幸いです。

問題:

  1. すべてのフィールドに対してクエリを実行すると、geomesa export -u A -p B -c catalog1 -f d1-json -F csvデータが返されます (サンプルについては以下を参照)。

  2. -a "short_text_field"単純な ORで列のサブセットを追加すると-q "short_text_field='Cow'"、データが存在するにもかかわらず、0 個の機能が返されます: geomesa export -u A -p B -c catalog1 -f d1-json -F csv -a "short_text_field" INFO Exported 0 features id,short_text_field:String,*geom:Point:srid=4326 INFO Feature export complete to standard out in 2077ms

(1) のサンプルデータ:

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," カウカー? カウ フィッシュ マウス キャット カーFish Horse Mouse Fish"," 诶 迪 伊迎 益 伊 迎 诶 迎 诶 伊")

質問: これをデバッグする最善の方法を知っている人はいますか?

-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
4

1 に答える 1

2

解決策は、名前空間を接頭辞として取り込みコマンドとエクスポート コマンドのカタログ パラメータに追加するだけです。

取り込むときは、必ず namespace.catalogname を指定してください

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

于 2017-01-10T15:57:13.060 に答える