I am implementing a custom sql sink connector for ...
# troubleshooting
j
I am implementing a custom sql sink connector for Amazon SageMaker Feature Store. It's working fine but when I try the connector option
'aws.credentials.provider' = 'ASSUME_ROLE'
with the following table definition I get an exception
Copy code
CREATE TABLE dev_risktech_realtime_p2p_features (
    msisdn string,
    transmission_date_and_time string,
    total_amount_1h double,
    total_amount_1d double,
    total_amount_30d double,
    event_hour int,
    event_day_of_week int,
    event_day_of_month int,
    num_send_all_count_1d int,
    num_send_all_count_30d int,
    num_send_unq_count_1d int,
    num_send_unq_count_30d int
) WITH (
    'connector' = 'featurestore',
    'aws.region' = 'ap-southeast-1',
    'feature-group-name' = 'dev-risktech-realtime-p2p-features',
    'aws.credentials.provider' = 'ASSUME_ROLE',
    'aws.credentials.role.arn' = 'arn:aws:iam::799043958023:role/DS-FeatureStore-Dev-RiskTech-ExecutionRole',
    'aws.credentials.role.sessionName' = 'dev-session',
    'aws.credentials.role.provider' = 'ASSUME_ROLE'
);
Error in logs
Copy code
Caused by: software.amazon.awssdk.services.sts.model.StsException: 2 validation errors detected: Value null at 'roleArn' failed to satisfy constraint: Member must not be null; Value null at 'roleSessionName' failed to satisfy constraint: Member must not be null (Service: Sts, Status Code: 400, Request ID: 65dd559f-b6bc-4efd-80f6-b762e8baee78)
FWIW I followed the implementation of https://github.com/apache/flink-connector-aws
s
Anyone with AWS Connector experience???