search

apache / pekko-connectors

Apache Pekko Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.
https://pekko.apache.org/
Apache License 2.0
63 stars 31 forks source link

get integration tests running in CI for aws-api-pekko-http #655

Open pjfanning opened 5 months ago

pjfanning commented 5 months ago
pjfanning commented 1 month ago

See https://github.com/apache/pekko-connectors/actions/runs/11051100151/job/30700278785 (which was run with the AWS creds set up as env vars but without AWS IAM permissions needed for Kinesis, DynamoDB, etc.

11:19:05.405 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.core.endpointdiscovery.providers.EndpointDiscoveryProviderChain -- Unable to load endpoint discovery from SystemPropertiesEndpointDiscoveryProvider():No endpoint discovery setting set.
11:19:05.417 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.core.endpointdiscovery.providers.EndpointDiscoveryProviderChain -- Unable to load endpoint discovery from ProfileEndpointDiscoveryProvider():No endpoint discovery setting provided in profile: default
11:19:05.759 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Creating an interceptor chain that will apply interceptors in the following order: [software.amazon.awssdk.core.internal.interceptor.HttpChecksumValidationInterceptor@7e77a5ad, software.amazon.awssdk.awscore.interceptor.HelpfulUnknownHostExceptionInterceptor@6e4171c0, software.amazon.awssdk.awscore.eventstream.EventStreamInitialRequestInterceptor@7b0e984a, software.amazon.awssdk.awscore.interceptor.TraceIdExecutionInterceptor@1efa5b6b, software.amazon.awssdk.services.kinesis.auth.scheme.internal.KinesisAuthSchemeInterceptor@5de3cfd4, software.amazon.awssdk.services.kinesis.endpoints.internal.KinesisResolveEndpointInterceptor@38c97ad9, software.amazon.awssdk.services.kinesis.endpoints.internal.KinesisRequestSetEndpointInterceptor@370a6942]
11:19:05.759 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Creating an interceptor chain that will apply interceptors in the following order: [software.amazon.awssdk.core.internal.interceptor.HttpChecksumValidationInterceptor@18906ef, software.amazon.awssdk.awscore.interceptor.HelpfulUnknownHostExceptionInterceptor@2f25456d, software.amazon.awssdk.awscore.eventstream.EventStreamInitialRequestInterceptor@6e7d2fb4, software.amazon.awssdk.awscore.interceptor.TraceIdExecutionInterceptor@4a9520b9, software.amazon.awssdk.services.sqs.auth.scheme.internal.SqsAuthSchemeInterceptor@362e97a, software.amazon.awssdk.services.sqs.endpoints.internal.SqsResolveEndpointInterceptor@6e9ca56, software.amazon.awssdk.services.sqs.endpoints.internal.SqsRequestSetEndpointInterceptor@1ee55b0, software.amazon.awssdk.services.sqs.internal.MessageMD5ChecksumInterceptor@629d3ddc]
11:19:05.759 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Creating an interceptor chain that will apply interceptors in the following order: [software.amazon.awssdk.core.internal.interceptor.HttpChecksumValidationInterceptor@46984494, software.amazon.awssdk.awscore.interceptor.HelpfulUnknownHostExceptionInterceptor@4ae8f6bf, software.amazon.awssdk.awscore.eventstream.EventStreamInitialRequestInterceptor@3e7a823, software.amazon.awssdk.awscore.interceptor.TraceIdExecutionInterceptor@e806ece, software.amazon.awssdk.services.s3.auth.scheme.internal.S3AuthSchemeInterceptor@a38376e, software.amazon.awssdk.services.s3.endpoints.internal.S3ResolveEndpointInterceptor@7686598, software.amazon.awssdk.services.s3.endpoints.internal.S3RequestSetEndpointInterceptor@397073e6, software.amazon.awssdk.services.s3.internal.handlers.StreamingRequestInterceptor@348b8c18, software.amazon.awssdk.services.s3.internal.handlers.CreateBucketInterceptor@7fc35ea0, software.amazon.awssdk.services.s3.internal.handlers.CreateMultipartUploadRequestInterceptor@3bc3b065, software.amazon.awssdk.services.s3.internal.handlers.DecodeUrlEncodedResponseInterceptor@1161bb8, software.amazon.awssdk.services.s3.internal.handlers.GetBucketPolicyInterceptor@6915bcce, software.amazon.awssdk.services.s3.internal.handlers.S3ExpressChecksumInterceptor@c46c912, software.amazon.awssdk.services.s3.internal.handlers.AsyncChecksumValidationInterceptor@2a200067, software.amazon.awssdk.services.s3.internal.handlers.SyncChecksumValidationInterceptor@1b5a0540, software.amazon.awssdk.services.s3.internal.handlers.EnableTrailingChecksumInterceptor@5fed3929, software.amazon.awssdk.services.s3.internal.handlers.ExceptionTranslationInterceptor@6559659f, software.amazon.awssdk.services.s3.internal.handlers.GetObjectInterceptor@4fd0626b, software.amazon.awssdk.services.s3.internal.handlers.ObjectMetadataInterceptor@46b1ed4]
11:19:05.759 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Creating an interceptor chain that will apply interceptors in the following order: [software.amazon.awssdk.core.internal.interceptor.HttpChecksumValidationInterceptor@1e326dd6, software.amazon.awssdk.awscore.interceptor.HelpfulUnknownHostExceptionInterceptor@15b9b990, software.amazon.awssdk.awscore.eventstream.EventStreamInitialRequestInterceptor@4cfc655, software.amazon.awssdk.awscore.interceptor.TraceIdExecutionInterceptor@1978a877, software.amazon.awssdk.services.dynamodb.auth.scheme.internal.DynamoDbAuthSchemeInterceptor@14a93a53, software.amazon.awssdk.services.dynamodb.endpoints.internal.DynamoDbResolveEndpointInterceptor@4c84746f, software.amazon.awssdk.services.dynamodb.endpoints.internal.DynamoDbRequestSetEndpointInterceptor@3603eec4]
11:19:05.771 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.auth.credentials.AwsCredentialsProviderChain -- Loading credentials from EnvironmentVariableCredentialsProvider()
11:19:05.771 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.auth.credentials.AwsCredentialsProviderChain -- Loading credentials from EnvironmentVariableCredentialsProvider()
11:19:05.771 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.auth.credentials.AwsCredentialsProviderChain -- Loading credentials from EnvironmentVariableCredentialsProvider()
11:19:05.792 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.auth.credentials.AwsCredentialsProviderChain -- Loading credentials from EnvironmentVariableCredentialsProvider()
11:19:05.797 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Interceptor 'software.amazon.awssdk.services.s3.internal.handlers.CreateBucketInterceptor@7fc35ea0' modified the message with its modifyRequest method.
11:19:05.819 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Interceptor 'software.amazon.awssdk.services.s3.endpoints.internal.S3RequestSetEndpointInterceptor@397073e6' modified the message with its modifyHttpRequest method.
11:19:05.819 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Interceptor 'software.amazon.awssdk.services.kinesis.endpoints.internal.KinesisRequestSetEndpointInterceptor@370a6942' modified the message with its modifyHttpRequest method.
11:19:05.819 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Interceptor 'software.amazon.awssdk.services.sqs.endpoints.internal.SqsRequestSetEndpointInterceptor@1ee55b0' modified the message with its modifyHttpRequest method.
11:19:05.819 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Interceptor 'software.amazon.awssdk.services.dynamodb.endpoints.internal.DynamoDbRequestSetEndpointInterceptor@3603eec4' modified the message with its modifyHttpRequest method.
11:19:05.853 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.retries.LegacyRetryStrategy -- Request attempt 1 token acquired (backoff: 0ms, cost: 0, capacity: 500/500)
11:19:05.853 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.retries.LegacyRetryStrategy -- Request attempt 1 token acquired (backoff: 0ms, cost: 0, capacity: 500/500)
11:19:05.854 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.retries.LegacyRetryStrategy -- Request attempt 1 token acquired (backoff: 0ms, cost: 0, capacity: 500/500)
11:19:05.857 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.request -- Sending Request: DefaultSdkHttpFullRequest(httpMethod=POST, protocol=https, host=sqs.eu-west-1.amazonaws.com, encodedPath=/, headers=[amz-sdk-invocation-id, Content-Length, Content-Type, User-Agent, X-Amz-Target], queryParameters=[])
11:19:05.857 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.request -- Sending Request: DefaultSdkHttpFullRequest(httpMethod=PUT, protocol=https, host=aws-spi-test-izgyu.s3.eu-west-1.amazonaws.com, encodedPath=, headers=[amz-sdk-invocation-id, Content-Length, Content-Type, User-Agent], queryParameters=[])
11:19:05.857 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.request -- Sending Request: DefaultSdkHttpFullRequest(httpMethod=POST, protocol=https, host=kinesis.eu-west-1.amazonaws.com, encodedPath=/, headers=[amz-sdk-invocation-id, Content-Length, Content-Type, User-Agent, X-Amz-Target], queryParameters=[])
11:19:05.857 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.request -- Sending Request: DefaultSdkHttpFullRequest(httpMethod=POST, protocol=https, host=dynamodb.eu-west-1.amazonaws.com, encodedPath=/, headers=[amz-sdk-invocation-id, Content-Length, Content-Type, User-Agent, X-Amz-Target], queryParameters=[])
11:19:05.858 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncSigningStage -- Using SelectedAuthScheme: aws.auth#sigv4
11:19:05.860 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncSigningStage -- Using SelectedAuthScheme: aws.auth#sigv4
11:19:05.865 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncSigningStage -- Using SelectedAuthScheme: aws.auth#sigv4
11:19:05.868 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncSigningStage -- Using SelectedAuthScheme: aws.auth#sigv4
11:19:05.878 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.core.internal.io.SdkLengthAwareInputStream -- Specified InputStream length of 46 has been reached. Returning EOF.
11:19:05.881 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.core.internal.io.SdkLengthAwareInputStream -- Specified InputStream length of 231 has been reached. Returning EOF.
11:19:05.881 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request: POST
/

amz-sdk-invocation-id:f9be05a2-33fe-7e4a-c365-3110f3a4a12e
amz-sdk-request:attempt=1; max=4
content-length:46
content-type:application/x-amz-cbor-1.1
host:kinesis.eu-west-1.amazonaws.com
x-amz-content-sha256:adc4968b54c4f0bc4e98668ebcf711b2e99b2f447650c07bc86180dcd05d1b52
x-amz-date:20240926T111905Z
x-amz-target:Kinesis_20131202.CreateStream

amz-sdk-invocation-id;amz-sdk-request;content-length;content-type;host;x-amz-content-sha256;x-amz-date;x-amz-target
adc4968b54c4f0bc4e98668ebcf711b2e99b2f447650c07bc86180dcd05d1b52
11:19:05.881 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.core.internal.io.SdkLengthAwareInputStream -- Specified InputStream length of 33 has been reached. Returning EOF.
11:19:05.881 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request: POST
/

amz-sdk-invocation-id:02767c93-5629-32aa-5103-861516a21c8b
amz-sdk-request:attempt=1; max=9
content-length:231
content-type:application/x-amz-json-1.0
host:dynamodb.eu-west-1.amazonaws.com
x-amz-content-sha256:de8cd7c4d743cc7f256998fee736d95dd8bce293a4b73cff4b6dcb0ec1bf04fc
x-amz-date:20240926T111905Z
x-amz-target:DynamoDB_20120810.CreateTable

amz-sdk-invocation-id;amz-sdk-request;content-length;content-type;host;x-amz-content-sha256;x-amz-date;x-amz-target
de8cd7c4d743cc7f256998fee736d95dd8bce293a4b73cff4b6dcb0ec1bf04fc
11:19:05.882 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request: POST
/

amz-sdk-invocation-id:b72bf46d-6d13-2a1a-75ab-475d4368ecbf
amz-sdk-request:attempt=1; max=4
content-length:33
content-type:application/x-amz-json-1.0
host:sqs.eu-west-1.amazonaws.com
x-amz-content-sha256:533b2a68547f2ab32ac648f1d95284f47aefff61d24728e12adf2b64dfe05fc1
x-amz-date:20240926T111905Z
x-amz-target:AmazonSQS.CreateQueue

amz-sdk-invocation-id;amz-sdk-request;content-length;content-type;host;x-amz-content-sha256;x-amz-date;x-amz-target
533b2a68547f2ab32ac648f1d95284f47aefff61d24728e12adf2b64dfe05fc1
11:19:05.882 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request Hash: 00eb4abdc6c6fa63da2629838508f91450af660b2c64c86842af93179d6611b6
11:19:05.882 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request Hash: 77ba61e8d7d080f4cd2437bbd7954ab6bcb3bbeaa953e6cefce79fc6d4ed514d
11:19:05.882 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 String to sign: AWS4-HMAC-SHA256
20240926T111905Z
20240926/eu-west-1/dynamodb/aws4_request
00eb4abdc6c6fa63da2629838508f91450af660b2c64c86842af93179d6611b6
11:19:05.882 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 String to sign: AWS4-HMAC-SHA256
20240926T111905Z
20240926/eu-west-1/sqs/aws4_request
77ba61e8d7d080f4cd2437bbd7954ab6bcb3bbeaa953e6cefce79fc6d4ed514d
11:19:05.884 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request: PUT
/

amz-sdk-invocation-id:d345bf3a-7be8-1158-e255-4b552071c812
amz-sdk-request:attempt=1; max=4
content-length:191
content-type:application/xml
host:aws-spi-test-izgyu.s3.eu-west-1.amazonaws.com
x-amz-content-sha256:UNSIGNED-PAYLOAD
x-amz-date:20240926T111905Z

amz-sdk-invocation-id;amz-sdk-request;content-length;content-type;host;x-amz-content-sha256;x-amz-date
UNSIGNED-PAYLOAD
11:19:05.885 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request Hash: 4ecd785b279e1fa99a3256a6eda7a61c87c398633bafd1b76613103ab9fa4536
11:19:05.885 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 String to sign: AWS4-HMAC-SHA256
20240926T111905Z
20240926/eu-west-1/s3/aws4_request
4ecd785b279e1fa99a3256a6eda7a61c87c398633bafd1b76613103ab9fa4536
11:19:05.895 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request Hash: d0e9d468a58122bb1e44ad254b10d6446f863123d401708aa545521dc19a01fe
11:19:05.896 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 String to sign: AWS4-HMAC-SHA256
20240926T111905Z
20240926/eu-west-1/kinesis/aws4_request
d0e9d468a58122bb1e44ad254b10d6446f863123d401708aa545521dc19a01fe
11:19:05.933 [pool-6-thread-5-ScalaTest-running-SQSITTest] DEBUG software.amazon.awssdk.core.internal.io.SdkLengthAwareInputStream -- Specified InputStream length of 33 has been reached. Returning EOF.
11:19:05.934 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.internal.io.SdkLengthAwareInputStream -- Specified InputStream length of 191 has been reached. Returning EOF.
11:19:05.934 [pool-6-thread-6-ScalaTest-running-KinesisITTest] DEBUG software.amazon.awssdk.core.internal.io.SdkLengthAwareInputStream -- Specified InputStream length of 46 has been reached. Returning EOF.
11:19:05.934 [pool-6-thread-9-ScalaTest-running-DynamoDBITTest] DEBUG software.amazon.awssdk.core.internal.io.SdkLengthAwareInputStream -- Specified InputStream length of 231 has been reached. Returning EOF.
11:19:07.072 [aws-pekko-http-pekko.actor.default-dispatcher-21] DEBUG software.amazon.awssdk.requestId -- Received failed response: 400, Request ID: c63f5b8c-c4f9-ce47-9950-1ee7364f442a, Extended Request ID: 95g8SGvQSpdIhUYBKdZrg7Rrf7LFbVqcttCW5H5TzvmVq9esrFdtvyQAajg73uN3HspNVHfZtE9/gLDWWw22tXb41wIkyI8D
11:19:07.073 [aws-pekko-http-pekko.actor.default-dispatcher-21] DEBUG software.amazon.awssdk.request -- Received failed response: 400, Request ID: c63f5b8c-c4f9-ce47-9950-1ee7364f442a, Extended Request ID: 95g8SGvQSpdIhUYBKdZrg7Rrf7LFbVqcttCW5H5TzvmVq9esrFdtvyQAajg73uN3HspNVHfZtE9/gLDWWw22tXb41wIkyI8D
11:19:07.076 [aws-pekko-http-pekko.actor.default-dispatcher-6] DEBUG software.amazon.awssdk.requestId -- Received failed response: 400, Request ID: 09DI3LQ960I64CFFTS4VC6TM6JVV4KQNSO5AEMVJF66Q9ASUAAJG, Extended Request ID: not available
11:19:07.076 [aws-pekko-http-pekko.actor.default-dispatcher-6] DEBUG software.amazon.awssdk.request -- Received failed response: 400, Request ID: 09DI3LQ960I64CFFTS4VC6TM6JVV4KQNSO5AEMVJF66Q9ASUAAJG, Extended Request ID: not available
11:19:07.081 [aws-pekko-http-pekko.actor.default-dispatcher-17] DEBUG software.amazon.awssdk.requestId -- Received failed response: 403, Request ID: e8af959c-a113-589c-b28f-caf3e4781435, Extended Request ID: not available
11:19:07.081 [aws-pekko-http-pekko.actor.default-dispatcher-17] DEBUG software.amazon.awssdk.request -- Received failed response: 403, Request ID: e8af959c-a113-589c-b28f-caf3e4781435, Extended Request ID: not available
11:19:07.123 [sdk-async-response-1-0] DEBUG software.amazon.awssdk.core.retry.ClockSkew -- Reported service date: Thu, 26 Sep 2024 11:19:07 GMT
11:19:07.131 [sdk-async-response-3-0] DEBUG software.amazon.awssdk.retries.LegacyRetryStrategy -- Request attempt 1 encountered non-retryable failure
software.amazon.awssdk.services.dynamodb.model.DynamoDbException: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: dynamodb:CreateTable on resource: arn:aws:dynamodb:eu-west-1:534396592182:table/Movies-x0XKV because no identity-based policy allows the dynamodb:CreateTable action (Service: DynamoDb, Status Code: 400, Request ID: 09DI3LQ960I64CFFTS4VC6TM6JVV4KQNSO5AEMVJF66Q9ASUAAJG)
    at software.amazon.awssdk.services.dynamodb.model.DynamoDbException$BuilderImpl.build(DynamoDbException.java:104)
    at software.amazon.awssdk.services.dynamodb.model.DynamoDbException$BuilderImpl.build(DynamoDbException.java:58)
    at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.unmarshall(AwsJsonProtocolErrorUnmarshaller.java:92)
    at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:66)
    at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:41)
    at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.lambda$handle$0(MetricCollectingHttpResponseHandler.java:52)
    at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:99)
    at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:92)
    at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.handle(MetricCollectingHttpResponseHandler.java:52)
    at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
    at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966)
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
    at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler$BaosSubscriber.onComplete(AsyncResponseHandler.java:135)
    at software.amazon.awssdk.core.internal.metrics.BytesReadTrackingPublisher$BytesReadTracker.onComplete(BytesReadTrackingPublisher.java:74)
    at org.apache.pekko.stream.impl.ReactiveStreamsCompliance$.tryOnComplete(ReactiveStreamsCompliance.scala:124)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$ActorOutputBoundary.complete(ActorGraphInterpreter.scala:418)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$ActorOutputBoundary.onUpstreamFinish(ActorGraphInterpreter.scala:444)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreter.processEvent(GraphInterpreter.scala:537)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:401)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:662)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$SimpleBoundaryEvent.execute(ActorGraphInterpreter.scala:71)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$SimpleBoundaryEvent.execute$(ActorGraphInterpreter.scala:67)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$RequestMore.execute(ActorGraphInterpreter.scala:299)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:637)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter.org$apache$pekko$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:813)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:831)
    at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
    at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:729)
    at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
    at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
    at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:272)
    at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:233)
    at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:245)
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
11:19:07.141 [sdk-async-response-1-0] DEBUG software.amazon.awssdk.core.retry.ClockSkew -- Reported service date: Thu, 26 Sep 2024 11:19:07 GMT
11:19:07.141 [sdk-async-response-1-0] DEBUG software.amazon.awssdk.retries.LegacyRetryStrategy -- Request attempt 1 encountered non-retryable failure
software.amazon.awssdk.services.sqs.model.SqsException: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: sqs:createqueue on resource: arn:aws:sqs:eu-west-1:534396592182:aws-spi-test-98ct because no identity-based policy allows the sqs:createqueue action (Service: Sqs, Status Code: 403, Request ID: e8af959c-a113-589c-b28f-caf3e4781435)
    at software.amazon.awssdk.services.sqs.model.SqsException$BuilderImpl.build(SqsException.java:104)
    at software.amazon.awssdk.services.sqs.model.SqsException$BuilderImpl.build(SqsException.java:58)
    at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.unmarshall(AwsJsonProtocolErrorUnmarshaller.java:92)
    at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:66)
    at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:41)
    at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.lambda$handle$0(MetricCollectingHttpResponseHandler.java:52)
    at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:99)
    at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:92)
    at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.handle(MetricCollectingHttpResponseHandler.java:52)
    at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
    at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966)
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
    at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler$BaosSubscriber.onComplete(AsyncResponseHandler.java:135)
    at software.amazon.awssdk.core.internal.metrics.BytesReadTrackingPublisher$BytesReadTracker.onComplete(BytesReadTrackingPublisher.java:74)
    at org.apache.pekko.stream.impl.ReactiveStreamsCompliance$.tryOnComplete(ReactiveStreamsCompliance.scala:124)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$ActorOutputBoundary.complete(ActorGraphInterpreter.scala:418)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$ActorOutputBoundary.onUpstreamFinish(ActorGraphInterpreter.scala:444)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreter.processEvent(GraphInterpreter.scala:537)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:401)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:662)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$SimpleBoundaryEvent.execute(ActorGraphInterpreter.scala:71)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$SimpleBoundaryEvent.execute$(ActorGraphInterpreter.scala:67)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$RequestMore.execute(ActorGraphInterpreter.scala:299)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:637)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter.org$apache$pekko$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:813)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:831)
    at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
    at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:729)
    at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
    at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
    at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:272)
    at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:233)
    at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:245)
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[INFO] [09/26/2024 11:19:07.164] [aws-pekko-http-pekko.actor.default-dispatcher-17] [CoordinatedShutdown(pekko://aws-pekko-http)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]
[INFO] [09/26/2024 11:19:07.164] [aws-pekko-http-pekko.actor.default-dispatcher-7] [CoordinatedShutdown(pekko://aws-pekko-http)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]
[INFO] [09/26/2024 11:19:07.164] [aws-pekko-http-pekko.actor.default-dispatcher-9] [CoordinatedShutdown(pekko://aws-pekko-http)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]
[info] KinesisITTest:
[info] Kinesis async client
[info] - should use a data stream: create + put + get + delete *** FAILED ***
[info]   java.util.concurrent.CompletionException: software.amazon.awssdk.services.kinesis.model.AccessDeniedException: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: kinesis:CreateStream on resource: arn:aws:kinesis:eu-west-1:534396592182:stream/aws-spi-test-drglr99 because no identity-based policy allows the kinesis:CreateStream action (Service: Kinesis, Status Code: 400, Request ID: c63f5b8c-c4f9-ce47-9950-1ee7364f442a, Extended Request ID: 95g8SGvQSpdIhUYBKdZrg7Rrf7LFbVqcttCW5H5TzvmVq9esrFdtvyQAajg73uN3HspNVHfZtE9/gLDWWw22tXb41wIkyI8D)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.errorAsCompletionException(CompletableFutureUtils.java:64)
[info]   at software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncExecutionFailureExceptionReportingStage.lambda$execute$0(AsyncExecutionFailureExceptionReportingStage.java:51)
[info]   at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
[info]   at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.lambda$forwardExceptionTo$0(CompletableFutureUtils.java:78)
[info]   at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
[info]   at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   ...
[info]   Cause: software.amazon.awssdk.services.kinesis.model.AccessDeniedException: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: kinesis:CreateStream on resource: arn:aws:kinesis:eu-west-1:534396592182:stream/aws-spi-test-drglr99 because no identity-based policy allows the kinesis:CreateStream action (Service: Kinesis, Status Code: 400, Request ID: c63f5b8c-c4f9-ce47-9950-1ee7364f442a, Extended Request ID: 95g8SGvQSpdIhUYBKdZrg7Rrf7LFbVqcttCW5H5TzvmVq9esrFdtvyQAajg73uN3HspNVHfZtE9/gLDWWw22tXb41wIkyI8D)
[info]   at software.amazon.awssdk.services.kinesis.model.AccessDeniedException$BuilderImpl.build(AccessDeniedException.java:126)
[info]   at software.amazon.awssdk.services.kinesis.model.AccessDeniedException$BuilderImpl.build(AccessDeniedException.java:80)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.unmarshall(AwsJsonProtocolErrorUnmarshaller.java:92)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:66)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:41)
[info]   at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.lambda$handle$0(MetricCollectingHttpResponseHandler.java:52)
[info]   at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:99)
[info] SQSITTest:
[info]   at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:92)
[info]   at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.handle(MetricCollectingHttpResponseHandler.java:52)
[info] Async SQS client
[info]   at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
[info] - should publish a message to a queue *** FAILED ***
[info]   ...
[info]   java.util.concurrent.CompletionException: software.amazon.awssdk.services.sqs.model.SqsException: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: sqs:createqueue on resource: arn:aws:sqs:eu-west-1:534396592182:aws-spi-test-98ct because no identity-based policy allows the sqs:createqueue action (Service: Sqs, Status Code: 403, Request ID: e8af959c-a113-589c-b28f-caf3e4781435)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.errorAsCompletionException(CompletableFutureUtils.java:64)
[info]   at software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncExecutionFailureExceptionReportingStage.lambda$execute$0(AsyncExecutionFailureExceptionReportingStage.java:51)
[info]   at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
[info]   at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.lambda$forwardExceptionTo$0(CompletableFutureUtils.java:78)
[info]   at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
[info]   at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   ...
[info]   Cause: software.amazon.awssdk.services.sqs.model.SqsException: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: sqs:createqueue on resource: arn:aws:sqs:eu-west-1:534396592182:aws-spi-test-98ct because no identity-based policy allows the sqs:createqueue action (Service: Sqs, Status Code: 403, Request ID: e8af959c-a113-589c-b28f-caf3e4781435)
[info]   at software.amazon.awssdk.services.sqs.model.SqsException$BuilderImpl.build(SqsException.java:104)
[info]   at software.amazon.awssdk.services.sqs.model.SqsException$BuilderImpl.build(SqsException.java:58)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.unmarshall(AwsJsonProtocolErrorUnmarshaller.java:92)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:66)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:41)
[info]   at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.lambda$handle$0(MetricCollectingHttpResponseHandler.java:52)
[info]   at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:99)
[info]   at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:92)
[info]   at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.handle(MetricCollectingHttpResponseHandler.java:52)
[info]   at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
[info]   ...
11:19:07.317 [aws-pekko-http-pekko.actor.default-dispatcher-19] DEBUG software.amazon.awssdk.requestId -- Received failed response: 403, Request ID: J9KZKCWTPZCDG57C, Extended Request ID: vj58c0+hceQI6B6dTCH+F8amRP4qu3+pfXWBsaS1vqZdoyBFV44jGG1gKWifEstlPwHKXkcPwsQfYX6PBt61sg==
11:19:07.317 [aws-pekko-http-pekko.actor.default-dispatcher-19] DEBUG software.amazon.awssdk.request -- Received failed response: 403, Request ID: J9KZKCWTPZCDG57C, Extended Request ID: vj58c0+hceQI6B6dTCH+F8amRP4qu3+pfXWBsaS1vqZdoyBFV44jGG1gKWifEstlPwHKXkcPwsQfYX6PBt61sg==
11:19:07.328 [sdk-async-response-0-0] DEBUG software.amazon.awssdk.core.retry.ClockSkew -- Reported service date: Thu, 26 Sep 2024 11:19:06 GMT
11:19:07.329 [sdk-async-response-0-0] DEBUG software.amazon.awssdk.core.retry.ClockSkew -- Reported service date: Thu, 26 Sep 2024 11:19:06 GMT
11:19:07.354 [sdk-async-response-0-0] DEBUG software.amazon.awssdk.retries.LegacyRetryStrategy -- Request attempt 1 encountered non-retryable failure
software.amazon.awssdk.services.s3.model.S3Exception: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: s3:CreateBucket on resource: "arn:aws:s3:::aws-spi-test-izgyu" because no identity-based policy allows the s3:CreateBucket action (Service: S3, Status Code: 403, Request ID: J9KZKCWTPZCDG57C, Extended Request ID: vj58c0+hceQI6B6dTCH+F8amRP4qu3+pfXWBsaS1vqZdoyBFV44jGG1gKWifEstlPwHKXkcPwsQfYX6PBt61sg==)
    at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handleErrorResponse(AwsXmlPredicatedResponseHandler.java:156)
    at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handleResponse(AwsXmlPredicatedResponseHandler.java:108)
    at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handle(AwsXmlPredicatedResponseHandler.java:85)
    at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handle(AwsXmlPredicatedResponseHandler.java:43)
    at software.amazon.awssdk.core.internal.handler.BaseClientHandler.lambda$successTransformationResponseHandler$7(BaseClientHandler.java:279)
    at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
    at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966)
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
    at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler$BaosSubscriber.onComplete(AsyncResponseHandler.java:135)
    at software.amazon.awssdk.core.internal.metrics.BytesReadTrackingPublisher$BytesReadTracker.onComplete(BytesReadTrackingPublisher.java:74)
    at org.apache.pekko.stream.impl.ReactiveStreamsCompliance$.tryOnComplete(ReactiveStreamsCompliance.scala:124)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$ActorOutputBoundary.complete(ActorGraphInterpreter.scala:418)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$ActorOutputBoundary.onUpstreamFinish(ActorGraphInterpreter.scala:444)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreter.processEvent(GraphInterpreter.scala:537)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:401)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:662)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:532)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:637)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter.org$apache$pekko$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:813)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:831)
    at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
    at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:729)
    at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
    at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
    at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:272)
    at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:233)
    at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:245)
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[INFO] [09/26/2024 11:19:07.358] [aws-pekko-http-pekko.actor.default-dispatcher-21] [CoordinatedShutdown(pekko://aws-pekko-http)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]
11:19:07.413 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Creating an interceptor chain that will apply interceptors in the following order: [software.amazon.awssdk.core.internal.interceptor.HttpChecksumValidationInterceptor@14c6b499, software.amazon.awssdk.awscore.interceptor.HelpfulUnknownHostExceptionInterceptor@1d55a8e0, software.amazon.awssdk.awscore.eventstream.EventStreamInitialRequestInterceptor@67957f78, software.amazon.awssdk.awscore.interceptor.TraceIdExecutionInterceptor@f65dad7, software.amazon.awssdk.services.s3.auth.scheme.internal.S3AuthSchemeInterceptor@2e26c5de, software.amazon.awssdk.services.s3.endpoints.internal.S3ResolveEndpointInterceptor@1e047a52, software.amazon.awssdk.services.s3.endpoints.internal.S3RequestSetEndpointInterceptor@52a6a855, software.amazon.awssdk.services.s3.internal.handlers.StreamingRequestInterceptor@733463b4, software.amazon.awssdk.services.s3.internal.handlers.CreateBucketInterceptor@6b244039, software.amazon.awssdk.services.s3.internal.handlers.CreateMultipartUploadRequestInterceptor@56cf61e5, software.amazon.awssdk.services.s3.internal.handlers.DecodeUrlEncodedResponseInterceptor@31cc9f69, software.amazon.awssdk.services.s3.internal.handlers.GetBucketPolicyInterceptor@61b57327, software.amazon.awssdk.services.s3.internal.handlers.S3ExpressChecksumInterceptor@2859d2a0, software.amazon.awssdk.services.s3.internal.handlers.AsyncChecksumValidationInterceptor@5344e07, software.amazon.awssdk.services.s3.internal.handlers.SyncChecksumValidationInterceptor@5056ae1f, software.amazon.awssdk.services.s3.internal.handlers.EnableTrailingChecksumInterceptor@1ab0c[379](https://github.com/apache/pekko-connectors/actions/runs/11051100151/job/30700278785#step:5:380), software.amazon.awssdk.services.s3.internal.handlers.ExceptionTranslationInterceptor@7c1ace5d, software.amazon.awssdk.services.s3.internal.handlers.GetObjectInterceptor@5bf9e3af, software.amazon.awssdk.services.s3.internal.handlers.ObjectMetadataInterceptor@3e3a9899]
11:19:07.414 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Interceptor 'software.amazon.awssdk.services.s3.internal.handlers.CreateBucketInterceptor@6b244039' modified the message with its modifyRequest method.
11:19:07.415 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.interceptor.ExecutionInterceptorChain -- Interceptor 'software.amazon.awssdk.services.s3.endpoints.internal.S3RequestSetEndpointInterceptor@52a6a855' modified the message with its modifyHttpRequest method.
11:19:07.415 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.retries.LegacyRetryStrategy -- Request attempt 1 token acquired (backoff: 0ms, cost: 0, capacity: 500/500)
11:19:07.416 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.request -- Sending Request: DefaultSdkHttpFullRequest(httpMethod=PUT, protocol=https, host=aws-spi-test-m4b0o.s3.eu-west-1.amazonaws.com, encodedPath=, headers=[amz-sdk-invocation-id, Content-Length, Content-Type, User-Agent], queryParameters=[])
11:19:07.416 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncSigningStage -- Using SelectedAuthScheme: aws.auth#sigv4
11:19:07.417 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request: PUT
/

amz-sdk-invocation-id:7fc7f93f-c137-78bb-9a54-8ad254285fb0
amz-sdk-request:attempt=1; max=4
content-length:191
content-type:application/xml
host:aws-spi-test-m4b0o.s3.eu-west-1.amazonaws.com
x-amz-content-sha256:UNSIGNED-PAYLOAD
x-amz-date:20240926T111907Z

amz-sdk-invocation-id;amz-sdk-request;content-length;content-type;host;x-amz-content-sha256;x-amz-date
UNSIGNED-PAYLOAD
11:19:07.417 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 Canonical Request Hash: f7996a49751e268bef9d3fa3a6f822225763f8021f6cd4ca849bf1f7091da39a
11:19:07.417 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.http.auth.aws.internal.signer.DefaultV4RequestSigner -- AWS4 String to sign: AWS4-HMAC-SHA256
20240926T111907Z
20240926/eu-west-1/s3/aws4_request
f7996a49751e268bef9d3fa3a6f822225763f8021f6cd4ca849bf1f7091da39a
11:19:07.418 [pool-6-thread-3-ScalaTest-running-S3ITTest] DEBUG software.amazon.awssdk.core.internal.io.SdkLengthAwareInputStream -- Specified InputStream length of 191 has been reached. Returning EOF.
11:19:07.903 [aws-pekko-http-pekko.actor.default-dispatcher-23] DEBUG software.amazon.awssdk.requestId -- Received failed response: 403, Request ID: X04REZNGGDD8RFRB, Extended Request ID: EB4+TNKrt4Q6QDA4td0kt6LRzPNo0w75LRUgWXcikeuebrWSn17PvOflZyLUpb2bRDysKQ0t0ybeoETPOXFsiuOelcaz31o9
11:19:07.903 [aws-pekko-http-pekko.actor.default-dispatcher-23] DEBUG software.amazon.awssdk.request -- Received failed response: 403, Request ID: X04REZNGGDD8RFRB, Extended Request ID: EB4+TNKrt4Q6QDA4td0kt6LRzPNo0w75LRUgWXcikeuebrWSn17PvOflZyLUpb2bRDysKQ0t0ybeoETPOXFsiuOelcaz31o9
11:19:07.904 [sdk-async-response-8-0] DEBUG software.amazon.awssdk.core.retry.ClockSkew -- Reported service date: Thu, 26 Sep 2024 11:19:07 GMT
11:19:07.904 [sdk-async-response-8-0] DEBUG software.amazon.awssdk.core.retry.ClockSkew -- Reported service date: Thu, 26 Sep 2024 11:19:07 GMT
11:19:07.904 [sdk-async-response-8-0] DEBUG software.amazon.awssdk.retries.LegacyRetryStrategy -- Request attempt 1 encountered non-retryable failure
software.amazon.awssdk.services.s3.model.S3Exception: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: s3:CreateBucket on resource: "arn:aws:s3:::aws-spi-test-m4b0o" because no identity-based policy allows the s3:CreateBucket action (Service: S3, Status Code: 403, Request ID: X04REZNGGDD8RFRB, Extended Request ID: EB4+TNKrt4Q6QDA4td0kt6LRzPNo0w75LRUgWXcikeuebrWSn17PvOflZyLUpb2bRDysKQ0t0ybeoETPOXFsiuOelcaz31o9)
    at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handleErrorResponse(AwsXmlPredicatedResponseHandler.java:156)
    at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handleResponse(AwsXmlPredicatedResponseHandler.java:108)
    at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handle(AwsXmlPredicatedResponseHandler.java:85)
    at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handle(AwsXmlPredicatedResponseHandler.java:43)
    at software.amazon.awssdk.core.internal.handler.BaseClientHandler.lambda$successTransformationResponseHandler$7(BaseClientHandler.java:279)
    at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
    at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966)
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
    at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler$BaosSubscriber.onComplete(AsyncResponseHandler.java:135)
    at software.amazon.awssdk.core.internal.metrics.BytesReadTrackingPublisher$BytesReadTracker.onComplete(BytesReadTrackingPublisher.java:74)
    at org.apache.pekko.stream.impl.ReactiveStreamsCompliance$.tryOnComplete(ReactiveStreamsCompliance.scala:124)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$ActorOutputBoundary.complete(ActorGraphInterpreter.scala:418)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$ActorOutputBoundary.onUpstreamFinish(ActorGraphInterpreter.scala:444)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreter.processEvent(GraphInterpreter.scala:537)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:401)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:662)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:532)
    at org.apache.pekko.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:637)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter.org$apache$pekko$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:813)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:831)
    at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
    at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
    at org.apache.pekko.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:729)
    at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
    at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
    at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:272)
    at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:233)
    at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:245)
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[INFO] [09/26/2024 11:19:07.906] [aws-pekko-http-pekko.actor.default-dispatcher-20] [CoordinatedShutdown(pekko://aws-pekko-http)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]
[info] DynamoDBITTest:
[info] DynamoDB
[info] - should create a table *** FAILED ***
[info]   java.util.concurrent.CompletionException: software.amazon.awssdk.services.dynamodb.model.DynamoDbException: User: arn:aws:iam::534[396](https://github.com/apache/pekko-connectors/actions/runs/11051100151/job/30700278785#step:5:397)592182:user/pekko-connectors is not authorized to perform: dynamodb:CreateTable on resource: arn:aws:dynamodb:eu-west-1:534396592182:table/Movies-x0XKV because no identity-based policy allows the dynamodb:CreateTable action (Service: DynamoDb, Status Code: 400, Request ID: 09DI3LQ960I64CFFTS4VC6TM6JVV4KQNSO5AEMVJF66Q9ASUAAJG)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.errorAsCompletionException(CompletableFutureUtils.java:64)
[info]   at software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncExecutionFailureExceptionReportingStage.lambda$execute$0(AsyncExecutionFailureExceptionReportingStage.java:51)
[info]   at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
[info]   at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.lambda$forwardExceptionTo$0(CompletableFutureUtils.java:78)
[info]   at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
[info]   at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   ...
[info]   Cause: software.amazon.awssdk.services.dynamodb.model.DynamoDbException: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: dynamodb:CreateTable on resource: arn:aws:dynamodb:eu-west-1:534396592182:table/Movies-x0XKV because no identity-based policy allows the dynamodb:CreateTable action (Service: DynamoDb, Status Code: [400](https://github.com/apache/pekko-connectors/actions/runs/11051100151/job/30700278785#step:5:401), Request ID: 09DI3LQ960I64CFFTS4VC6TM6JVV4KQNSO5AEMVJF66Q9ASUAAJG)
[info]   at software.amazon.awssdk.services.dynamodb.model.DynamoDbException$BuilderImpl.build(DynamoDbException.java:104)
[info]   at software.amazon.awssdk.services.dynamodb.model.DynamoDbException$BuilderImpl.build(DynamoDbException.java:58)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.unmarshall(AwsJsonProtocolErrorUnmarshaller.java:92)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:66)
[info]   at software.amazon.awssdk.protocols.json.internal.unmarshall.AwsJsonProtocolErrorUnmarshaller.handle(AwsJsonProtocolErrorUnmarshaller.java:41)
[info]   at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.lambda$handle$0(MetricCollectingHttpResponseHandler.java:52)
[info]   at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:99)
[info]   at software.amazon.awssdk.core.internal.util.MetricUtils.measureDurationUnsafe(MetricUtils.java:92)
[info]   at software.amazon.awssdk.core.http.MetricCollectingHttpResponseHandler.handle(MetricCollectingHttpResponseHandler.java:52)
[info]   at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
[info]   ...
[info] S3ITTest:
[info] S3 async client
[info] - should upload and download a file to a bucket + cleanup *** FAILED ***
[info]   java.util.concurrent.CompletionException: software.amazon.awssdk.services.s3.model.S3Exception: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: s3:CreateBucket on resource: "arn:aws:s3:::aws-spi-test-izgyu" because no identity-based policy allows the s3:CreateBucket action (Service: S3, Status Code: [403](https://github.com/apache/pekko-connectors/actions/runs/11051100151/job/30700278785#step:5:404), Request ID: J9KZKCWTPZCDG57C, Extended Request ID: vj58c0+hceQI6B6dTCH+F8amRP4qu3+pfXWBsaS1vqZdoyBFV44jGG1gKWifEstlPwHKXkcPwsQfYX6PBt61sg==)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.errorAsCompletionException(CompletableFutureUtils.java:64)
[info]   at software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncExecutionFailureExceptionReportingStage.lambda$execute$0(AsyncExecutionFailureExceptionReportingStage.java:51)
[info]   at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
[info]   at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.lambda$forwardExceptionTo$0(CompletableFutureUtils.java:78)
[info]   at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
[info]   at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   ...
[info]   Cause: software.amazon.awssdk.services.s3.model.S3Exception: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: s3:CreateBucket on resource: "arn:aws:s3:::aws-spi-test-izgyu" because no identity-based policy allows the s3:CreateBucket action (Service: S3, Status Code: 403, Request ID: J9KZKCWTPZCDG57C, Extended Request ID: vj58c0+hceQI6B6dTCH+F8amRP4qu3+pfXWBsaS1vqZdoyBFV44jGG1gKWifEstlPwHKXkcPwsQfYX6PBt61sg==)
[info]   at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handleErrorResponse(AwsXmlPredicatedResponseHandler.java:156)
[info]   at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handleResponse(AwsXmlPredicatedResponseHandler.java:108)
[info]   at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handle(AwsXmlPredicatedResponseHandler.java:85)
[info]   at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handle(AwsXmlPredicatedResponseHandler.java:43)
[info]   at software.amazon.awssdk.core.internal.handler.BaseClientHandler.lambda$successTransformationResponseHandler$7(BaseClientHandler.java:279)
[info]   at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
[info]   at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966)
[info]   at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
[info]   ...
[info] - should multipart upload *** FAILED ***
[info]   java.util.concurrent.CompletionException: software.amazon.awssdk.services.s3.model.S3Exception: User: arn:aws:iam::53[439](https://github.com/apache/pekko-connectors/actions/runs/11051100151/job/30700278785#step:5:440)6592182:user/pekko-connectors is not authorized to perform: s3:CreateBucket on resource: "arn:aws:s3:::aws-spi-test-m4b0o" because no identity-based policy allows the s3:CreateBucket action (Service: S3, Status Code: 403, Request ID: X04REZNGGDD8RFRB, Extended Request ID: EB4+TNKrt4Q6QDA4td0kt6LRzPNo0w75LRUgWXcikeuebrWSn17PvOflZyLUpb2bRDysKQ0t0ybeoETPOXFsiuOelcaz31o9)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.errorAsCompletionException(CompletableFutureUtils.java:64)
[info]   at software.amazon.awssdk.core.internal.http.pipeline.stages.AsyncExecutionFailureExceptionReportingStage.lambda$execute$0(AsyncExecutionFailureExceptionReportingStage.java:51)
[info]   at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
[info]   at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
[info]   at software.amazon.awssdk.utils.CompletableFutureUtils.lambda$forwardExceptionTo$0(CompletableFutureUtils.java:78)
[info]   at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
[info]   at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   ...
[info]   Cause: software.amazon.awssdk.services.s3.model.S3Exception: User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: s3:CreateBucket on resource: "arn:aws:s3:::aws-spi-test-m4b0o" because no identity-based policy allows the s3:CreateBucket action (Service: S3, Status Code: 403, Request ID: X04REZNGGDD8RFRB, Extended Request ID: EB4+TNKrt4Q6QDA4td0kt6LRzPNo0w75LRUgWXcikeuebrWSn17PvOflZyLUpb2bRDysKQ0t0ybeoETPOXFsiuOelcaz31o9)
[info]   at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handleErrorResponse(AwsXmlPredicatedResponseHandler.java:156)
[info]   at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handleResponse(AwsXmlPredicatedResponseHandler.java:108)
[info]   at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handle(AwsXmlPredicatedResponseHandler.java:85)
[info]   at software.amazon.awssdk.protocols.xml.internal.unmarshall.AwsXmlPredicatedResponseHandler.handle(AwsXmlPredicatedResponseHandler.java:43)
[info]   at software.amazon.awssdk.core.internal.handler.BaseClientHandler.lambda$successTransformationResponseHandler$7(BaseClientHandler.java:279)
[info]   at software.amazon.awssdk.core.internal.http.async.AsyncResponseHandler.lambda$prepare$0(AsyncResponseHandler.java:92)
[info]   at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966)
[info]   at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
[info]   at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[info]   at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
[info]   ...
[info] Run completed in 3 seconds, 682 milliseconds.
[info] Total number of tests run: 5
[info] Suites: completed 4, aborted 0
[info] Tests: succeeded 0, failed 5, canceled 0, ignored 0, pending 0
[info] *** 5 TESTS FAILED ***
[error] Failed tests:
[error]     org.apache.pekko.stream.connectors.awsspi.kinesis.KinesisITTest
[error]     org.apache.pekko.stream.connectors.awsspi.dynamodb.DynamoDBITTest
[error]     org.apache.pekko.stream.connectors.awsspi.s3.S3ITTest
[error]     org.apache.pekko.stream.connectors.awsspi.sqs.SQSITTest
[error] (aws-spi-pekko-http / IntegrationTest / test) sbt.TestsFailedException: Tests unsuccessful
[error] Total time: 12 s, compl
jtjeferreira commented 1 month ago

The important bits are User: arn:aws:iam::534396592182:user/pekko-connectors is not authorized to perform: XXX on resource: YYY:

of course after these are fixed others will be missing...

mdedetrich commented 1 month ago

Need to work with ASF infra to give the necessary permissions to do these tests.

They also will not work on PR's, instead the tests will only work on a GitHub branch that runs against main (see the existing S3 tests for details)

pjfanning commented 1 month ago

I think we will need to consider making changes to the tests so that the created resources are more deterministic (name wise) and that the tests clean up after themselves in all scenarios.

It would be ideal not to have to go to ASF Infra and request that we can create KInesis resources (for example) without any restrictions.