|
Change Parameter Type taskFactory : Function<Environment,? extends TwoInputStreamTask<IN1,IN2,OUT>> to taskFactory : Function<Environment,? extends AbstractTwoInputStreamTask<IN1,IN2,OUT>> in method public TwoInputStreamTaskTestHarness(taskFactory Function<Environment,? extends AbstractTwoInputStreamTask<IN1,IN2,OUT>>, inputType1 TypeInformation<IN1>, inputType2 TypeInformation<IN2>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTestHarness |
From |
To |
|
Change Parameter Type taskFactory : Function<Environment,? extends TwoInputStreamTask<IN1,IN2,OUT>> to taskFactory : Function<Environment,? extends AbstractTwoInputStreamTask<IN1,IN2,OUT>> in method public TwoInputStreamTaskTestHarness(taskFactory Function<Environment,? extends AbstractTwoInputStreamTask<IN1,IN2,OUT>>, numInputGates int, numInputChannelsPerGate int, inputGateAssignment int[], inputType1 TypeInformation<IN1>, inputType2 TypeInformation<IN2>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTestHarness |
From |
To |