Repository: gora Updated Branches: refs/heads/master d48708eca -> 1a42a6239
GORA-378 Log error trace as well as error message in GoraRecordWriter Project: http://git-wip-us.apache.org/repos/asf/gora/repo Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/1a42a623 Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/1a42a623 Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/1a42a623 Branch: refs/heads/master Commit: 1a42a6239caf8f444a3c53ad7f86a6b681f7eccc Parents: d48708e Author: Lewis John McGibbney <[email protected]> Authored: Sat Sep 27 14:03:39 2014 -0700 Committer: Lewis John McGibbney <[email protected]> Committed: Sat Sep 27 14:03:39 2014 -0700 ---------------------------------------------------------------------- CHANGES.txt | 6 ++++++ .../org/apache/gora/cassandra/store/CassandraClient.java | 8 ++++---- .../java/org/apache/gora/mapreduce/GoraRecordWriter.java | 4 ++++ 3 files changed, 14 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/gora/blob/1a42a623/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 23cf5cb..546a8af 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -2,6 +2,12 @@ ==CHANGES.txt ======================================================================= +Current Development 0.6-SNAPSHOT + +* GORA-378 Log error trace as well as error message in GoraRecordWriter (lewismc) + +* GORA-376 Gora Cassandra doesn't accept user credentials for connection (Viju Kothuvatiparambil via lewismc) + * GORA-372: Fixed runtime error with the slf4j-api version conflict. (Viacheslav Dobromyslov (dobromyslov) via hsaputra) Apache Gora 0.5 Release - 15/09/14 http://git-wip-us.apache.org/repos/asf/gora/blob/1a42a623/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java ---------------------------------------------------------------------- diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java index cb54ed1..ddceec3 100644 --- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java +++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java @@ -272,19 +272,19 @@ public class CassandraClient<K, T extends PersistentBase> { String columnName = this.cassandraMapping.getColumn(fieldName); if (columnName == null) { - LOG.warn("Column name is null for field=" + fieldName ); + LOG.warn("Column name is null for field: " + fieldName ); return; } - if( LOG.isDebugEnabled() ) LOG.debug( "fieldName:"+fieldName +" columnName:" + columnName ); + if( LOG.isDebugEnabled() ) LOG.debug( "fieldName: "+fieldName +" columnName: " + columnName ); String ttlAttr = this.cassandraMapping.getColumnsAttribs().get(columnName); if ( null == ttlAttr ){ ttlAttr = CassandraMapping.DEFAULT_COLUMNS_TTL; - if( LOG.isDebugEnabled() ) LOG.debug( "ttl was not set for field:" + fieldName + " .Using " + ttlAttr ); + if( LOG.isDebugEnabled() ) LOG.debug( "ttl was not set for field: " + fieldName + ". Using " + ttlAttr ); } else { - if( LOG.isDebugEnabled() ) LOG.debug( "ttl for field:" + fieldName + " is " + ttlAttr ); + if( LOG.isDebugEnabled() ) LOG.debug( "ttl for field: " + fieldName + " is " + ttlAttr ); } synchronized(mutator) { http://git-wip-us.apache.org/repos/asf/gora/blob/1a42a623/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java ---------------------------------------------------------------------- diff --git a/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java b/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java index a1f326a..b05f775 100644 --- a/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java +++ b/gora-core/src/main/java/org/apache/gora/mapreduce/GoraRecordWriter.java @@ -56,6 +56,8 @@ public class GoraRecordWriter<K, T> extends RecordWriter<K, T> { store.close(); }catch(Exception e){ LOG.warn("Exception at GoraRecordWriter.class while closing datastore." + e.getMessage()); + LOG.warn("Trace: " + e.getStackTrace()); + e.printStackTrace(); } } @@ -70,6 +72,8 @@ public class GoraRecordWriter<K, T> extends RecordWriter<K, T> { } }catch(Exception e){ LOG.warn("Exception at GoraRecordWriter.class while writing to datastore. " + e.getMessage()); + LOG.warn("Trace: " + e.getStackTrace()); + e.printStackTrace(); } } }
