[NU-1934] Ability to create json kafka source without schema registry #16231
paw787878Annotations
10 errors and 1 warning
|
pl.touk.nussknacker.defaultmodel.FinkExactlyOnceItSpec ► should read message from kafka and write message in transaction to kafka on checkpoint:
engine/flink/tests/src/test/scala/pl/touk/nussknacker/defaultmodel/FinkExactlyOnceItSpec.scala#L49
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.FinkExactlyOnceItSpec.xml
Error:
org.scalatest.exceptions.TestFailedException: null did not equal {
|
|
pl.touk.nussknacker.defaultmodel.FlinkDisabledNamespacedKafkaTest ► should send message to topic without appended namespace when namespace is disabled for used kafka topic:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.FlinkDisabledNamespacedKafkaTest.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: InvalidPropertyFixedValue(ParameterName(Topic),None,'output',List(, 'input'),output)
|
|
pl.touk.nussknacker.defaultmodel.FlinkNamespacedKafkaTest ► should send message to topic with appended namespace:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.FlinkNamespacedKafkaTest.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: InvalidPropertyFixedValue(ParameterName(Topic),None,'output',List(, 'input'),output)
|
|
pl.touk.nussknacker.defaultmodel.KafkaAvroItSpec ► should read avro object from kafka, filter and save it to kafka, passing timestamp:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.KafkaAvroItSpec.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: ExpressionParserCompilationError(Property access on Unknown is not allowed,name-filter,Some(ParameterName($expression)),#input.first == 'Jan',None), InvalidPropertyFixedValue(ParameterName(Topic),None,'test.generic.avro.output.read-filter-save-avro',List(, 'test.generic.avro.input.read-filter-save-avro'),end)
|
|
pl.touk.nussknacker.defaultmodel.KafkaAvroItSpec ► should read avro object from kafka and save new one created from scratch:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.KafkaAvroItSpec.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: InvalidPropertyFixedValue(ParameterName(Topic),None,'test.generic.avro.output.read-save-scratch',List(, 'test.generic.avro.input.read-filter-save-avro', 'test.generic.avro.input.read-save-scratch'),end), InvalidPropertyFixedValue(ParameterName(Schema version),None,'1',List('latest'),end), ExpressionParserCompilationError(Property access on Unknown is not allowed,end,Some(ParameterName(Value)),{first: #input.first, last: #input.last},None)
|
|
pl.touk.nussknacker.defaultmodel.KafkaAvroItSpec ► should read avro object in v1 from kafka and deserialize it to v2, filter and save it to kafka in v2:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.KafkaAvroItSpec.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: ExpressionParserCompilationError(Property access on Unknown is not allowed,name-filter,Some(ParameterName($expression)),#input.first == 'Jan',None), InvalidPropertyFixedValue(ParameterName(Topic),None,'test.generic.avro.output.v1.v2.v2',List(, 'test.generic.avro.input.read-filter-save-avro', 'test.generic.avro.input.read-save-scratch', 'test.generic.avro.input.v1.v2.v2'),end)
|
|
pl.touk.nussknacker.defaultmodel.KafkaAvroItSpec ► should read avro object in v2 from kafka and deserialize it to v1, filter and save it to kafka in v2:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.KafkaAvroItSpec.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: ExpressionParserCompilationError(Property access on Unknown is not allowed,name-filter,Some(ParameterName($expression)),#input.first == 'Jan',None), InvalidPropertyFixedValue(ParameterName(Topic),None,'test.generic.avro.output.v2.v1.v1',List(, 'test.generic.avro.input.read-filter-save-avro', 'test.generic.avro.input.read-save-scratch', 'test.generic.avro.input.v1.v2.v2', 'test.generic.avro.input.v2.v1.v1'),end)
|
|
pl.touk.nussknacker.defaultmodel.KafkaAvroSchemaJsonPayloadItSpec ► should read schemed json from kafka, filter and save it to kafka, passing timestamp:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.KafkaAvroSchemaJsonPayloadItSpec.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: ExpressionParserCompilationError(Property access on Unknown is not allowed,name-filter,Some(ParameterName($expression)),#input.first == 'Jan',None), InvalidPropertyFixedValue(ParameterName(Topic),None,'test.generic.avro.output.read-filter-save-json',List(, 'test.generic.avro.input.read-filter-save-json'),end)
|
|
pl.touk.nussknacker.defaultmodel.StateCompatibilityTest ► should restore from snapshot:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.defaultmodel.StateCompatibilityTest.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: InvalidPropertyFixedValue(ParameterName(Topic),None,'test.generic.avro.output.state.compatibility.output',List(),sink), InvalidPropertyFixedValue(ParameterName(Topic),None,'test.generic.avro.input.state.compatibility.input',List(),start), InvalidPropertyFixedValue(ParameterName(Schema version),None,'1',List('latest'),start)
|
|
pl.touk.nussknacker.devmodel.TableKafkaPingPongTest ► should ping-pong with sql kafka source and DataStream kafka sink:
engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in:
engine/flink/tests/target/test-reports/TEST-pl.touk.nussknacker.devmodel.TableKafkaPingPongTest.xml
Error:
java.lang.IllegalArgumentException: Compilation errors: InvalidPropertyFixedValue(ParameterName(Topic),None,'test.generic.avro.output.table-ping-pong.test1',List(, 'test.generic.avro.input.table-ping-pong.test1'),output)
|
|
triage
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
|