2017-01-10 19 views
2

Fragen Sie uns, ob Sie uns bitte helfen könnten, ein Problem bei der Abfrage von Geomesa/Accumulo zu verstehen?Geomesa Export gibt keine Ergebnisse zurück, obwohl Daten vorhanden sind

Ausgabe:

  1. Wenn wir für alle Felder abfragen mit geomesa export -u A -p B -c catalog1 -f d1-json -F csv es Daten zurückgibt (siehe unten für die Probe sehen).

  2. Wenn wir eine Teilmenge von Spalten mit -a "short_text_field" hinzufügen oder sogar einem einfachen -q "short_text_field='Cow'" es 0 zurück Merkmale trotz der Daten vorhanden sind: geomesa export -u A -p B -c catalog1 -f d1-json -F csv -a "short_text_field" INFO Exportierte 0 Funktionen id, short_text_field: String, * geom: Punkt: srid = 4326 INFO Feature-Export abgeschlossen Standard aus in 2077ms

Beispieldaten aus (1):

id, geom: Punkt: srid = 4326, short_text_field: String, long_text_field_1: String, long_text_field_2: String e9c756ef-06d6-42dd-84a9-c774ec9086ec, PUNKT (-117.830256 -76.799443), 597Fish, "Cow Car? Kuh-Fisch-Mauskatze-Auto-Fisch-Pferdemaus Fisch „“ 诶 迪 伊 迎 益 伊 迎 诶 迎 诶 伊 ")

Frage: Ist jemand bekannt, der beste Weg, dies zu debuggen

Auszug aus den Protokollen, wenn? Abfrage wird mit -a laufen.

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 

Antwort

1

die Lösung ist, den Namensraum als Präfix für das Einspeisen und Export-Befehle Katalog Parameter einfach hinzufügen

Wenn die Einnahme unbedingt die namespace.catalogname angeben

Ähnlich muss das Gleiche bei der Abfrage gemacht werden.

+0

Es scheint nicht, dass dies die gestellte Frage beantwortet. In der Frage wird '-c catalog1' sowohl für den erfolgreichen als auch für den fehlgeschlagenen Befehl verwendet. – vpipkt

+0

Der Schlüsselpunkt ist, wenn Sie dem Exportbefehl -a oder -q hinzufügen, stellen Sie sicher, dass Sie dem Katalogparameter einen Namespace voranstellen. – mds91

Verwandte Themen