Hi,
I am writing (functional) unit test for RichAsyncFunction; following thread
- https://lists.apache.org/thread/12n9fcj9v50sdpnrqsmxgx2ktc44c32c
I am getting following exception. How would I resolve this?
Test -
@ClassRule
val miniCluster = MiniClusterWithClientResource(
MiniClusterResourceConfiguration.Builder()
.setNumberTaskManagers(1)
.setNumberSlotsPerTaskManager(2)
.build()
)
val env = StreamExecutionEnvironment.getExecutionEnvironment()
env.parallelism = PARALLELISM
val stream = env.fromElements(
DataProvider.getStoreUpdate(
storeId = consumerStoreResponse.getStores(0).id.value,
market = consumerStoreResponse.getStores(0).market.id.value.toLong()
)
)
val asyncStream = AsyncDataStream.unorderedWait(
stream,
MyAsyncFunction(),
10,
TimeUnit.SECONDS,
StoreEnricher.CAPACITY
).name(this.javaClass.name)
asyncStream.executeAndCollect(100)
Receiver class org.apache.flink.client.deployment.executors.LocalExecutor
does not define or inherit an implementation of the resolved method
'abstract java.util.concurrent.CompletableFuture
execute(org.apache.flink.api.dag.Pipeline,
org.apache.flink.configuration.Configuration, java.lang.ClassLoader)' of
interface org.apache.flink.core.execution.PipelineExecutor.
java.lang.AbstractMethodError: Receiver class
org.apache.flink.client.deployment.executors.LocalExecutor does not define
or inherit an implementation of the resolved method 'abstract
java.util.concurrent.CompletableFuture
execute(org.apache.flink.api.dag.Pipeline,
org.apache.flink.configuration.Configuration, java.lang.ClassLoader)' of
interface org.apache.flink.core.execution.PipelineExecutor.
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1957)
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1926)
at
org.apache.flink.streaming.api.datastream.DataStream.executeAndCollectWithClient(DataStream.java:1348)
at
org.apache.flink.streaming.api.datastream.DataStream.executeAndCollect(DataStream.java:1318)
at
org.apache.flink.streaming.api.datastream.DataStream.executeAndCollect(DataStream.java:1303)
