diff --git a/realtime/src/main/java/com/metamx/druid/realtime/firehose/WikipediaIrcDecoder.java b/realtime/src/main/java/com/metamx/druid/realtime/firehose/WikipediaIrcDecoder.java index b1ecf91554e..fc45f5f4e91 100644 --- a/realtime/src/main/java/com/metamx/druid/realtime/firehose/WikipediaIrcDecoder.java +++ b/realtime/src/main/java/com/metamx/druid/realtime/firehose/WikipediaIrcDecoder.java @@ -199,7 +199,12 @@ class WikipediaIrcDecoder implements IrcDecoder @Override public List getDimension(String dimension) { - return ImmutableList.of(dimensions.get(dimension)); + final String value = dimensions.get(dimension); + if(value != null) { + return ImmutableList.of(value); + } else { + return ImmutableList.of(); + } } @Override