prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a
record too large exception for oversized records in changelog
URL: https://github.com/apache/samza/pull/1008#discussion_r297874975
##########
File path:
samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValueStorageEngineFactory.scala
##########
@@ -124,22 +129,39 @@ trait BaseKeyValueStorageEngineFactory[K, V] extends
StorageEngineFactory[K, V]
new LoggedStore(rawStore, changeLogSystemStreamPartition, collector,
loggedStoreMetrics)
}
- // wrap with serialization
- val serializedMetrics = new SerializedKeyValueStoreMetrics(storeName,
registry)
- val serialized = new SerializedKeyValueStore[K, V](maybeLoggedStore,
keySerde, msgSerde, serializedMetrics)
+ var toBeAccessLoggedStore: KeyValueStore[K, V] = null
+
+ if (largeMessagesExpected) {
+ // Execute "if" when we expect to get large messages and user defined
config -> EXPECT_LARGE_MESSAGES = true, no matter the value of
DROP_LARGE_MESSAGES
Review comment:
A better way to document this would be to describe what the expected
behavior is instead of what the code is actually doing. I.e., document the what
and the why, not the how.
Also, let's try to describe this in plain english instead of code and
variables. Same for the comments on line 149.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
