kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Randall Hauch (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-5774) WorkerSinkTask failure exception should include cause
Date Thu, 24 Aug 2017 17:50:02 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-5774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Randall Hauch updated KAFKA-5774:
---------------------------------
    Description: 
When the WorkerSinkTask shuts down because of a connector exception, the task throws an exception
with the message like the following:

{code}
ERROR Task Vital-ElasticsearchSinkConnector-0 threw an uncaught and unrecoverable exception
(org.apache.kafka.connect.runtime.WorkerTask:141)
org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable
exception.
	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:451)
        ...
{code}

without any information about the exception that caused the task to fail. The cause is logged
just prior to this error, but it would be more helpful for the shutdown error message to include
the cause.

  was:When the WorkerSinkTask shuts down because of a connector exception, the task throws
an exception with the message "" without any information about the exception that caused the
task to fail. The cause is logged just prior to this error, but it would be more helpful for
the shutdown error message to include the cause.


> WorkerSinkTask failure exception should include cause
> -----------------------------------------------------
>
>                 Key: KAFKA-5774
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5774
>             Project: Kafka
>          Issue Type: Bug
>          Components: KafkaConnect
>    Affects Versions: 0.11.0.0
>            Reporter: Randall Hauch
>
> When the WorkerSinkTask shuts down because of a connector exception, the task throws
an exception with the message like the following:
> {code}
> ERROR Task Vital-ElasticsearchSinkConnector-0 threw an uncaught and unrecoverable exception
(org.apache.kafka.connect.runtime.WorkerTask:141)
> org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable
exception.
> 	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:451)
>         ...
> {code}
> without any information about the exception that caused the task to fail. The cause is
logged just prior to this error, but it would be more helpful for the shutdown error message
to include the cause.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message