MAPREDUCE-7368. DBOutputFormat.DBRecordWriter#write must throw exception when it fails. (#3671). Contributed by Stamatis Zampetakis.
Signed-off-by: Ayush Saxena <ayushsaxena@apache.org>
This commit is contained in:
parent
25849ff7b7
commit
bface2ac6c
@ -122,7 +122,7 @@ public void write(K key, V value) throws IOException {
|
|||||||
key.write(statement);
|
key.write(statement);
|
||||||
statement.addBatch();
|
statement.addBatch();
|
||||||
} catch (SQLException e) {
|
} catch (SQLException e) {
|
||||||
e.printStackTrace();
|
throw new IOException("Failed to execute SQL statement for key " + key, e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user