This is an automated email from the ASF dual-hosted git repository.
bharathkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new 8641081 Fixing log message for trimmed messages during state restore
(#1356)
8641081 is described below
commit 8641081f9e9ab6368a3d3617088dfa8dc8b70c93
Author: bkonold <[email protected]>
AuthorDate: Wed Jun 3 14:17:30 2020 -0700
Fixing log message for trimmed messages during state restore (#1356)
---
.../main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala
b/samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala
index afba824..eacb2ba 100644
---
a/samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala
+++
b/samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala
@@ -196,7 +196,7 @@ class KeyValueStorageEngine[K, V](
}
lastBatchFlushed = true
}
- info(restoredMessages + " entries trimmed for store: " + storeName + " in
directory: " + storeDir.toString + ".")
+ info(trimmedMessages + " entries trimmed for store: " + storeName + " in
directory: " + storeDir.toString + ".")
// flush the store and the changelog producer
flush() // TODO HIGH pmaheshw SAMZA-2338: Need a way to flush changelog
producers. This only flushes the stores.
