Skip to content

Commit

Permalink
Fix Flink process runner test
Browse files Browse the repository at this point in the history
  • Loading branch information
Elmacioro committed Jan 27, 2025
1 parent 263da5c commit 36119cd
Showing 1 changed file with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -764,13 +764,15 @@ class FlinkProcessTestRunnerSpec
)
.emptySink("out", "valueMonitor", "Value" -> "#input.value1".spel)

val dictEditorException = intercept[IllegalStateException] {
val dictEditorException = intercept[IllegalArgumentException] {
prepareTestRunner(useIOMonadInInterpreter).runTests(
process,
ScenarioTestData(List(createTestRecord(id = "2", value1 = 2)))
)
}
dictEditorException.getMessage shouldBe "DictKeyWithLabel expression can only be used with DictParameterEditor, got Some(DualParameterEditor(StringParameterEditor,RAW))"
dictEditorException.getMessage.startsWith(
"Compilation errors: IncompatibleParameterDefinitionModification(ParameterName(static),dictKeyWithLabel,Some(DualParameterEditor(StringParameterEditor,RAW))"
) shouldBe true
}

"should run correctly when parameter was modified by AdditionalUiConfigProvider with dict editor and flink was provided with additional config" in {
Expand Down

0 comments on commit 36119cd

Please sign in to comment.