[cassandra] branch trunk updated: Add splits to output to fix CqlInputFormat

[dj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

djoshi pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 57bb806  Add splits to output to fix CqlInputFormat
57bb806 is described below

commit 57bb806d7941f8ae44611618bb6c16e940c3279c
Author: David Capwell <dc...@apple.com>
AuthorDate: Thu Apr 23 15:35:15 2020 -0700

    Add splits to output to fix CqlInputFormat
    
    Patch by David Capwell; reviewed by Dinesh Joshi for CASSANDRA-15637
---
 src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java
index 262965f..1ea8eda 100644
--- a/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java
+++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java
@@ -204,6 +204,7 @@ public class CqlInputFormat extends org.apache.hadoop.mapreduce.InputFormat<Long
                         maxSplits = tokenRangeSplits.size();
                         expectedPartionsForFailedRanges = tokenRangeSplits.get(0).getLength();
                     }
+                    splits.addAll(tokenRangeSplits);
                 }
                 catch (Exception e)
                 {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org