--- ThriftServer.java 2008-08-14 19:45:04.000000000 +0100 +++ ThriftServer.java.new 2008-08-14 19:29:16.000000000 +0100 @@ -418,6 +418,9 @@ + new String(row) + ", ts=" + timestamp + " mutations=" + mutations.size()); for (Mutation m : mutations) { + if (m.column == null) { + throw new IllegalArgument("No column name provided"); + } if (m.isDelete) { LOG.debug("mutateRowTs: : delete - " + new String(getText(m.column))); } else { @@ -432,6 +435,9 @@ table = getTable(tableName); BatchUpdate batchUpdate = new BatchUpdate(getText(row), timestamp); for (Mutation m : mutations) { + if (m.column == null) { + throw new IllegalArgument("No column name provided"); + } if (m.isDelete) { batchUpdate.delete(getText(m.column)); } else { @@ -465,6 +471,9 @@ if (LOG.isDebugEnabled()) { LOG.debug("mutateRowsTs: : row=" + new String(row) + " mutations=" + mutations.size()); for (Mutation m : mutations) { + if (m.column == null) { + throw new IllegalArgument("No column name provided"); + } if (m.isDelete) { LOG.debug("mutateRowsTs: : delete - " + new String(getText(m.column))); } else { @@ -475,6 +484,9 @@ } BatchUpdate batchUpdate = new BatchUpdate(getText(row), timestamp); for (Mutation m : mutations) { + if (m.column == null) { + throw new IllegalArgument("No column name provided"); + } if (m.isDelete) { batchUpdate.delete(getText(m.column)); } else {