[NU-1979] MiniCluster refactor: separated module + passing StreamExecutionEnvironment #16360
Annotations
3 errors
pl.touk.nussknacker.engine.management.streaming.FlinkStreamingDeploymentManagerSpec ► be able verify&redeploy kafka scenario:
engine/flink/management/src/it/scala/pl/touk/nussknacker/engine/management/streaming/StreamingDockerTest.scala#L82
Failed test found in:
engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.FlinkStreamingDeploymentManagerSpec.xml
Error:
org.scalatest.exceptions.TestFailedException: The future returned an exception of type: java.lang.IllegalArgumentException, with message: State is incompatible, please stop scenario and start again with clean state.
|
pl.touk.nussknacker.engine.management.streaming.FlinkStreamingDeploymentManagerSpec ► save state when redeploying:
engine/flink/management/src/it/scala/pl/touk/nussknacker/engine/management/streaming/StreamingDockerTest.scala#L82
Failed test found in:
engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.FlinkStreamingDeploymentManagerSpec.xml
Error:
org.scalatest.exceptions.TestFailedException: The future returned an exception of type: java.lang.IllegalArgumentException, with message: State is incompatible, please stop scenario and start again with clean state.
|
pl.touk.nussknacker.engine.management.streaming.FlinkStreamingDeploymentManagerSpec ► redeploy scenario with greater parallelism than configured in mini cluster:
engine/flink/management/src/it/scala/pl/touk/nussknacker/engine/management/streaming/StreamingDockerTest.scala#L82
Failed test found in:
engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.FlinkStreamingDeploymentManagerSpec.xml
Error:
org.scalatest.exceptions.TestFailedException: The future returned an exception of type: java.lang.IllegalArgumentException, with message: State is incompatible, please stop scenario and start again with clean state.
|