DEA-C01 Data Operations and Support Practice Test 13 — 15 Questions

Question 1

A data engineer is troubleshooting an AWS Glue job that writes data to an S3 bucket. The IAM role attached to the Glue job has the policy shown in the exhibit. The job fails when writing to the 'secrets/' prefix but succeeds when writing to other prefixes. What is the reason for the failure?

Accepted Answer

The Deny statement explicitly denies PutObject to the secrets/ prefix.. Option B is correct because the Deny statement explicitly denies s3:PutObject to the secrets/ prefix, which overrides the Allow. Option A is wrong because the resource is correctly specified for both statements. Option C is wrong because the Deny is explicit. Option D is wrong because the job can write to other prefixes.

Answer

The job does not have permission to write to the bucket at all.

Answer

The resource ARN in the Allow statement does not include the bucket itself.

Answer

The Deny statement is not effective because it is placed after the Allow.

Question 2

A data pipeline uses Amazon Kinesis Data Firehose to deliver data to an Amazon S3 bucket. The delivery stream is configured with a buffer size of 5 MB and a buffer interval of 60 seconds. The team notices that the S3 objects are much smaller than 5 MB. What is the most likely explanation?

Accepted Answer

The incoming data volume is low, so the 60-second buffer interval triggers delivery before the 5 MB buffer is filled.. Option A is correct because if the incoming data rate is low, the buffer interval (60 seconds) expires before the buffer size (5 MB) is reached, causing small objects. Option B is wrong because compression would reduce size but not cause small objects. Option C is wrong because S3 events are not related. Option D is wrong because S3 lifecycle would delete objects, not create small ones.

Answer

The S3 bucket has event notifications that split the objects.

Answer

The S3 bucket has a lifecycle policy that transitions objects to Glacier.

Answer

The delivery stream is using GZIP compression, which reduces the object size.

Question 3

A data engineer is investigating a failed AWS Glue job. The engineer runs the CLI command shown in the exhibit to retrieve the latest log stream. The output shows storedBytes: 0. What does this indicate?

Accepted Answer

The Glue job failed before writing any log events to CloudWatch.. Option C is correct because storedBytes: 0 means no log events were stored, likely because the job failed before writing any logs or logging was not enabled. Option A is wrong because logs are not expired; they were never written. Option B is wrong because the stream exists. Option D is wrong because the command retrieved the latest stream.

Answer

The log stream is from a different Glue job.

Answer

The log stream is empty because the job is still running.

Answer

The log stream has been expired and deleted.

Question 4

A data engineer runs an AWS Glue ETL job that reads from an S3 bucket containing JSON files. The job fails with an error indicating that some records are malformed. The engineer wants to skip the malformed records and continue processing. Which approach should the engineer take?

Accepted Answer

Configure the Glue DynamicFrame to use the `withErrorThreshold` option to skip corrupt records.. Option C is correct because Glue's DynamicFrame has a `recurse` option in `withErrorThreshold` or can use `from_options` with `multiLine` and `allowQuotedRecordDelimiters`. However, the best approach is to use the `from_catalog` or `from_options` with `withErrorThreshold` to skip bad records. Option A is wrong because modifying the data source is not always possible. Option B is wrong because using a different file format does not fix malformed JSON. Option D is wrong because AWS Glue Schema Registry validates schemas, not malformed records.

Answer

Pre-process the JSON files to correct the malformed records before Glue reads them.

Answer

Convert the JSON files to Parquet format and use Glue to read Parquet.

Answer

Use AWS Glue Schema Registry to reject invalid records.

Question 5

A data engineer is configuring an S3 bucket for a data lake. The engineer runs the command shown in the exhibit. What does the output indicate about the bucket?

Accepted Answer

Versioning is enabled on the bucket.. Option A is correct because Status: Enabled means versioning is enabled. Option B is wrong because MFADelete is disabled. Option C is wrong because versioning is enabled, not suspended. Option D is wrong because it does not indicate specific versions.

Answer

The bucket retains only the latest version of each object.

Answer

Versioning is suspended on the bucket.

Answer

MFA Delete is enabled for the bucket.

Question 6

A data engineering team notices that an AWS Glue ETL job fails intermittently with a 'ThrottlingException' error. The job reads from an Amazon S3 bucket and writes to an Amazon Redshift table. What is the MOST likely cause of this error?

Accepted Answer

The Redshift cluster's write throughput is exceeding its provisioned capacity.. Option A is correct because ThrottlingException when writing to Redshift typically indicates that the write throughput exceeds the cluster's capacity, causing API throttling. Option B is incorrect because S3 throttling would result in a different error (e.g., SlowDown). Option C is incorrect because Glue job throttling would be at the API level for job operations, not data operations. Option D is incorrect because insufficient memory would cause OutOfMemoryError, not ThrottlingException.

Answer

The S3 bucket's request rate is exceeding the bucket's performance limits.

Answer

The Glue job is exceeding the maximum number of concurrent runs allowed.

Answer

The Glue job's allocated memory is insufficient for the data volume.

Question 7

A company uses Amazon EMR to run Spark jobs on a transient cluster. The jobs process data from S3 and write results back to S3. The team wants to reduce costs by optimizing the cluster. Which action should the team take?

Accepted Answer

Use Spot Instances for the task nodes.. Using Spot Instances for task nodes in a transient EMR cluster significantly reduces compute costs because Spot Instances are spare AWS EC2 capacity offered at up to 90% discount compared to On-Demand. Since transient clusters are terminated after job completion, the risk of Spot Instance interruptions is mitigated—the job can simply be retried on a new cluster if needed. This directly addresses the cost optimization goal without sacrificing job functionality.

Answer

Increase the number of core nodes and use larger instance types.

Answer

Enable EMRFS consistent view.

Answer

Terminate the cluster after each job and manually restart it for the next job.

Question 8

A company runs an Amazon DynamoDB table with on-demand capacity. A new reporting application performs frequent Scan operations on the table, causing occasional 'ProvisionedThroughputExceededException' errors. The operations team needs to resolve this with minimal cost. What should they do?

Accepted Answer

Create a global secondary index (GSI) on the attributes used in the reporting queries.. Option B is correct because on-demand tables do not have provisioned throughput, but the error indicates throttling due to per-partition throughput limits. Creating a GSI allows the reporting queries to use a more efficient query pattern, reducing scans and partition hot spots. Option A is incorrect because switching to provisioned capacity would require careful capacity planning and might increase cost. Option C is incorrect because the error is not due to table-level limits but partition-level limits. Option D is incorrect because DAX is a caching layer that can reduce read load but does not address the root cause of inefficient Scan operations.

Answer

Increase the table's maximum read capacity by requesting a limit increase from AWS Support.

Answer

Switch the table to provisioned capacity and increase the read capacity units.

Answer

Enable DynamoDB Accelerator (DAX) to cache the Scan results.

Question 9

A data engineer is troubleshooting a failed AWS Glue ETL job that reads from an S3 bucket. The job logs show the following error: 'java.lang.RuntimeException: java.lang.ClassNotFoundException: Class org.apache.hadoop.fs.s3a.S3AFileSystem not found'. Which TWO actions will resolve this issue?

Accepted Answer

Include the hadoop-aws jar as an extra jar in the Glue job configuration.. Options A and D are correct. The error indicates the S3A filesystem class is missing, which is part of the Hadoop AWS library. Adding the jar to the job's extra jars (A) or using a Glue version that includes the library (D) fixes it. Option B is wrong because changing S3 access mode to EMRFS is for EMR, not Glue. Option C is wrong because the error is a classpath issue, not an IAM issue. Option E is wrong because enabling S3 endpoint is a networking issue.

Answer

Enable VPC S3 endpoint for the Glue job.

Answer

Update the IAM role to allow access to S3.

Answer

Change the S3 access mode from S3A to EMRFS.

Question 10

A data engineer is troubleshooting a failed Amazon Kinesis Data Firehose delivery stream. The stream is configured to deliver data to an Amazon S3 bucket. The error log shows: 'The destination S3 bucket's bucket policy does not allow the firehose to put objects.' What is the MOST likely issue?

Accepted Answer

The S3 bucket policy does not include an Allow statement for the firehose to put objects.. Option C is correct because the error states the bucket policy does not allow the firehose to put objects. The solution is to add an Allow statement in the bucket policy granting the firehose's IAM role permission to execute s3:PutObject. Option A is incorrect because the error is about bucket policy, not ACLs. Option B is incorrect because the error is already about permissions. Option D is incorrect because the issue is at the S3 bucket policy level, not IAM role trust policy.

Answer

The S3 bucket's ACL is configured to deny write access to the firehose.

Answer

The IAM role used by Firehose does not have the necessary permissions.

Answer

The IAM role's trust policy does not allow Firehose to assume the role.

Question 11

A company uses Amazon RDS for MySQL as a source for AWS DMS. The replication tasks are failing due to large transactions on the source. The team wants to reduce the impact of large transactions on DMS. Which THREE actions should the team take?

Accepted Answer

Increase the size of the source RDS instance and enable binary logging with ROW format.. Options A, C, and D are correct. BatchApply reduces apply time, tuning transaction size reduces memory pressure, and increasing the TLog size helps capture changes. Option B is wrong because parallel threads on source may increase CPU. Option E is wrong because switching to full load only is not a replication solution.

Answer

Increase the number of parallel threads on the source.

Answer

Use the 'full load only' migration type.

Question 12

A company uses Amazon Redshift for data warehousing. They notice that queries are running slowly, and the STL_LOAD_ERRORS table shows many 'Parse error' entries. The data is loaded from Amazon S3 using COPY commands. What is the MOST likely cause of the parse errors?

Accepted Answer

The source data files have a different schema or delimiter than what is specified in the COPY command.. Option A is correct because parse errors during COPY typically indicate that the source data does not match the target table schema (e.g., data type mismatch or delimiter issues). Option B is incorrect because incorrect compression would cause decompression errors, not parse errors. Option C is incorrect because data encryption issues would cause access denied errors. Option D is incorrect because insufficient compute resources would cause performance issues but not parse errors.

Answer

The Redshift cluster does not have enough compute nodes to process the data.

Answer

The IAM role used by Redshift does not have permission to decrypt the S3 objects.

Answer

The source data files are compressed using an unsupported compression format.

Question 13

A data engineer is monitoring Amazon CloudWatch metrics for an Amazon Redshift cluster and notices high CPU utilization. The engineer wants to reduce CPU usage. Which TWO actions should the engineer take?

Accepted Answer

Enable concurrency scaling to offload read queries to additional clusters.. Options B and C are correct. Setting concurrency scaling offloads queries, and using sort keys reduces the amount of data scanned. Option A is wrong because vacuum does not reduce CPU significantly. Option D is wrong because increasing node count increases CPU capacity but not reduce usage. Option E is wrong because enabling audit logging adds CPU overhead.

Answer

Increase the number of nodes in the cluster.

Answer

Run the VACUUM command on all tables.

Answer

Enable audit logging to monitor queries.

Question 14

A data engineer is monitoring an Amazon Kinesis Data Stream and notices that the 'WriteProvisionedThroughputExceeded' metric is frequently elevated. The stream has 5 shards and is used by multiple producers. What is the BEST action to resolve this issue?

Accepted Answer

Increase the number of shards in the Kinesis data stream.. Option B is correct because WriteProvisionedThroughputExceeded indicates that the write rate exceeds the shards' capacity. Increasing the number of shards increases the total write capacity. Option A is incorrect because retries do not resolve the root cause of insufficient capacity. Option C is incorrect because reducing the retention period does not affect write throughput. Option D is incorrect because enhancing the consumer's processing speed does not affect write throttling.

Answer

Increase the consumer's processing speed to reduce lag.

Answer

Reduce the data retention period of the stream.

Answer

Implement exponential backoff and retries in the producer applications.

Question 15

A data engineer notices that an AWS Glue ETL job that processes streaming data from Amazon Kinesis Data Streams is failing intermittently with a 'ResourceNotFoundException' error for the Kinesis stream. The job has been running successfully for weeks. Which action should the engineer take to resolve the issue?

Accepted Answer

Add the 'kinesis:DescribeStream' permission to the IAM role used by the Glue job.. Option C is correct because the most common cause of intermittent 'ResourceNotFoundException' for a Kinesis stream is that the IAM role used by the Glue job does not have the kinesis:DescribeStream permission, which is required for the job to check stream details. Option A is incorrect because increasing the Kinesis shard count would not resolve a permissions issue. Option B is incorrect because the Kinesis stream name must match exactly; case sensitivity would cause a consistent error, not intermittent. Option D is incorrect because the timeout setting on the Glue job would not cause a resource not found error.

Answer

Increase the number of shards in the Kinesis data stream to handle higher throughput.

Answer

Rename the Kinesis data stream to match the stream name used in the Glue job exactly, including case.

Answer

Increase the timeout for the Glue job in the job configuration.

DEA-C01 Data Operations and Support Practice Test 13 — 15 Questions

Exhibit

DEA-C01 Data Operations and Support Practice Test 13 — 15 Questions

Exhibit