Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2476#discussion_r158125258
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/TridentKafkaState.java
---
@@ -116,8 +114,9 @@ public void updateState(List<TridentTuple> tuples,
TridentCollector collector) {
}
if (exceptions.size() > 0) {
- StringBuilder errorMsg = new StringBuilder("Could not
retrieve result for messages " + tuples + " from topic = " + topic
- + " because of the following exceptions:" +
System.lineSeparator());
+ StringBuilder errorMsg = new StringBuilder("Could not
retrieve result for messages ");
--- End diff --
Since the message is only ~5 strings long, I don't think there's much
reason to use a StringBuilder at all.
---
