--- old/test/java/util/stream/test/org/openjdk/tests/java/util/stream/SliceOpTest.java 2016-01-29 19:38:17.917108100 +0600 +++ new/test/java/util/stream/test/org/openjdk/tests/java/util/stream/SliceOpTest.java 2016-01-29 19:38:17.605068500 +0600 @@ -341,4 +341,13 @@ return Arrays.asList(0, 1, size / 2, size - 1, size, size + 1, 2 * size); } } + + public void testLimitParallelHugeInput() { + for (int n : new int[] {10, 100, 1000, 10000}) { + long[] actual = LongStream.range(0, Long.MAX_VALUE) + .parallel().filter(x -> true) // remove SIZED + .limit(n).toArray(); + assertEquals(LongStream.range(0, n).toArray(), actual); + } + } }