Skip to content

Commit caf34b8

Browse files
committed
Update metadata cache IT
Signed-off-by: Simeon Widdis <[email protected]>
1 parent 961d5a3 commit caf34b8

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

integ-test/src/integration/scala/org/opensearch/flint/spark/metadatacache/FlintOpenSearchMetadataCacheWriterITSuite.scala

+7-7
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ class FlintOpenSearchMetadataCacheWriterITSuite extends FlintSparkSuite with Mat
9494
properties should have size 3
9595
properties should contain allOf (Entry(
9696
"metadataCacheVersion",
97-
FlintMetadataCache.metadataCacheVersion),
97+
ExportedFlintMetadata.metadataCacheVersion),
9898
Entry("lastRefreshTime", testLastRefreshCompleteTime))
9999
}
100100

@@ -208,7 +208,7 @@ class FlintOpenSearchMetadataCacheWriterITSuite extends FlintSparkSuite with Mat
208208
properties should have size 4
209209
properties should contain allOf (Entry(
210210
"metadataCacheVersion",
211-
FlintMetadataCache.metadataCacheVersion),
211+
ExportedFlintMetadata.metadataCacheVersion),
212212
Entry("refreshInterval", 600),
213213
Entry("lastRefreshTime", testLastRefreshCompleteTime))
214214
}
@@ -297,7 +297,7 @@ class FlintOpenSearchMetadataCacheWriterITSuite extends FlintSparkSuite with Mat
297297
properties should have size 4
298298
properties should contain allOf (Entry(
299299
"metadataCacheVersion",
300-
FlintMetadataCache.metadataCacheVersion),
300+
ExportedFlintMetadata.metadataCacheVersion),
301301
Entry("lastRefreshTime", testLastRefreshCompleteTime), Entry(
302302
"custom_in_properties",
303303
"test_custom"))
@@ -320,7 +320,7 @@ class FlintOpenSearchMetadataCacheWriterITSuite extends FlintSparkSuite with Mat
320320
"checkpoint_location" -> "s3a://test/"),
321321
s"""
322322
| {
323-
| "metadataCacheVersion": "${FlintMetadataCache.metadataCacheVersion}",
323+
| "metadataCacheVersion": "${ExportedFlintMetadata.metadataCacheVersion}",
324324
| "refreshInterval": 600,
325325
| "sourceTables": ["$testTable"]
326326
| }
@@ -330,7 +330,7 @@ class FlintOpenSearchMetadataCacheWriterITSuite extends FlintSparkSuite with Mat
330330
Map.empty[String, String],
331331
s"""
332332
| {
333-
| "metadataCacheVersion": "${FlintMetadataCache.metadataCacheVersion}",
333+
| "metadataCacheVersion": "${ExportedFlintMetadata.metadataCacheVersion}",
334334
| "sourceTables": ["$testTable"]
335335
| }
336336
|""".stripMargin),
@@ -339,7 +339,7 @@ class FlintOpenSearchMetadataCacheWriterITSuite extends FlintSparkSuite with Mat
339339
Map("incremental_refresh" -> "true", "checkpoint_location" -> "s3a://test/"),
340340
s"""
341341
| {
342-
| "metadataCacheVersion": "${FlintMetadataCache.metadataCacheVersion}",
342+
| "metadataCacheVersion": "${ExportedFlintMetadata.metadataCacheVersion}",
343343
| "sourceTables": ["$testTable"]
344344
| }
345345
|""".stripMargin)).foreach { case (refreshMode, optionsMap, expectedJson) =>
@@ -397,7 +397,7 @@ class FlintOpenSearchMetadataCacheWriterITSuite extends FlintSparkSuite with Mat
397397
val propertiesJson = compact(render(getPropertiesJValue(testFlintIndex)))
398398
propertiesJson should matchJson(s"""
399399
| {
400-
| "metadataCacheVersion": "${FlintMetadataCache.metadataCacheVersion}",
400+
| "metadataCacheVersion": "${ExportedFlintMetadata.metadataCacheVersion}",
401401
| "refreshInterval": 600,
402402
| "sourceTables": ["$testTable"]
403403
| }

0 commit comments

Comments
 (0)