You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by pr...@apache.org on 2016/03/08 20:24:54 UTC
incubator-apex-core git commit: Updated formatting
Repository: incubator-apex-core
Updated Branches:
refs/heads/master 9d8d9fd75 -> 30bb9e022
Updated formatting
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/30bb9e02
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/30bb9e02
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/30bb9e02
Branch: refs/heads/master
Commit: 30bb9e022f6508e293869fce482d3e64f5a4575a
Parents: 9d8d9fd
Author: Pramod Immaneni <pr...@datatorrent.com>
Authored: Mon Mar 7 15:41:06 2016 -0800
Committer: Pramod Immaneni <pr...@datatorrent.com>
Committed: Tue Mar 8 11:24:40 2016 -0800
----------------------------------------------------------------------
.../java/com/datatorrent/bufferserver/internal/LogicalNode.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/30bb9e02/bufferserver/src/main/java/com/datatorrent/bufferserver/internal/LogicalNode.java
----------------------------------------------------------------------
diff --git a/bufferserver/src/main/java/com/datatorrent/bufferserver/internal/LogicalNode.java b/bufferserver/src/main/java/com/datatorrent/bufferserver/internal/LogicalNode.java
index ab76d01..c08cfb9 100644
--- a/bufferserver/src/main/java/com/datatorrent/bufferserver/internal/LogicalNode.java
+++ b/bufferserver/src/main/java/com/datatorrent/bufferserver/internal/LogicalNode.java
@@ -158,7 +158,8 @@ public class LogicalNode implements DataListener
logger.debug("catching up {}->{}", upstream, group);
long lBaseSeconds = (long)iterator.getBaseSeconds() << 32;
- logger.debug("BaseSeconds = {} and lBaseSeconds = {}", Codec.getStringWindowId(baseSeconds), Codec.getStringWindowId(lBaseSeconds));
+ logger.debug("BaseSeconds = {} and lBaseSeconds = {}", Codec.getStringWindowId(baseSeconds),
+ Codec.getStringWindowId(lBaseSeconds));
if (lBaseSeconds > baseSeconds) {
baseSeconds = lBaseSeconds;
}