src/main/java/com/amazonaws/kda/flink/benchmarking/util/DDBUtil.java [60:73]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				.withString("job_status", jobStatus)
				.withNumber("number_of_interactions_processed", numInteractionsProcessed)
				.withString("job_starttime", jobStartTime);
		try {
			PutItemOutcome outcome = table.putItem(item);
			int statusCode = outcome.getPutItemResult().getSdkHttpMetadata().getHttpStatusCode();
			if (statusCode == 200) {
				itemInserted = true;
			}
		} catch (Exception e) {
			e.printStackTrace();
			System.out.println("Item could not be inserted to DynamoDB table.");
		}
		return itemInserted;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/amazonaws/kda/flink/benchmarking/util/DDBUtil.java [96:109]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				.withString("job_status", jobStatus)
				.withNumber("number_of_interactions_processed", numInteractionsProcessed)
				.withString("job_starttime", jobStartTime);
		try {
			PutItemOutcome outcome = table.putItem(item);
			int statusCode = outcome.getPutItemResult().getSdkHttpMetadata().getHttpStatusCode();
			if (statusCode == 200) {
				itemInserted = true;
			}
		} catch (Exception e) {
			e.printStackTrace();
			System.out.println("Item could not be inserted to DynamoDB table.");
		}
		return itemInserted;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -