Hi, I am trying to access dynamo streams from a different aws account but getting resource not found exception while trying to access the dynamo streams from Task Manager. I have provided the following configurations :
*dynamodbStreamsConsumerConfig.setProperty(ConsumerConfigConstants.AWS_ROLE_CREDENTIALS_PROVIDER,AWSConfigConstants.CredentialProvider.ASSUME_ROLE.name <http://AWSConfigConstants.CredentialProvider.ASSUME_ROLE.name>());* *dynamodbStreamsConsumerConfig.setProperty(ConsumerConfigConstants.AWS_ROLE_ARN,dynamoDbConnect.getRoleArn());* *dynamodbStreamsConsumerConfig.setProperty(ConsumerConfigConstants.AWS_ROLE_SESSION_NAME,dynamoDbConnect.getRoleSessionName());* In the main class I am able to get the arn of dynamoDb table using STSAssumeRoleSessionCredentialsProvider, so the assume role is working fine . Getting error only while accessing from TM. I assume that the credentials are not required to be passed : https://github.com/apache/flink/blob/abbd6b02d743486f3c0c1336139dd6b3edd20840/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java#L164 Regards, Vinay Patil
