[geomesa-dev] [JIRA] (GEOMESA-2654) Update features can fail due to key

["Emilio Lahr-Vivaz (JIRA)" <jira@xxxxxxxxxxxxxxxxxxxxx>]

Title: Message Title

Emilio Lahr-Vivaz created an issue

GeoMesa / GEOMESA-2654

Update features can fail due to key timestamps

Issue Type:	Bug
Affects Versions:	2.1.0, 2.2.0, 2.1.1, 2.3.0, 2.1.2, 2.2.1, 2.2.2, 2.1.3
Assignee:	Emilio Lahr-Vivaz
Created:	17/Jun/19 4:15 PM
Priority:	Major
Reporter:	Emilio Lahr-Vivaz

Have observed this in Accumulo. Turning on logical timestamps seems to fix the issue. May affect other backends, and/or versions. Does not show up in unit tests due to mock accumulo handling timestamps differently? Script to reproduce:

import org.locationtech.geomesa.utils.geotools.FeatureUtils
val ds = DataStoreFinder.getDataStore(Map("accumulo.instance.id" -> "foo", "accumulo.zookeepers" -> "localhost", "accumulo.user" -> "root", "accumulo.password" -> "***", "accumulo.catalog" -> "240.test"))
ds.createSchema(SimpleFeatureTypes.createType("update-test", "GUID:String:index=full,RPT_GUID:String:index=full,RPT_DTG:Date:index=full,*GEOMETRY:Point:srid=4326;geomesa.index.dtg='RPT_DTG',geomesa.logical.time='true'"))
val sft = ds.getSchema("update-test")
val features = Seq(ScalaSimpleFeature.create(sft, "R1", "T1", "R1", "2018-01-02T00:00:00.000Z", "POINT (45 45)"), ScalaSimpleFeature.create(sft, "R2", "T2", "R2", "2018-01-02T00:00:00.000Z", "POINT (45 45)"))
val writer = ds.getFeatureWriterAppend("update-test", Transaction.AUTO_COMMIT)
features.foreach(FeatureUtils.write(writer, _, useProvidedFid = true))
writer.close()
val filters = Seq("IN ('R1', 'R2')","GUID = 'T1'","RPT_GUID IN ('R1', 'R2')","bbox(GEOMETRY,44,44,46,46)","bbox(GEOMETRY,44,44,46,46) and RPT_DTG during 2018-01-01T23:00:00.000Z/2018-01-02T01:00:00.000Z","RPT_DTG during 2018-01-01T23:00:00.000Z/2018-01-02T01:00:00.000Z")
filters.foreach { filter => val query = new Query(sft.getTypeName, ECQL.toFilter(filter)); val results = SelfClosingIterator(ds.getFeatureReader(query, Transaction.AUTO_COMMIT)).toList; println(results) }
val fs = ds.getFeatureSource("update-test").asInstanceOf[org.locationtech.geomesa.index.geotools.GeoMesaFeatureStore]
fs.modifyFeatures("GUID", "T1", ECQL.toFilter("IN ('R2')"))
filters.foreach { filter => val query = new Query(sft.getTypeName, ECQL.toFilter(filter)); val results = SelfClosingIterator(ds.getFeatureReader(query, Transaction.AUTO_COMMIT)).toList; println(results) }

Add Comment

Get Jira notifications on your phone! Download the Jira Cloud app for Android or iOS
This message was sent by Atlassian Jira (v1001.0.0-SNAPSHOT#100104-sha1:ce3e8e1)