Skip to content

Commit

Permalink
[hotfix][runtime] Clean up unused member variables in StreamTwoInputS…
Browse files Browse the repository at this point in the history
…electableProcessor
  • Loading branch information
sunhaibotb authored and pnowojski committed Aug 30, 2019
1 parent 6779bd6 commit d23e237
Showing 1 changed file with 1 addition and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,6 @@
import org.apache.flink.streaming.runtime.tasks.StreamTask;
import org.apache.flink.util.ExceptionUtils;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.util.Collection;
import java.util.concurrent.CompletableFuture;
Expand All @@ -48,19 +45,14 @@
import static org.apache.flink.util.Preconditions.checkState;

/**
* Input reader for {@link org.apache.flink.streaming.runtime.tasks.TwoInputSelectableStreamTask}
* in the case that the operator is InputSelectable.
* Input reader for {@link org.apache.flink.streaming.runtime.tasks.TwoInputSelectableStreamTask}.
*
* @param <IN1> The type of the records that arrive on the first input
* @param <IN2> The type of the records that arrive on the second input
*/
@Internal
public final class StreamTwoInputSelectableProcessor<IN1, IN2> implements StreamInputProcessor {

private static final Logger LOG = LoggerFactory.getLogger(StreamTwoInputSelectableProcessor.class);

private static final CompletableFuture<?> UNAVAILABLE = new CompletableFuture<>();

private final TwoInputStreamOperator<IN1, IN2, ?> streamOperator;

private final TwoInputSelectionHandler inputSelectionHandler;
Expand Down

0 comments on commit d23e237

Please sign in to comment.