Fix bug with deleted Cassandra table column
[proteocache.git] / datadb / compbio / cassandra / CassandraWriter.java
index b12f59e..04adcec 100644 (file)
@@ -155,7 +155,6 @@ public class CassandraWriter {
                        // requests)
                        // TODO I don't like the bit of code. There should not be so many
                        // counters...
-                       int njobsTotal = 1;
                        int njobsOk = 0;
                        int njobsStop = 0;
                        int njobsError = 0;
@@ -175,15 +174,13 @@ public class CassandraWriter {
                        }
                        if (!results4.isExhausted()) {
                                Row r = results4.one();
-                               njobsTotal += r.getLong("Total");
                                njobsOk += r.getLong("TotalOK");
                                njobsError += r.getLong("TotalError");
                                njobsStop += r.getLong("TotalStopped");
                                njobsTimeOut += r.getLong("TotalTimeOut");
                        }
-                       String com = "INSERT INTO JobDateInfo " + "(jobday, Total, TotalOK, TotalStopped, TotalError, TotalTimeOut)" + " VALUES ("
-                                       + job.getStartingDate() + "," + njobsTotal + "," + njobsOk + "," + njobsStop + "," + njobsError + "," + njobsTimeOut
-                                       + ");";
+                       String com = "INSERT INTO JobDateInfo " + "(jobday, TotalOK, TotalStopped, TotalError, TotalTimeOut)" + " VALUES ("
+                                       + job.getStartingDate() + "," + njobsOk + "," + njobsStop + "," + njobsError + "," + njobsTimeOut + ");";
                        if (null == execute(com)) {
                                System.out.println("CassandraWriter.FormQueryTables: couldn't insert into JobDateInfo");
                                // return 0;