diff --git a/geomesa-filter/src/test/resources/getFeatures.xml b/geomesa-filter/src/test/resources/getFeatures.xml deleted file mode 100644 index e69de29bb2d1..000000000000 diff --git a/geomesa-fs/geomesa-fs-spark-runtime/src/test/scala/org/locationtech/geomesa/fs/spark/FileSystemRDDProviderTest.scala b/geomesa-fs/geomesa-fs-spark-runtime/src/test/scala/org/locationtech/geomesa/fs/spark/FileSystemRDDProviderTest.scala index 57f011f229c5..5ad51293d8dd 100644 --- a/geomesa-fs/geomesa-fs-spark-runtime/src/test/scala/org/locationtech/geomesa/fs/spark/FileSystemRDDProviderTest.scala +++ b/geomesa-fs/geomesa-fs-spark-runtime/src/test/scala/org/locationtech/geomesa/fs/spark/FileSystemRDDProviderTest.scala @@ -37,7 +37,7 @@ class FileSystemRDDProviderTest extends Specification with LazyLogging { var sc: SQLContext = _ lazy val path = s"${HadoopSharedCluster.Container.getHdfsUrl}/${getClass.getSimpleName}/" - lazy val params = Map("fs.path" -> path) + lazy val params = Map("fs.path" -> path, "fs.config.xml" -> HadoopSharedCluster.ContainerConfig) lazy val ds: DataStore = DataStoreFinder.getDataStore(params.asJava) val formats = Seq("orc", "parquet") diff --git a/geomesa-fs/geomesa-fs-tools/src/test/scala/org/locationtech/geomesa/fs/tools/ingest/FsManageMetadataCommandTest.scala b/geomesa-fs/geomesa-fs-tools/src/test/scala/org/locationtech/geomesa/fs/tools/ingest/FsManageMetadataCommandTest.scala index b7f6dbde9928..cd74c3229766 100644 --- a/geomesa-fs/geomesa-fs-tools/src/test/scala/org/locationtech/geomesa/fs/tools/ingest/FsManageMetadataCommandTest.scala +++ b/geomesa-fs/geomesa-fs-tools/src/test/scala/org/locationtech/geomesa/fs/tools/ingest/FsManageMetadataCommandTest.scala @@ -41,9 +41,6 @@ class FsManageMetadataCommandTest extends Specification { ScalaSimpleFeature.create(sft, "2", "name1", "2022-01-01T00:00:00.000Z", "POINT (0 0)") ) - val gzipXml = - "parquet.compressionGZIP" - val counter = new AtomicInteger(0) def nextPath(): String = @@ -52,7 +49,7 @@ class FsManageMetadataCommandTest extends Specification { "ManageMetadata command" should { "find file inconsistencies" in { val dir = nextPath() - val dsParams = Map("fs.path" -> dir, "fs.config.xml" -> gzipXml) + val dsParams = Map("fs.path" -> dir, "fs.config.xml" -> HadoopSharedCluster.ContainerConfig) WithClose(DataStoreFinder.getDataStore(dsParams.asJava).asInstanceOf[FileSystemDataStore]) { ds => ds.createSchema(SimpleFeatureTypes.copy(sft)) WithClose(ds.getFeatureWriterAppend(sft.getTypeName, Transaction.AUTO_COMMIT)) { writer => @@ -73,7 +70,7 @@ class FsManageMetadataCommandTest extends Specification { val command = new FsManageMetadataCommand.CheckConsistencyCommand() command.params.path = dir command.params.featureName = sft.getTypeName - command.params.configuration = Collections.singletonList(s"fs.config.xml=$gzipXml") + command.params.configuration = Collections.singletonList(s"fs.config.xml=${HadoopSharedCluster.ContainerConfig}") command.params.repair = true command.execute() @@ -89,7 +86,7 @@ class FsManageMetadataCommandTest extends Specification { } "rebuild metadata from scratch" in { val dir = nextPath() - val dsParams = Map("fs.path" -> dir, "fs.config.xml" -> gzipXml) + val dsParams = Map("fs.path" -> dir, "fs.config.xml" -> HadoopSharedCluster.ContainerConfig) WithClose(DataStoreFinder.getDataStore(dsParams.asJava).asInstanceOf[FileSystemDataStore]) { ds => ds.createSchema(SimpleFeatureTypes.copy(sft)) WithClose(ds.getFeatureWriterAppend(sft.getTypeName, Transaction.AUTO_COMMIT)) { writer => @@ -114,7 +111,7 @@ class FsManageMetadataCommandTest extends Specification { val command = new FsManageMetadataCommand.CheckConsistencyCommand() command.params.path = dir command.params.featureName = sft.getTypeName - command.params.configuration = Collections.singletonList(s"fs.config.xml=$gzipXml") + command.params.configuration = Collections.singletonList(s"fs.config.xml=${HadoopSharedCluster.ContainerConfig}") command.params.rebuild = true command.execute() diff --git a/geomesa-redis/geomesa-redis-datastore/src/test/scala/org/locationtech/geomesa/redis/data/RedisDataStoreTest.scala b/geomesa-redis/geomesa-redis-datastore/src/test/scala/org/locationtech/geomesa/redis/data/RedisDataStoreTest.scala index a9ad41f757f1..00cc1859290a 100644 --- a/geomesa-redis/geomesa-redis-datastore/src/test/scala/org/locationtech/geomesa/redis/data/RedisDataStoreTest.scala +++ b/geomesa-redis/geomesa-redis-datastore/src/test/scala/org/locationtech/geomesa/redis/data/RedisDataStoreTest.scala @@ -113,7 +113,7 @@ class RedisDataStoreTest extends Specification with LazyLogging { "expire features based on ingest time" in { val sft = featureType("ingest", Some("2 seconds")) - RedisSystemProperties.AgeOffInterval.threadLocalValue.set("500 ms") + RedisSystemProperties.AgeOffInterval.threadLocalValue.set("100 ms") val ds = try { DataStoreFinder.getDataStore(params.asJava).asInstanceOf[RedisDataStore] } finally { RedisSystemProperties.AgeOffInterval.threadLocalValue.remove() } @@ -141,7 +141,7 @@ class RedisDataStoreTest extends Specification with LazyLogging { foreach(filters) { filter => val query = new Query(sft.getTypeName, filter) - eventually(40, 100.millis) { + eventually(10, 1000.millis) { val result = SelfClosingIterator(ds.getFeatureReader(query, Transaction.AUTO_COMMIT)).toList result must beEmpty } @@ -161,7 +161,7 @@ class RedisDataStoreTest extends Specification with LazyLogging { val sft = featureType("time", Some(s"dtg($time ms)")) - RedisSystemProperties.AgeOffInterval.threadLocalValue.set("500 ms") + RedisSystemProperties.AgeOffInterval.threadLocalValue.set("100 ms") val ds = try { DataStoreFinder.getDataStore(params.asJava).asInstanceOf[RedisDataStore] } finally { RedisSystemProperties.AgeOffInterval.threadLocalValue.remove() } @@ -191,7 +191,7 @@ class RedisDataStoreTest extends Specification with LazyLogging { foreach(filters) { filter => val expected = features.drop(1).filter(filter.evaluate) val query = new Query(sft.getTypeName, filter) - eventually(40, 100.millis) { + eventually(10, 1000.millis) { val result = SelfClosingIterator(ds.getFeatureReader(query, Transaction.AUTO_COMMIT)).toList result must containTheSameElementsAs(expected) } diff --git a/pom.xml b/pom.xml index 2bac8837ff07..77be70dd30f6 100644 --- a/pom.xml +++ b/pom.xml @@ -119,7 +119,7 @@ 4.13.2 5.9.3 1.19.7 - 1.3.0 + 1.4.0 2.28.2