Package | Description |
---|---|
org.apache.flink.connector.testframe.container | |
org.apache.flink.connector.testframe.environment | |
org.apache.flink.connector.testframe.testsuites |
Modifier and Type | Class and Description |
---|---|
class |
FlinkContainerTestEnvironment
Test environment running job on
FlinkContainers . |
Modifier and Type | Class and Description |
---|---|
class |
MiniClusterTestEnvironment
Test environment for running jobs on Flink mini-cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
SourceTestSuiteBase.testTaskManagerFailure(TestEnvironment testEnv,
DataStreamSourceExternalContext<T> externalContext,
ClusterControllable controller,
CheckpointingMode semantic)
Test connector source with task manager failover.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.