Repository: storm Updated Branches: refs/heads/master 0d5d4b129 -> d063a1ac3
STORM-731. Support compiling with HBase-1.0.0. Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/011debe9 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/011debe9 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/011debe9 Branch: refs/heads/master Commit: 011debe9bf6fb1b001bdac81cfae01b2f9f823fb Parents: 330e135 Author: Sriharsha Chintalapani <[email protected]> Authored: Sun Mar 29 09:02:21 2015 -0700 Committer: Sriharsha Chintalapani <[email protected]> Committed: Sun Mar 29 09:02:21 2015 -0700 ---------------------------------------------------------------------- .../java/org/apache/storm/hbase/trident/state/HBaseMapState.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/011debe9/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java ---------------------------------------------------------------------- diff --git a/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java b/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java index 82cc3f8..a040e51 100644 --- a/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java +++ b/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java @@ -231,6 +231,8 @@ public class HBaseMapState<T> implements IBackingMap<T> { throw new FailedException("Interrupted while writing to HBase", e); } catch (RetriesExhaustedWithDetailsException e) { throw new FailedException("Retries exhaused while writing to HBase", e); + } catch (IOException e) { + throw new FailedException("IOException while writing to HBase", e); } }
