This is an automated email from the ASF dual-hosted git repository.
frankgh pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-analytics.git
The following commit(s) were added to refs/heads/trunk by this push:
new 77c8f418 CASSANALYTICS-69: Set KeyStore to be optional (#123)
77c8f418 is described below
commit 77c8f418a3953abd50de7acf646dad5c2360451d
Author: Andrew Johnson <[email protected]>
AuthorDate: Thu Aug 21 18:47:10 2025 +0100
CASSANALYTICS-69: Set KeyStore to be optional (#123)
Patch by Andrew Johnson; reviewed by Saranya Krishnakumar, Yifan Cai,
Francisco Guerrero for CASSANALYTICS-69
---
CHANGES.txt | 2 +-
.../org/apache/cassandra/spark/validation/KeyStoreValidationTests.java | 3 +--
.../java/org/apache/cassandra/spark/validation/KeyStoreValidation.java | 2 +-
3 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/CHANGES.txt b/CHANGES.txt
index fdc8fed0..6ef2f947 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,10 +1,10 @@
0.2.0
-----
+ * Set KeyStore to be optional (CASSANALYTICS-69)
* Unique restoreJobId per write target (CASSANALYTICS-81)
* Allow writing to local datacenter only for coordinated write
(CASSANALYTICS-75)
0.1.0
------
* Simplify SidecarTableSizeProvider (CASSANALYTICS-73)
* Use full ring instead of only IPs from configuration (CASSANALYTICS-20)
* Bulk Reader should dynamically size the Spark job based on estimated table
size (CASSANALYTICS-36)
diff --git
a/cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/validation/KeyStoreValidationTests.java
b/cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/validation/KeyStoreValidationTests.java
index f6cd75b1..2cfda192 100644
---
a/cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/validation/KeyStoreValidationTests.java
+++
b/cassandra-analytics-core/src/test/java/org/apache/cassandra/spark/validation/KeyStoreValidationTests.java
@@ -38,8 +38,7 @@ public class KeyStoreValidationTests
KeyStoreValidation validation = new KeyStoreValidation(secrets);
Throwable throwable = validation.perform();
- assertThat(throwable).isInstanceOf(RuntimeException.class);
- assertThat(throwable.getMessage()).isEqualTo("KeyStore is not
configured");
+ assertThat(throwable).isNull(); // KeyStore is optional
}
@Test
diff --git
a/cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/KeyStoreValidation.java
b/cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/KeyStoreValidation.java
index cf68ca88..eb1c0e48 100644
---
a/cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/KeyStoreValidation.java
+++
b/cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/KeyStoreValidation.java
@@ -74,7 +74,7 @@ public class KeyStoreValidation implements StartupValidation
{
if (!configured)
{
- throw new RuntimeException("KeyStore is not configured");
+ return; // KeyStore is optional
}
if (password == null)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
