No commit message

.github/workflows/java.yml

@@ -201,24 +201,24 @@ jobs:
                   cargo-toml-folder: ./java
               name: lint java rust
 
-    start-self-hosted-runner:
-        if: github.repository_owner == 'valkey-io'
-        runs-on: ubuntu-latest
-        environment: AWS_ACTIONS
-        steps:
-            - name: Checkout
-              uses: actions/checkout@v4
-        
-            - name: Start self hosted EC2 runner
-              uses: ./.github/workflows/start-self-hosted-runner
-              with:
-                  role-to-assume: ${{ secrets.ROLE_TO_ASSUME }}
-                  aws-region: ${{ secrets.AWS_REGION }}
-                  ec2-instance-id: ${{ secrets.AWS_EC2_INSTANCE_ID }}
+#    start-self-hosted-runner:
+#        if: github.repository_owner == 'valkey-io'
+#        runs-on: ubuntu-latest
+#        environment: AWS_ACTIONS
+#        steps:
+#            - name: Checkout
+#              uses: actions/checkout@v4
+#
+#            - name: Start self hosted EC2 runner
+#              uses: ./.github/workflows/start-self-hosted-runner
+#              with:
+#                  role-to-assume: ${{ secrets.ROLE_TO_ASSUME }}
+#                  aws-region: ${{ secrets.AWS_REGION }}
+#                  ec2-instance-id: ${{ secrets.AWS_EC2_INSTANCE_ID }}
 
     test-modules:
         if: github.repository_owner == 'valkey-io'
-        needs: [start-self-hosted-runner]
+#        needs: [start-self-hosted-runner]
         name: Running Module Tests
         runs-on: [self-hosted, linux, ARM64]
         timeout-minutes: 15

java/integTest/src/test/java/glide/modules/VectorSearchTests.java

@@ -15,6 +15,7 @@
 import glide.api.BaseClient;
 import glide.api.GlideClient;
 import glide.api.GlideClusterClient;
+import glide.api.models.commands.FlushMode;
 import glide.api.models.commands.vss.FTCreateOptions.DistanceMetric;
 import glide.api.models.commands.vss.FTCreateOptions.FieldInfo;
 import glide.api.models.commands.vss.FTCreateOptions.IndexType;
@@ -54,6 +55,7 @@ public static void init() {
         var clusterClient =
                 GlideClusterClient.createClient(commonClusterClientConfig().requestTimeout(5000).build())
                         .get();
+        clusterClient.flushall(FlushMode.SYNC, ALL_PRIMARIES).get();
 
         clients = List.of(/*Arguments.of(standaloneClient),*/ Arguments.of(clusterClient));
     }
@@ -174,7 +176,7 @@ public void ft_create(BaseClient client) {
                                                 new FieldInfo[0])
                                         .get());
         assertInstanceOf(RequestException.class, exception.getCause());
-        assertTrue(exception.getMessage().contains("arguments are missing"));
+        assertTrue(exception.getMessage().contains("wrong number of arguments"));
     }
 
     @SneakyThrows
@@ -282,7 +284,7 @@ public void ft_search(BaseClient client) {
                                         .ftsearch(UUID.randomUUID().toString(), "*", FTSearchOptions.builder().build())
                                         .get());
         assertInstanceOf(RequestException.class, exception.getCause());
-        assertTrue(exception.getMessage().contains("no such index"));
+        assertTrue(exception.getMessage().contains("Index not found"));
     }
 
     @SneakyThrows
@@ -338,6 +340,6 @@ public void ft_drop(BaseClient client) {
 
         var exception = assertThrows(ExecutionException.class, () -> client.ftdrop(index).get());
         assertInstanceOf(RequestException.class, exception.getCause());
-        assertTrue(exception.getMessage().contains("Unknown: Index name"));
+        assertTrue(exception.getMessage().contains("Index does not exist"));
     }
 }