tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseSenderTest.java [125:141]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            int indexInOriginal = recordsInBuffer.indexOf(remainingRecord);
            boolean found = Arrays.binarySearch(failedRecords, indexInOriginal) >= 0;
            Assert.assertTrue(found);
        }
    }


    @DataProvider(name="retryingPartialFailures")
    public Object[][] retryingPartialFailuresData() {
        return new Object[][] {
                {10, new int[][] {{2,4,6,8,9}, {0,1}, {1}}},
                {5, new int[][] {{0,1,2,3,4}, {0,4}}}
        };
    }

    @Test(dataProvider="retryingPartialFailures")
    public void testRetryingPartialFailures(final int recordCount, final int[][] successiveFailedRecords) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tst/com/amazon/kinesis/streaming/agent/tailing/KinesisSenderTest.java [121:137]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                int indexInOriginal = recordsInBuffer.indexOf(remainingRecord);
                boolean found = Arrays.binarySearch(failedRecords, indexInOriginal) >= 0;
                Assert.assertTrue(found);
            }
        }
    }
    
    @DataProvider(name="retryingPartialFailures")
    public Object[][] retryingPartialFailuresData() {
        return new Object[][] {
                {10, new int[][] {{2,4,6,8,9}, {0,1}, {1}}},
                {5, new int[][] {{0,1,2,3,4}, {0,4}}}
        };
    }

    @Test(dataProvider="retryingPartialFailures")
    public void testRetryingPartialFailures(final int recordCount, final int[][] successiveFailedRecords) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -