You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/04/28 07:10:35 UTC
[GitHub] [pulsar] RobertIndie opened a new pull request #10416: [Kinesis] Fix null error messages in onFailure exception in KinesisSink.
RobertIndie opened a new pull request #10416:
URL: https://github.com/apache/pulsar/pull/10416
### Motivation
Currently, if the kinesis producer fails to send a message, the error message in the exception in `onFailure` is null.
So the log output will look like below:
`exception.getMessage()` is null.
If the exception is `UserRecordFailedException`, we need to extract it to see real error messages.
The expected output is as follows:
> [kpl-callback-pool-0-thread-0] ERROR org.apache.pulsar.io.kinesis.KinesisSink - [test-io] Failed to published message for replicator of Optional[persistent://public/default/test-kinesis-0]-Optional[420369924113]: Attempts:errorMessage:Unable to connect to endpoint with address : 3.15.36.110, errorCode:, delay:103, duration:12010;errorMessage:Unable to connect to endpoint, errorCode:, delay:54, duration:6005;errorMessage:Unable to connect to endpoint, errorCode:, delay:54, duration:6004;errorMessage:Unable to connect to endpoint, errorCode:, delay:50, duration:6004;errorMessage:Record has reached expiration, errorCode:Expired, delay:0, duration:0;
### Modifications
* Extract the `UserRecordFailedException` to see real error messages
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] sijie commented on pull request #10416: [Kinesis] Fix null error messages in onFailure exception in KinesisSink.
Posted by GitBox <gi...@apache.org>.
sijie commented on pull request #10416:
URL: https://github.com/apache/pulsar/pull/10416#issuecomment-829439757
@eolivelli @codelipenghui I marked this issue for 2.7.2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui merged pull request #10416: [Kinesis] Fix null error messages in onFailure exception in KinesisSink.
Posted by GitBox <gi...@apache.org>.
codelipenghui merged pull request #10416:
URL: https://github.com/apache/pulsar/pull/10416
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] eolivelli commented on pull request #10416: [Kinesis] Fix null error messages in onFailure exception in KinesisSink.
Posted by GitBox <gi...@apache.org>.
eolivelli commented on pull request #10416:
URL: https://github.com/apache/pulsar/pull/10416#issuecomment-829443769
Okay
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org