diff --git a/aws-api/src/main/java/com/amplifyframework/api/aws/MutiAuthSubscriptionOperation.java b/aws-api/src/main/java/com/amplifyframework/api/aws/MutiAuthSubscriptionOperation.java
index 7ab97a314..c54fe619b 100644
--- a/aws-api/src/main/java/com/amplifyframework/api/aws/MutiAuthSubscriptionOperation.java
+++ b/aws-api/src/main/java/com/amplifyframework/api/aws/MutiAuthSubscriptionOperation.java
@@ -17,7 +17,6 @@
 
 import androidx.annotation.NonNull;
 
-import com.amplifyframework.AmplifyException;
 import com.amplifyframework.api.ApiException;
 import com.amplifyframework.api.ApiException.ApiAuthException;
 import com.amplifyframework.api.aws.auth.AuthRuleRequestDecorator;
diff --git a/aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/SubscriptionProcessor.java b/aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/SubscriptionProcessor.java
index bf01e456d..4e96cd9fd 100644
--- a/aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/SubscriptionProcessor.java
+++ b/aws-datastore/src/main/java/com/amplifyframework/datastore/syncengine/SubscriptionProcessor.java
@@ -198,8 +198,7 @@ private boolean isExceptionType(DataStoreException exception, AppSyncErrorType e
                 emitter::onNext,
                 dataStoreException -> {
                     if (ErrorInspector.contains(dataStoreException, ApiException.ApiAuthException.class) ||
-                            isExceptionType(dataStoreException, AppSyncErrorType.UNAUTHORIZED))
-                    {
+                            isExceptionType(dataStoreException, AppSyncErrorType.UNAUTHORIZED)) {
                         // Ignore Unauthorized errors, so that DataStore can still be used even if the user is only
                         // authorized to read a subset of the models.
                         latch.countDown();