Skip to content

[NU-1962] Flink scenario testing mechanism: mini cluster created once and reused each time #16164

[NU-1962] Flink scenario testing mechanism: mini cluster created once and reused each time

[NU-1962] Flink scenario testing mechanism: mini cluster created once and reused each time #16164

Triggered via pull request January 17, 2025 10:37
@arkadiusarkadius
synchronize #7458
Status Success
Total duration 9s
Artifacts

labeler.yml

on: pull_request_target
Fit to window
Zoom out
Zoom in

Annotations

11 errors and 1 warning
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should be able to return test results: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should collect results for split: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should return correct result for custom node: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should handle large parallelism: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should detect errors: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should ignore real exception handler: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should handle json input: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should handle custom variables in source: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should give meaningful error messages for sink errors: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should be able to test process with time windows: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec ► A scenario run on Flink engine when IO monad interpreter is used should be able to test typed map: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala#L60
Failed test found in: engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml engine/flink/executor/target/test-reports/TEST-pl.touk.nussknacker.engine.process.runner.FlinkTestMainSpec.xml Error: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
triage
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636