Repository: giraph Updated Branches: refs/heads/trunk 9a232d185 -> e004359a1
GIRAPH-855: RecordReaderWrapper swallows exceptions (aching) Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/e004359a Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/e004359a Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/e004359a Branch: refs/heads/trunk Commit: e004359a1702cd01d7e40edba789d9fbfe65ac53 Parents: 9a232d1 Author: Avery Ching <[email protected]> Authored: Mon Feb 17 07:42:26 2014 -0800 Committer: Avery Ching <[email protected]> Committed: Mon Feb 17 19:15:57 2014 -0800 ---------------------------------------------------------------------- CHANGELOG | 2 ++ .../java/org/apache/giraph/hive/input/RecordReaderWrapper.java | 6 ++---- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/e004359a/CHANGELOG ---------------------------------------------------------------------- diff --git a/CHANGELOG b/CHANGELOG index 5ec1cc6..492ed57 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,6 +1,8 @@ Giraph Change Log Release 1.1.0 - unreleased + GIRAPH-855: RecordReaderWrapper swallows exceptions (aching) + GIRAPH-848: Allowing plain computation with types being configurable (ikabiljo via majakabiljo) GIRAPH-854: fix for test fail due to GIRAPH-840 (pavanka via majakabiljo) http://git-wip-us.apache.org/repos/asf/giraph/blob/e004359a/giraph-hive/src/main/java/org/apache/giraph/hive/input/RecordReaderWrapper.java ---------------------------------------------------------------------- diff --git a/giraph-hive/src/main/java/org/apache/giraph/hive/input/RecordReaderWrapper.java b/giraph-hive/src/main/java/org/apache/giraph/hive/input/RecordReaderWrapper.java index 7b64a40..5c941c6 100644 --- a/giraph-hive/src/main/java/org/apache/giraph/hive/input/RecordReaderWrapper.java +++ b/giraph-hive/src/main/java/org/apache/giraph/hive/input/RecordReaderWrapper.java @@ -51,11 +51,9 @@ public class RecordReaderWrapper<T> extends AbstractIterator<T> { return null; } return recordReader.getCurrentValue(); - } catch (IOException e) { - throw new IllegalStateException("computeNext: IOException occurred"); - } catch (InterruptedException e) { + } catch (IOException | InterruptedException e) { throw new IllegalStateException( - "computeNext: InterruptedException occurred"); + "computeNext: Unexpected exception occurred", e); } } }
