[
https://issues.apache.org/jira/browse/TWILL-151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14936710#comment-14936710
]
ASF GitHub Bot commented on TWILL-151:
--------------------------------------
GitHub user sanojkodikkara opened a pull request:
https://github.com/apache/incubator-twill/pull/65
TWILL-151 Improve Logging error when fetching message after Kafka server
Modified the logic to log the exception only if the service is running, if
the service shutdown is under progress then the “running” flag will be false.
Now the code wont log the “java.net.ConnectException: Connection refused” ,
while the service shutdown.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sanojkodikkara/incubator-twill master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-twill/pull/65.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #65
----
commit a62a15bd693df45d45b49d13dbdc30c76e148237
Author: sanojkodikkara <[email protected]>
Date: 2015-09-30T10:53:08Z
TWILL-151 Improve Logging error when fetching message after Kafka server
is stopped
----
> Improve Logging error when fetching message after Kafka server is stopped
> -------------------------------------------------------------------------
>
> Key: TWILL-151
> URL: https://issues.apache.org/jira/browse/TWILL-151
> Project: Apache Twill
> Issue Type: Bug
> Reporter: Shankar Selvam
>
> when we add LogHandler, We start a Kafka Consumer thread in Client that polls
> Kafka Server (Started when AM Starts).
> When the AM stops, we stop the kafka server, but there can be race where we
> make request to fetch message from the KafkaConsumer after the Kafka Server
> is stopped. We log the stack-trace in this case and it can be confusing for
> the user, we can improve the error logging in this case to make it cleaner.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)