better error messages

ChangeLog.md

@@ -1,3 +1,6 @@
+## 0.0.15
+- Better error handling for case when C* inserts are failing
+
 ## 0.0.14
 - Updated cassandra-unloader to add support for collections,
 	consistency level, ssl, etc

README.md

@@ -15,11 +15,11 @@ loading of various types of delimited files, including
 
 ### Downloading
 This utility has already been built, and is available at
-https://github.com/brianmhess/cassandra-loader/releases/download/v0.0.14/cassandra-loader
+https://github.com/brianmhess/cassandra-loader/releases/download/v0.0.15/cassandra-loader
 
 Get it with wget:
 ```
-wget https://github.com/brianmhess/cassandra-loader/releases/download/v0.0.14/cassandra-loader
+wget https://github.com/brianmhess/cassandra-loader/releases/download/v0.0.15/cassandra-loader
 ```
 
 ### Building
@@ -255,7 +255,7 @@ cassandra-unloader
 
 Usage statement:
 ```
-version: 0.0.14
+version: 0.0.15
 Usage: -f <outputStem> -host <ipaddress> -schema <schema> [OPTIONS]
 OPTIONS:
   -configFile <filename>         File with configuration options

build.gradle

@@ -1,7 +1,7 @@
 apply plugin: 'java'
 apply plugin: 'application'
 
-def versionNum = '0.0.14'
+def versionNum = '0.0.15'
 
 allprojects {
     tasks.withType(JavaCompile) {

src/main/java/com/datastax/loader/CqlDelimLoad.java

@@ -86,7 +86,7 @@
 import com.codahale.metrics.Timer;
 
 public class CqlDelimLoad {
-    private String version = "0.0.14";
+    private String version = "0.0.15";
     private String host = null;
     private int port = 9042;
     private String username = null;

src/main/java/com/datastax/loader/CqlDelimLoadTask.java

@@ -86,6 +86,7 @@ class CqlDelimLoadTask implements Callable<Long> {
     private PrintStream badParsePrinter = null;
     private PrintStream badInsertPrinter = null;
     private PrintStream logPrinter = null;
+    private String logFname = "";
     private BufferedReader reader;
     private File infile;
     private int numFutures;
@@ -160,7 +161,8 @@ private void setup() throws IOException, ParseException {
 	if (null != badDir) {
 	    badParsePrinter = new PrintStream(new BufferedOutputStream(new FileOutputStream(badDir + "/" + readerName + BADPARSE)));
 	    badInsertPrinter = new PrintStream(new BufferedOutputStream(new FileOutputStream(badDir + "/" + readerName + BADINSERT)));
-	    logPrinter = new PrintStream(new BufferedOutputStream(new FileOutputStream(badDir + "/" + readerName + LOG)));
+	    logFname = badDir + "/" + readerName + LOG;
+	    logPrinter = new PrintStream(new BufferedOutputStream(new FileOutputStream(logFname)));
 	}
 
 	cdp = new CqlDelimParser(cqlSchema, delimiter, nullString, 
@@ -230,7 +232,7 @@ private long execute() throws IOException {
 		if (1 == batchSize) {
 		    resultSetFuture = session.executeAsync(bind);
 		    if (!fm.add(resultSetFuture, line)) {
-			System.err.println("Oh no - cleaning up");
+			System.err.println("There was an error.  Please check the log file for more information (" + logFname + ")");
 			cleanup(false);
 			return -2;
 		    }
@@ -241,7 +243,7 @@ private long execute() throws IOException {
 		    if (batchSize == batch.size()) {
 			resultSetFuture = session.executeAsync(batch);
 			if (!fm.add(resultSetFuture, line)) {
-			    System.err.println("Uh oh - cleaning up");
+			    System.err.println("There was an error.  Please check the log file for more information (" + logFname + ")");
 			    cleanup(false);
 			    return -2;
 			}

src/main/java/com/datastax/loader/CqlDelimUnload.java

@@ -75,7 +75,7 @@
 
 
 public class CqlDelimUnload {
-    private String version = "0.0.14";
+    private String version = "0.0.15";
     private String host = null;
     private int port = 9042;
     private String username = null;