Skip to content

Commit 13fb172

Browse files
committed
Fix failing GEO tests
1 parent 0387a47 commit 13fb172

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

spark/sql-13/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkSQL.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2072,6 +2072,7 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
20722072

20732073
@Test
20742074
def testGeoShapeCircle() {
2075+
EsAssume.versionOnOrBefore(EsMajorVersion.V_5_X, "circle geo shape is removed in later 6.6+ versions")
20752076
val mapping = s"""{ "data": {
20762077
| "properties": {
20772078
| "name": {
@@ -2092,10 +2093,10 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
20922093
RestUtils.putMapping(index, typed, mapping.getBytes(StringUtils.UTF_8))
20932094

20942095
val circle = """{"name":"circle", "location": {"type":"circle", "coordinates":[ -45.0, 45.0], "radius":"100m"} }""".stripMargin
2095-
2096+
20962097
sc.makeRDD(Seq(circle)).saveJsonToEs(indexAndType)
20972098
val df = sqc.read.format("es").load(index)
2098-
2099+
20992100
val dataType = df.schema("location").dataType
21002101
assertEquals("struct", dataType.typeName)
21012102

spark/sql-20/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkSQL.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2130,6 +2130,7 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
21302130

21312131
@Test
21322132
def testGeoShapeCircle() {
2133+
EsAssume.versionOnOrBefore(EsMajorVersion.V_5_X, "circle geo shape is removed in later 6.6+ versions")
21332134
val mapping = s"""{ "data": {
21342135
| "properties": {
21352136
| "name": {

0 commit comments

Comments
 (0)