From 6a6b772c4980106efe71e3799da9e6a00746dd4e Mon Sep 17 00:00:00 2001
From: ChangLi <69448640+lichang-bd@users.noreply.github.com>
Date: Wed, 16 Dec 2020 19:37:01 +0800
Subject: [PATCH] [MINOR] Fix error information in exception (#2341)

---
 .../java/org/apache/hudi/operator/InstantGenerateOperator.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java b/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
index 165eeb087..cac701039 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
@@ -196,7 +196,7 @@ public class InstantGenerateOperator extends AbstractStreamOperator<HoodieRecord
         return;
       }
     }
-    throw new InterruptedException("Last instant costs more than ten second, stop task now");
+    throw new InterruptedException(String.format("Last instant costs more than %s second, stop task now", retryTimes * retryInterval));
   }