[rocketmq-connect] branch master updated: [ISSUE #265] Fix ClassCastException (#266)

[sunxiaojian]

This is an automated email from the ASF dual-hosted git repository.

sunxiaojian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


The following commit(s) were added to refs/heads/master by this push:
     new 031a309  [ISSUE #265] Fix ClassCastException (#266)
031a309 is described below

commit 031a309cd05bdea13a8009cdfbf549e1d05ce2a7
Author: Oliver <wqdyx...@163.com>
AuthorDate: Wed Aug 24 11:26:28 2022 +0800

    [ISSUE #265] Fix ClassCastException (#266)
---
 .../apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java
 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java
index 9ffd1c2..325f0a6 100644
--- 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java
+++ 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java
@@ -184,9 +184,12 @@ public abstract class WorkerTask implements Runnable {
         try {
             Thread.currentThread().setName(THREAD_NAME_PREFIX + id);
             doRun();
+        } catch (InterruptedException e) {
+            // set interrupted flag to caller
+            Thread.currentThread().interrupt();
         } catch (Throwable t) {
             onFailure(t);
-            throw (Error) t;
+            throw t;
         } finally {
             Thread.currentThread().setName(savedName);
         }