[flink] 16/16: [hotfix][network] Drop one testing constructor of CheckpointedInputGate

[pnowojski]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 6311a651bf66c393bca86af02fbabd9a9c4129e9
Author: Piotr Nowojski <piotr.nowoj...@gmail.com>
AuthorDate: Wed Jun 26 17:02:15 2019 +0200

    [hotfix][network] Drop one testing constructor of CheckpointedInputGate
---
 .../flink/streaming/runtime/io/CheckpointedInputGate.java  | 14 --------------
 .../io/CheckpointBarrierAlignerMassiveRandomTest.java      |  2 +-
 2 files changed, 1 insertion(+), 15 deletions(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
index ce80e30..8e82a00 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java
@@ -18,7 +18,6 @@
 package org.apache.flink.streaming.runtime.io;
 
 import org.apache.flink.annotation.Internal;
-import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.runtime.io.AsyncDataInput;
 import org.apache.flink.runtime.io.network.api.CancelCheckpointMarker;
 import org.apache.flink.runtime.io.network.api.CheckpointBarrier;
@@ -63,19 +62,6 @@ public class CheckpointedInputGate implements 
AsyncDataInput<BufferOrEvent> {
         * {@link #bufferStorage}. */
        private boolean isFinished;
 
-       /**
-        * Creates a new checkpoint stream aligner.
-        *
-        * <p>There is no limit to how much data may be buffered during an 
alignment.
-        *
-        * @param inputGate The input gate to draw the buffers and events from.
-        * @param bufferStorage The storage to hold the buffers and events for 
blocked channels.
-        */
-       @VisibleForTesting
-       CheckpointedInputGate(InputGate inputGate, BufferStorage bufferStorage) 
{
-               this (inputGate, bufferStorage, "Testing: No task associated", 
null);
-       }
-
        public CheckpointedInputGate(
                        InputGate inputGate,
                        BufferStorage bufferStorage,
diff --git 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAlignerMassiveRandomTest.java
 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAlignerMassiveRandomTest.java
index 7da0aa3..82920aa 100644
--- 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAlignerMassiveRandomTest.java
+++ 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAlignerMassiveRandomTest.java
@@ -62,7 +62,7 @@ public class CheckpointBarrierAlignerMassiveRandomTest {
                                        new BufferPool[] { pool1, pool2 },
                                        new BarrierGenerator[] { new 
CountBarrier(100000), new RandomBarrier(100000) });
 
-                       CheckpointedInputGate checkpointedInputGate = new 
CheckpointedInputGate(myIG, new BufferSpiller(ioMan, myIG.getPageSize()));
+                       CheckpointedInputGate checkpointedInputGate = new 
CheckpointedInputGate(myIG, new BufferSpiller(ioMan, myIG.getPageSize()), 
"Testing: No task associated", null);
 
                        for (int i = 0; i < 2000000; i++) {
                                BufferOrEvent boe = 
checkpointedInputGate.pollNext().get();