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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
