[
https://issues.apache.org/jira/browse/APEXCORE-393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207563#comment-15207563
]
ASF GitHub Bot commented on APEXCORE-393:
-----------------------------------------
Github user ishark commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/274#discussion_r57090295
--- Diff:
engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java ---
@@ -950,7 +977,11 @@ private void execute() throws YarnException,
IOException
if (!blacklistAdditions.isEmpty()) {
amRmClient.updateBlacklist(blacklistAdditions, null);
- blacklistedNodesQueueWithTimeStamp.add(new Pair<Long,
List<String>>(System.currentTimeMillis(), blacklistAdditions));
+ long timeStamp = System.currentTimeMillis();
+ for(String hostname : blacklistAdditions) {
--- End diff --
Addressed the checkstyle errors. Thus didn't get caught in checkstyle
because max allowed violation count was greater. Have reduced it now.
> Reset failure count when consecutive failed node is removed from blacklist
> --------------------------------------------------------------------------
>
> Key: APEXCORE-393
> URL: https://issues.apache.org/jira/browse/APEXCORE-393
> Project: Apache Apex Core
> Issue Type: Bug
> Reporter: Isha Arkatkar
> Assignee: Isha Arkatkar
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
