diff --git a/sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempBasicAuthClientExecutor.java b/sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempBasicAuthClientExecutor.java index 965fc8741374..14528b3c3dfc 100644 --- a/sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempBasicAuthClientExecutor.java +++ b/sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempBasicAuthClientExecutor.java @@ -56,7 +56,7 @@ * response is 401 Unauthorized, the client will execute an additional request with Basic Auth * header to refresh the token. */ -public class SempBasicAuthClientExecutor implements Serializable { +public class SempBasicAuthClientExecutor { // Every request will be repeated 2 times in case of abnormal connection failures. private static final int REQUEST_NUM_RETRIES = 2; private static final Map COOKIE_MANAGER_MAP = diff --git a/sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/BasicAuthMultipleSempClient.java b/sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/BasicAuthMultipleSempClient.java index b930270ccac4..637cecdcfd15 100644 --- a/sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/BasicAuthMultipleSempClient.java +++ b/sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/BasicAuthMultipleSempClient.java @@ -29,7 +29,7 @@ * Example class showing how the {@link BasicAuthSempClient} can be extended or have functionalities * overridden. In this case, the modified method is {@link * BasicAuthSempClient#getBacklogBytes(String)}, which queries multiple SEMP endpoints to collect - * acurrate backlog metrics. For usage, see {@link SolaceIOMultipleSempIT}. + * accurate backlog metrics. For usage, see {@link SolaceIOMultipleSempIT}. */ public class BasicAuthMultipleSempClient extends BasicAuthSempClient { private final List sempBacklogBasicAuthClientExecutors;