Repository: storm Updated Branches: refs/heads/master ca022899b -> 37403d17d
In the DRPCSpout class, when the fetch from the DRPC server fails, the log should return to get the DRPC request failed instead of getting the DRPC result failed Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cf91236b Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cf91236b Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cf91236b Branch: refs/heads/master Commit: cf91236b385065209cf50d86d2d3071a402e5cd8 Parents: 352cd46 Author: httfighter <han.tiant...@zte.com.cn> Authored: Tue Oct 10 10:51:06 2017 +0800 Committer: httfighter <han.tiant...@zte.com.cn> Committed: Tue Oct 10 10:51:06 2017 +0800 ---------------------------------------------------------------------- storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/cf91236b/storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java b/storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java index 8605c05..00ae469 100644 --- a/storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java +++ b/storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java @@ -213,12 +213,12 @@ public class DRPCSpout extends BaseRichSpout { } } catch (AuthorizationException aze) { reconnectAsync(client); - LOG.error("Not authorized to fetch DRPC result from DRPC server", aze); + LOG.error("Not authorized to fetch DRPC request from DRPC server", aze); } catch (TException e) { reconnectAsync(client); - LOG.error("Failed to fetch DRPC result from DRPC server", e); + LOG.error("Failed to fetch DRPC request from DRPC server", e); } catch (Exception e) { - LOG.error("Failed to fetch DRPC result from DRPC server", e); + LOG.error("Failed to fetch DRPC request from DRPC server", e); } } checkFutures();
