Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2295#discussion_r139648054
--- Diff:
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/TridentResultSetValuesMapper.java
---
@@ -44,6 +44,8 @@ public TridentResultSetValuesMapper(Fields
outputDeclaredFields) {
@Override
public List<List<Values>> map(Session session, Statement statement,
ITuple tuple) {
List<List<Values>> list = new ArrayList<>();
+ List<Values> innerList = new LinkedList<>();
--- End diff --
Could you explain that how different the changeset is? I don't get it and
for me it looks like same.
---