From 4ffc50a8ffd729641cda22f2eca49c9cbe8ad719 Mon Sep 17 00:00:00 2001
From: glarwood <gabriel@fivetran.com>
Date: Fri, 22 Mar 2019 18:10:29 +0000
Subject: [PATCH] refactor(Worker): update error message

---
 .../services/kinesis/clientlibrary/lib/worker/Worker.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java
index 945a7938..9df8ff73 100644
--- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java
+++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java
@@ -522,7 +522,7 @@ public class Worker implements Runnable {
             Thread.sleep(idleTimeInMilliseconds);
         } catch (Exception e) {
             if (causedByStreamRecordProcessingError(e))
-                throw new RuntimeException("Failing worker after irrecoverable failure in processing records");
+                throw new RuntimeException("Failing worker after irrecoverable failure: " + e.getMessage());
             if (exitOnFailure && retries.getAndIncrement() > MAX_RETRIES)
                 throw new RuntimeException("Failing after " + MAX_RETRIES + " attempts", e);