commit 2493bcbf508fcc9570c6e5798217e7feb55ccb7e
author ajaygit158 <ajaygit158@gmail.com> Wed May 17 11:25:33 2017 +0530
committer ajaygit158 <ajaygit158@gmail.com> Thu May 25 01:22:11 2017 +0530
tree 534389d790ce3ab4b8eb59ae9ff0d4bb945ee2bc
parent 1c902dfb22b5f815f9b5ec5441e646beec424ced

APEXMALHAR-2492 Correct usage of empty Slice in Malhar Library

library/src/main/java/org/apache/apex/malhar/lib/dedup/BoundedDedupOperator.java

diff --git a/library/src/main/java/org/apache/apex/malhar/lib/dedup/BoundedDedupOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/dedup/BoundedDedupOperator.java
index e2a1297..0552532 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/dedup/BoundedDedupOperator.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/dedup/BoundedDedupOperator.java
@@ -156,8 +156,7 @@
   protected void putManagedState(Object tuple)
   {
     Slice key = getKey(tuple);
-    ((ManagedTimeStateImpl)managedState).put(getBucketId(key), DEFAULT_CONSTANT_TIME,
-        key, new Slice(new byte[0]));
+    ((ManagedTimeStateImpl)managedState).put(getBucketId(key), DEFAULT_CONSTANT_TIME, key, new Slice(null, 0, 0));
   }
 
   protected int getBucketId(Slice key)

library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java

diff --git a/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java
index 3b5f5e2..9f83441 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java
@@ -186,7 +186,7 @@
   @Override
   protected void putManagedState(Object tuple)
   {
-    ((ManagedTimeUnifiedStateImpl)managedState).put(getTime(tuple), getKey(tuple), new Slice(new byte[0]));
+    ((ManagedTimeUnifiedStateImpl)managedState).put(getTime(tuple), getKey(tuple), new Slice(null, 0, 0));
   }