Skip to content

Commit d1e6f95

Browse files
committed
fixed numberOfShards in single server tests
1 parent 6328cb4 commit d1e6f95

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

integration-tests/src/test/scala/org/apache/spark/sql/arangodb/datasource/BaseSparkTest.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ class BaseSparkTest {
3434
}
3535

3636
def isSingle: Boolean = BaseSparkTest.isSingle
37+
def isCluster: Boolean = !BaseSparkTest.isSingle
3738
}
3839

3940
object BaseSparkTest {

integration-tests/src/test/scala/org/apache/spark/sql/arangodb/datasource/write/CreateCollectionTest.scala

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,9 @@ class CreateCollectionTest extends BaseSparkTest {
5050
))
5151
.save()
5252

53-
assertThat(collection.getProperties.getNumberOfShards).isEqualTo(5)
53+
if (isCluster) {
54+
assertThat(collection.getProperties.getNumberOfShards).isEqualTo(5)
55+
}
5456
assertThat(collection.getProperties.getType.getType).isEqualTo(CollectionType.EDGES.getType)
5557
}
5658

@@ -70,7 +72,9 @@ class CreateCollectionTest extends BaseSparkTest {
7072
))
7173
.save()
7274

73-
assertThat(collection.getProperties.getNumberOfShards).isEqualTo(5)
75+
if (isCluster) {
76+
assertThat(collection.getProperties.getNumberOfShards).isEqualTo(5)
77+
}
7478
assertThat(collection.getProperties.getType.getType).isEqualTo(CollectionType.EDGES.getType)
7579
}
7680

0 commit comments

Comments
 (0)