|
Hello Antony,
My accumulo version is 1.6.6, but I wil try to use new 1.3.0-m3
and test if the issue persists.
Thanks,
Milan
On 23.12.2016 14:14, Anthony Fox wrote:
Hi Milan
What version of Accumulo are you
using? I've seen this error when using 1.8.0. We recently
merged a fix into master (1.3.0-m3-SNAPSHOT) that addresses the
issue. Basically, versions of the libthrift library are out of
sync.
Thanks
Anthony
Hello everyone and merry christmas
I want to use write data to geomesa programatically, but I
get following error:
Exception in thread "main" java.lang.NoSuchMethodError:
org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.sendBaseOneway(Ljava/lang/String;Lorg/apache/thrift/TBase;)V
at
org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.send_closeScan(TabletClientService.java:303)
at
org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.closeScan(TabletClientService.java:295)
at
org.apache.accumulo.core.client.impl.ThriftScanner.getBatchFromServer(ThriftScanner.java:117)
at
org.apache.accumulo.core.metadata.MetadataLocationObtainer.lookupTablet(MetadataLocationObtainer.java:101)
at
org.apache.accumulo.core.client.impl.TabletLocatorImpl.lookupTabletLocation(TabletLocatorImpl.java:483)
at
org.apache.accumulo.core.client.impl.TabletLocatorImpl.lookupTabletLocationAndCheckLock(TabletLocatorImpl.java:654)
at
org.apache.accumulo.core.client.impl.TabletLocatorImpl._locateTablet(TabletLocatorImpl.java:640)
at
org.apache.accumulo.core.client.impl.TabletLocatorImpl.locateTablet(TabletLocatorImpl.java:456)
at
org.apache.accumulo.core.client.impl.TabletLocatorImpl.lookupTabletLocation(TabletLocatorImpl.java:480)
at
org.apache.accumulo.core.client.impl.TabletLocatorImpl.lookupTabletLocationAndCheckLock(TabletLocatorImpl.java:654)
at
org.apache.accumulo.core.client.impl.TabletLocatorImpl._locateTablet(TabletLocatorImpl.java:640)
at
org.apache.accumulo.core.client.impl.TabletLocatorImpl.locateTablet(TabletLocatorImpl.java:456)
at
org.apache.accumulo.core.client.impl.ThriftScanner.scan(ThriftScanner.java:247)
at
org.apache.accumulo.core.client.impl.ScannerIterator$Reader.run(ScannerIterator.java:79)
at
org.apache.accumulo.core.client.impl.ScannerIterator.hasNext(ScannerIterator.java:150)
at
scala.collection.convert.Wrappers$JIteratorWrapper.hasNext(Wrappers.scala:42)
at
scala.collection.Iterator$class.foreach(Iterator.scala:893)
at
scala.collection.AbstractIterator.foreach(Iterator.scala:1336)
at
scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at
scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at
scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
at
scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.locationtech.geomesa.accumulo.data.MultiRowAccumuloMetadata.getFeatureTypes(GeoMesaMetadata.scala:339)
at
org.locationtech.geomesa.accumulo.data.AccumuloDataStore.getTypeNames(AccumuloDataStore.scala:104)
at
org.locationtech.geomesa.accumulo.data.AccumuloDataStore.getFeatureSource(AccumuloDataStore.scala:346)
at
org.locationtech.geomesa.accumulo.data.AccumuloDataStore.getFeatureSource(AccumuloDataStore.scala:362)
at
com.aimaps.geomesa.DataWriter$.main(DataWriter.scala:100)
at
com.aimaps.geomesa.DataWriter.main(DataWriter.scala)
I am new to scala, this is my code:
package com.aimaps.geomesa
import
org.locationtech.geomesa.accumulo.data.AccumuloDataStore
import
org.locationtech.geomesa.accumulo.index.Constants
import
org.locationtech.geomesa.utils.interop.SimpleFeatureTypes
import org.locationtech.geomesa.utils.interop.WKTUtils
import org.opengis.feature.Feature
import org.opengis.feature.simple.SimpleFeature
import org.opengis.feature.simple.SimpleFeatureType
import org.geotools.data.DataStore
import org.geotools.data.DataStoreFinder
import org.geotools.data.FeatureSource
import org.geotools.data.FeatureStore
import org.geotools.data.Query
import org.geotools.data.simple.SimpleFeatureStore
import org.geotools.factory.CommonFactoryFinder
import org.geotools.factory.Hints
import org.geotools.feature.DefaultFeatureCollection
import org.geotools.feature.FeatureCollection
import org.geotools.feature.FeatureIterator
import org.geotools.feature.SchemaException
import org.geotools.feature.simple.SimpleFeatureBuilder
import org.geotools.data.DataStore
import org.geotools.data.DataStoreFinder
import org.apache.hadoop.conf.Configuration
import org.apache.spark.{SparkConf, SparkContext}
import scala.collection.JavaConversions._
import java.util.UUID.randomUUID
object DataWriter {
def main(args: Array[String]) {
println("Starting up!")
println("Generating Simple Feature")
// Vygenerovanie sample tuple zaznamu
val data = "" "Sample Sensor", 78,
System.currentTimeMillis(), 48.5, 18.0)
// println(f"Generated data: $data")
// Creating simple feature type
val simpleFeatureType =
SimpleFeatureTypes.createType("sampleSensor","objectId:String:index=full,note:String,value:Int:index=full,time:Date,geom:Point:srid=4326:index=full")
//definicia ktory atribut ma byt pouzity ako time
index
simpleFeatureType.getUserData().put(Constants.SF_PROPERTY_START_TIME,
"time");
// vytvorenie simple feature buildera
val featureBuilder = new
SimpleFeatureBuilder(simpleFeatureType)
// vytvorenie noveho simple feature
val simpleFeature =
featureBuilder.buildFeature(randomUUID.toString());
//naplnenie simple feature datami
simpleFeature.setAttribute("objectId", data._1)
simpleFeature.setAttribute("note", data._2)
simpleFeature.setAttribute("value", data._3)
simpleFeature.setAttribute("time", data._4)
// vytvorenie geometrie a priradenie geometrie
val geometry = WKTUtils.read("POINT(" + data._6 + "
" + data._5 + ")")
simpleFeature.setAttribute("geom", geometry)
println("Generujem Feature Collection")
val featureCollection = new
DefaultFeatureCollection()
featureCollection.add(simpleFeature)
/**
* ZAPIS SIMPLE FEATURE DO TABULKY
*/
println("Initializing geomesa connection")
// configuracia pripojenia na geomesa
val dataStoreConfig = Map(
"instanceId" -> "accumulo",
"zookeepers" -> "localhost:2181",
"user" -> "root",
"password" -> "pass1234",
"tableName" -> "test_insert",
"auth" -> "")
println("Creating data store")
// vytvorenie datastore
val dataStore =
DataStoreFinder.getDataStore(dataStoreConfig).asInstanceOf[AccumuloDataStore]
// vytvorenie schemy
// dataStore.createSchema(simpleFeatureType)
println("Creating feature store")
val featureStore =
dataStore.getFeatureSource("sampleSensor")
println("Inserting features")
featureStore.addFeatures(featureCollection)
println("DONE.")
}
}
Thank you for any sudgestions,
Milan
_______________________________________________
geomesa-users mailing list
geomesa-users@xxxxxxxxxxxxxxxx
To change your delivery options, retrieve your password, or unsubscribe from this list, visit
https://www.locationtech.org/mailman/listinfo/geomesa-users
|
