Skip to content

Commit 82f7c17

Browse files
committed
Fix cluster creation
1 parent 9cd6c40 commit 82f7c17

2 files changed

Lines changed: 2 additions & 3 deletions

File tree

src/it/java/io/weaviate/containers/Weaviate.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -412,12 +412,13 @@ public void stop() {
412412
*/
413413
private void bindNodes(int gossip, int data, int raft) {
414414
var publicPort = leader.getExposedPorts().get(0); // see WeaviateContainer Testcontainer.
415+
var clusterSize = String.valueOf(nodes.size());
415416

416417
nodes.forEach(node -> node
417418
.withEnv("CLUSTER_GOSSIP_BIND_PORT", String.valueOf(gossip))
418419
.withEnv("CLUSTER_DATA_BIND_PORT", String.valueOf(data))
419420
.withEnv("RAFT_PORT", String.valueOf(raft))
420-
.withEnv("RAFT_BOOTSTRAP_EXPECT", "1"));
421+
.withEnv("RAFT_BOOTSTRAP_EXPECT", clusterSize));
421422

422423
followers.forEach(node -> node
423424
.withEnv("CLUSTER_JOIN", leader.containerName + ":" + gossip)

src/it/java/io/weaviate/integration/ClusterITest.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,6 @@ public class ClusterITest extends ConcurrentTest {
2121

2222
@Test
2323
public void test_shardingState() throws IOException {
24-
Version.V134.orSkip();
25-
2624
// Arrange
2725
var nsA = ns("A");
2826
var nsB = ns("B");

0 commit comments

Comments
 (0)