Skip to content

Commit c10eed0

Browse files
committed
fix small issue
1 parent edd22ef commit c10eed0

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

common/utils/src/main/resources/error/error-conditions.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5507,7 +5507,7 @@
55075507
},
55085508
"sqlState" : "42616"
55095509
},
5510-
"STATE_REPARTITION_INVALID_STATE_STORE_CONFIG": {
5510+
"STATE_REPARTITION_INVALID_STATE_STORE_CONFIG" : {
55115511
"message" : [
55125512
"StateStoreConfig <configName> is invalid:"
55135513
],

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/v2/state/StatePartitionAllColumnFamiliesReaderSuite.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,7 @@ class StatePartitionAllColumnFamiliesReaderSuite extends StateDataSourceTestBase
276276

277277
testWithChangelogConfig("all-column-families: dropDuplicates validation") {
278278
withTempDir { tempDir =>
279-
runDropDuplicatesQuery(tempDir.getAbsolutePath)
279+
runDropDuplicatesQuery(tempDir.getAbsolutePath)
280280

281281
val keySchema = StructType(Array(
282282
StructField("value", IntegerType, nullable = false),
@@ -295,7 +295,7 @@ class StatePartitionAllColumnFamiliesReaderSuite extends StateDataSourceTestBase
295295

296296
testWithChangelogConfig("all-column-families: dropDuplicates with column specified") {
297297
withTempDir { tempDir =>
298-
runDropDuplicatesQueryWithColumnSpecified(tempDir.getAbsolutePath)
298+
runDropDuplicatesQueryWithColumnSpecified(tempDir.getAbsolutePath)
299299

300300
val keySchema = StructType(Array(
301301
StructField("col1", org.apache.spark.sql.types.StringType, nullable = true)
@@ -313,7 +313,7 @@ class StatePartitionAllColumnFamiliesReaderSuite extends StateDataSourceTestBase
313313

314314
testWithChangelogConfig("all-column-families: dropDuplicatesWithinWatermark") {
315315
withTempDir { tempDir =>
316-
runDropDuplicatesWithinWatermarkQuery(tempDir.getAbsolutePath)
316+
runDropDuplicatesWithinWatermarkQuery(tempDir.getAbsolutePath)
317317

318318
val keySchema = StructType(Array(
319319
StructField("_1", org.apache.spark.sql.types.StringType, nullable = true)
@@ -331,7 +331,7 @@ class StatePartitionAllColumnFamiliesReaderSuite extends StateDataSourceTestBase
331331

332332
testWithChangelogConfig("all-column-families: session window aggregation") {
333333
withTempDir { tempDir =>
334-
runSessionWindowAggregationQuery(tempDir.getAbsolutePath)
334+
runSessionWindowAggregationQuery(tempDir.getAbsolutePath)
335335

336336
val keySchema = StructType(Array(
337337
StructField("sessionId", org.apache.spark.sql.types.StringType, nullable = false),

0 commit comments

Comments
 (0)