You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gora.apache.org by le...@apache.org on 2014/09/27 23:08:24 UTC
git commit: GORA-378 Log error trace as well as error message in
GoraRecordWriter
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 <le...@jpl.nasa.gov>
Authored: Sat Sep 27 14:03:39 2014 -0700
Committer: Lewis John McGibbney <le...@jpl.nasa.gov>
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();
}
}
}