clean up exception messages further. return null for getPath()

coltnz · Apr 17, 2009 · 23353a9 · 23353a9
1 parent fe30446
commit 23353a9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/java/cascading/jdbc/JDBCTap.java b/src/java/cascading/jdbc/JDBCTap.java
@@ -133,7 +133,7 @@ public String getTableName()
    */
   public Path getPath()
     {
-    return new Path( "jdbc:/" + connectionUrl.replaceAll( ":", "_" ) );
+    return null;
     }
 
   public TupleEntryIterator openForRead( JobConf conf ) throws IOException

diff --git a/src/java/cascading/jdbc/db/DBOutputFormat.java b/src/java/cascading/jdbc/db/DBOutputFormat.java
@@ -87,7 +87,7 @@ public void close( Reporter reporter ) throws IOException
           LOG.warn( StringUtils.stringifyException( sqlException ) );
           }
 
-        throw new IOException( "unable to commit batch", exception );
+        throw new IOException( "unable to commit batch: " + exception.getMessage(), exception.getNextException() );
         }
       finally
         {
-Original file line number
+Diff line change
@@ Expand Up / @@ -87,7 +87,7 @@ public void close( Reporter reporter ) throws IOException @@
               LOG.warn( StringUtils.stringifyException( sqlException ) );
               }
-            throw new IOException( "unable to commit batch", exception );
+            throw new IOException( "unable to commit batch: " + exception.getMessage(), exception.getNextException() );
             }
           finally
             {
@@ Expand Down @@