Skip to content

Commit

Permalink
removed SimpleProcessConfigCreator to allow run tests from IDE
Browse files Browse the repository at this point in the history
  • Loading branch information
arkadius committed Jan 21, 2025
1 parent 09a5efb commit 6325dc4
Show file tree
Hide file tree
Showing 4 changed files with 3 additions and 64 deletions.
5 changes: 3 additions & 2 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -631,7 +631,8 @@ lazy val flinkDeploymentManager = (project in flink("management"))
componentsApi % Provided,
httpUtils % Provided,
flinkScalaUtils % Provided,
flinkExecutor % Test,
// test->test dependency is needed to load SimpleProcessConfigCreator
flinkExecutor % "test,test->test",
flinkTestUtils % "it,test",
kafkaTestUtils % "it,test"
)
Expand Down Expand Up @@ -721,7 +722,7 @@ lazy val flinkTests = (project in flink("tests"))
kafkaTestUtils % Test,
flinkComponentsTestkit % Test,
flinkDeploymentManager % Test,
// TODO: cleanup kafka testsmechanism tests in order to remove test->test dependency
// test->test dependencies are needed to load components from these modules
flinkKafkaComponentsUtils % "test->test",
flinkSchemedKafkaComponentsUtils % "test->test",
// for local development
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -429,8 +429,6 @@ class FlinkProcessTestRunnerSpec
results.exceptions should have length 1
results.exceptions.head.nodeId shouldBe Some("out")
results.exceptions.head.throwable.getMessage should include("message: / by zero")

SimpleProcessConfigCreator.sinkForIntsResultsHolder.results should have length 0
}

"be able to test process with time windows" in {
Expand Down

This file was deleted.

0 comments on commit 6325dc4

Please sign in to comment.