@Test
public void testToMapOnInfinityDoubleReturnMaxNegativeValue() {

    long timestampMillis = System.currentTimeMillis();
    EventHeaderProtos.Header header = EventHeaderProtos.Header.newBuilder().build();
    FlinkEventProtos.OperatorEvent.Builder operatorEvent = FlinkEventProtos.OperatorEvent.newBuilder()
        .setRecordsLagMax(Double.NEGATIVE_INFINITY);
    GarmadonMessage message = new GarmadonMessage(GarmadonSerialization.TypeMarker.FLINK_OPERATOR_EVENT, timestampMillis, header, operatorEvent.build(), null);
    Map<String, Object> map = message.toMap(true, true);
    TestCase.assertEquals(-Double.MAX_VALUE, map.get("records_lag_max"));
}