apache · sborya · Oct 16, 2017 · Oct 17, 2017 · Oct 25, 2017 · Oct 25, 2017
diff --git a/samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableOperatorImpl.java b/samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableOperatorImpl.java
@@ -55,7 +55,13 @@ protected void handleInit(Context context) {
   @Override
   protected CompletionStage<Collection<KV<K, V>>> handleMessageAsync(KV<K, V> message, MessageCollector collector,
       TaskCoordinator coordinator) {
-    table.put(message.getKey(), message.getValue());
+    K key = message.getKey();
+    V val = message.getValue();
+    if (val == null) {
+      table.delete(key);
+    } else {
+      table.put(key, val);
+    }
     return CompletableFuture.completedFuture(Collections.singleton(message));
   }