add some live prometheus test data

Author: BrandonArp

src/main/docker/mad/Dockerfile

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-FROM openjdk:8u302-jre-slim
+FROM openjdk:8u302-jre
 
 MAINTAINER arpnetworking
 

src/main/java/com/arpnetworking/metrics/mad/parsers/PrometheusToRecordParser.java

@@ -40,13 +40,16 @@
 import org.xerial.snappy.Snappy;
 
 import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
 import java.time.Instant;
 import java.time.ZoneOffset;
 import java.time.ZonedDateTime;
 import java.util.List;
 import java.util.Objects;
 import java.util.Optional;
 import java.util.UUID;
+import java.util.concurrent.atomic.AtomicInteger;
 
 /**
  * Parses the Prometheus protobuf binary protocol into records.
@@ -111,7 +114,12 @@ public List<Record> parse(final HttpRequest data) throws ParsingException {
         final List<Record> records = Lists.newArrayList();
         final byte[] uncompressed;
         try {
-            uncompressed = Snappy.uncompress(data.getBody().toArray());
+            final byte[] input = data.getBody().toArray();
+            int outputFile = _outputFileNumber.incrementAndGet();
+            if (outputFile < 10) {
+                Files.write(Paths.get("prometheus_debug_" + outputFile), input);
+            }
+            uncompressed = Snappy.uncompress(input);
         } catch (final IOException e) {
             throw new ParsingException("Failed to decompress snappy stream", data.getBody().toArray(), e);
         }
@@ -185,6 +193,7 @@ private static String createUnitMapKey(final String name) {
     }
 
     private final boolean _interpretUnits;
+    private final AtomicInteger _outputFileNumber = new AtomicInteger(0);
 
     private static final ImmutableMap<String, Unit> UNIT_MAP = ImmutableMap.of(
             createUnitMapKey("seconds"), Unit.SECOND,

src/test/java/com/arpnetworking/metrics/mad/parsers/PrometheusToRecordParserTest.java

@@ -156,6 +156,13 @@ public void testUnitParserBits() {
         testUnitParsing("bits", Unit.BIT);
     }
 
+    @Test
+    public void testLive1() throws ParsingException, IOException {
+        final List<Record> records = parseRecords("PrometheusParserTest/testLivePrometheus1");
+
+        Assert.assertEquals(0, records.size());
+    }
+
     private static void testUnitParsing(final String prometheusUnit, final Unit expected) {
         assertUnitNewName(prometheusUnit, prometheusUnit, expected);
         assertUnitNewName("foo_" + prometheusUnit, prometheusUnit, expected);