in src/main/java/com/amazonaws/services/dynamodbv2/streamsadapter/model/AmazonServiceExceptionTransformer.java [89:109]
private static AmazonServiceException applyFields(AmazonServiceException original, AmazonServiceException transformed) {
if (transformed == null) {
LOG.error("Could not transform a DynamoDB AmazonServiceException to a compatible Kinesis exception", original);
return original;
}
// Here we update the transformed exception fields with the original exception values
if (original.getErrorCode() != null) {
transformed.setErrorCode(original.getErrorCode());
}
// Null is transformed to UNKNOWN, so a null value is impossible.
transformed.setErrorType(original.getErrorType());
if (original.getRequestId() != null) {
transformed.setRequestId(original.getRequestId());
}
if (original.getServiceName() != null) {
transformed.setServiceName(original.getServiceName());
}
transformed.setStatusCode(original.getStatusCode());
LOG.error(String.format("DynamoDB Streams exception: %s tranformed to Kinesis %s", original.getClass(), transformed.getClass()), original);
return transformed;
}