Skip to content
Pull Request Labeler

Kafka Admin Client: creating once instead of many times #16069

Sign in to view logs

Kafka Admin Client: creating once instead of many times

Kafka Admin Client: creating once instead of many times #16069

Triggered via pull request January 13, 2025 15:26
@arkadiusarkadius
synchronize #7433
Status Success
Total duration 12s
Artifacts –

labeler.yml

on: pull_request_target
triage
3s
triage
Fit to window
Zoom out
Zoom in

Annotations

14 errors and 1 warning
Fragment ► should allow adding input parameters and display used fragment graph in modal ► Fragment should allow adding input parameters and display used fragment graph in modal: 17d602f5f8e1530cd465910c506123cb.xml#L0
Failed test found in: 17d602f5f8e1530cd465910c506123cb.xml Error: AssertionError: Timed out retrying after 30000ms: expected '<input.node-input.css-0>' to have value 'name_value_string_any_value', but the value was 'name'
pl.touk.nussknacker.engine.schemedkafka.source.flink.TestWithTestDataSpec ► Should pass correct timestamp from test data: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in: engine/flink/schemed-kafka-components-utils/target/test-reports/TEST-pl.touk.nussknacker.engine.schemedkafka.source.flink.TestWithTestDataSpec.xml Error: java.lang.IllegalArgumentException: Compilation errors: ExpressionParserCompilationError(Unresolved reference 'inputMeta',end,Some(ParameterName(Value)),#inputMeta,None), CannotCreateObjectError(Failed to create new KafkaAdminClient,start)
pl.touk.nussknacker.engine.schemedkafka.source.flink.TestWithTestDataSpec ► Should pass parameters correctly and use them in scenario test: engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/compiler/FlinkProcessCompilerData.scala#L55
Failed test found in: engine/flink/schemed-kafka-components-utils/target/test-reports/TEST-pl.touk.nussknacker.engine.schemedkafka.source.flink.TestWithTestDataSpec.xml Error: java.lang.IllegalArgumentException: Compilation errors: ExpressionParserCompilationError(Property access on Unknown is not allowed,end,Some(ParameterName(Value)),#input.name + '-' + #input.address.city + '-' + #input.address.street,None), CannotCreateObjectError(Failed to create new KafkaAdminClient,start)
pl.touk.nussknacker.engine.lite.components.KafkaJsonRefFunctionalSpec ► filled record after empty record with schema using refs: utils/test-utils/src/main/scala/pl/touk/nussknacker/test/ValidatedValuesDetailedMessage.scala#L25
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.KafkaJsonRefFunctionalSpec.xml Error: org.scalatest.exceptions.TestFailedException: The Validated on which validValue was invoked was defined as Invalid(NonEmptyList(CannotCreateObjectError(Failed to create new KafkaAdminClient,sink), CannotCreateObjectError(Failed to create new KafkaAdminClient,source)))
pl.touk.nussknacker.engine.lite.components.KafkaJsonRefFunctionalSpec ► filled record after empty record with schema with inlined refs: utils/test-utils/src/main/scala/pl/touk/nussknacker/test/ValidatedValuesDetailedMessage.scala#L25
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.KafkaJsonRefFunctionalSpec.xml Error: org.scalatest.exceptions.TestFailedException: The Validated on which validValue was invoked was defined as Invalid(NonEmptyList(CannotCreateObjectError(Failed to create new KafkaAdminClient,sink), CannotCreateObjectError(Failed to create new KafkaAdminClient,source)))
pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest ► simple 1:1 #input as sink output: engine/lite/components/kafka-tests/src/test/scala/pl/touk/nussknacker/engine/lite/components/LiteKafkaUniversalAvroSchemaFunctionalTest.scala#L33
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest.xml Error: org.scalatest.exceptions.GeneratorDrivenPropertyCheckFailedException: TestFailedException was thrown during property evaluation.
pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest ► simple 1:1 SpEL as sink output: engine/lite/components/kafka-tests/src/test/scala/pl/touk/nussknacker/engine/lite/components/LiteKafkaUniversalAvroSchemaFunctionalTest.scala#L33
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest.xml Error: org.scalatest.exceptions.GeneratorDrivenPropertyCheckFailedException: TestFailedException was thrown during property evaluation.
pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest ► should test end to end kafka avro record data at sink / source with primitive integers: engine/lite/components/kafka-tests/src/test/scala/pl/touk/nussknacker/engine/lite/components/LiteKafkaUniversalAvroSchemaFunctionalTest.scala#L33
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest.xml Error: org.scalatest.exceptions.TableDrivenPropertyCheckFailedException: TestFailedException was thrown during property evaluation. (LiteKafkaUniversalAvroSchemaFunctionalTest.scala:1097)
pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest ► should test end to end kafka avro record data at sink with Unknown type: engine/lite/components/kafka-tests/src/test/scala/pl/touk/nussknacker/engine/lite/components/LiteKafkaUniversalAvroSchemaFunctionalTest.scala#L33
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest.xml Error: org.scalatest.exceptions.TableDrivenPropertyCheckFailedException: TestFailedException was thrown during property evaluation. (LiteKafkaUniversalAvroSchemaFunctionalTest.scala:1097)
pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest ► should test end to end kafka avro record data at sink / source with primitive longs: engine/lite/components/kafka-tests/src/test/scala/pl/touk/nussknacker/engine/lite/components/LiteKafkaUniversalAvroSchemaFunctionalTest.scala#L33
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest.xml Error: org.scalatest.exceptions.TableDrivenPropertyCheckFailedException: TestFailedException was thrown during property evaluation. (LiteKafkaUniversalAvroSchemaFunctionalTest.scala:1097)
pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest ► should test end to end kafka avro record data at sink / source with primitive float: engine/lite/components/kafka-tests/src/test/scala/pl/touk/nussknacker/engine/lite/components/LiteKafkaUniversalAvroSchemaFunctionalTest.scala#L33
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest.xml Error: org.scalatest.exceptions.TableDrivenPropertyCheckFailedException: TestFailedException was thrown during property evaluation. (LiteKafkaUniversalAvroSchemaFunctionalTest.scala:1097)
pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest ► should test end to end kafka avro record data at sink / source with primitive double: engine/lite/components/kafka-tests/src/test/scala/pl/touk/nussknacker/engine/lite/components/LiteKafkaUniversalAvroSchemaFunctionalTest.scala#L33
Failed test found in: engine/lite/components/kafka-tests/target/test-reports/TEST-pl.touk.nussknacker.engine.lite.components.LiteKafkaUniversalAvroSchemaFunctionalTest.xml Error: org.scalatest.exceptions.TableDrivenPropertyCheckFailedException: TestFailedException was thrown during property evaluation. (LiteKafkaUniversalAvroSchemaFunctionalTest.scala:1097)
pl.touk.nussknacker.engine.schemedkafka.schemaregistry.azure.AzureSchemaBasedSerdeProviderIntegrationTest ► serialization round-trip: utils/kafka-utils/src/main/scala/pl/touk/nussknacker/engine/kafka/KafkaUtils.scala#L36
Failed test found in: utils/schemed-kafka-components-utils/target/test-reports/TEST-pl.touk.nussknacker.engine.schemedkafka.schemaregistry.azure.AzureSchemaBasedSerdeProviderIntegrationTest.xml Error: org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
pl.touk.nussknacker.engine.schemedkafka.schemaregistry.azure.AzureTestsFromFileIntegrationTest ► test from file round-trip: utils/kafka-utils/src/main/scala/pl/touk/nussknacker/engine/kafka/KafkaUtils.scala#L36
Failed test found in: utils/schemed-kafka-components-utils/target/test-reports/TEST-pl.touk.nussknacker.engine.schemedkafka.schemaregistry.azure.AzureTestsFromFileIntegrationTest.xml Error: org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
triage
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636