You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/09/21 00:03:02 UTC
[2/4] storm git commit: match style to the rest of the file
match style to the rest of the file
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e6819387
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e6819387
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e6819387
Branch: refs/heads/0.9.x-branch
Commit: e6819387019dca33e8d835a1110ca78fd8d8b672
Parents: aa8114f
Author: Michael Schonfeld <mi...@schonfeld.org>
Authored: Sat Sep 19 01:55:09 2015 -0400
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Mon Sep 21 07:01:55 2015 +0900
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/e6819387/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
index 7f801e5..067dddc 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -307,7 +307,7 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
* If the write operation fails, then we will close the channel and trigger a reconnect.
*/
private void flushMessages(Channel channel, final MessageBatch batch) {
- if(null == batch || batch.isEmpty()){
+ if (null == batch || batch.isEmpty()) {
return;
}