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 <[email protected]> Authored: Mon Mar 7 15:41:06 2016 -0800 Committer: Pramod Immaneni <[email protected]> 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; }
