PreCommit RAT

Refactor and cleanup yaml MapToFields. (#28462) #8262

Sign in to view logs

This check has been archived and is scheduled for deletion. Learn more about checks retention

GitHub Actions / Test Results succeeded Sep 21, 2023 in 0s

All 101 tests pass, 1 skipped in 20m 54s

  34 files   34 suites 20m 54s ⏱️
102 tests 101 ✔️   1 💤 0 ❌
503 runs 493 ✔️ 10 💤 0 ❌

Results for commit c5e6c79.

Annotations

Check notice on line 0 in .github

github-actions / Test Results

1 skipped test found

There is 1 skipped test, see "Raw output" for the name of the skipped test.

Raw output


            org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithoutBoundedWrapper

Check notice on line 0 in .github

github-actions / Test Results

102 tests found

There are 102 tests, see "Raw output" for the full list of tests.

Raw output


            org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProviderTest ‑ testDeserialize
org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProviderTest ‑ testGetCoder
org.apache.beam.sdk.io.kafka.CustomTimestampPolicyWithLimitedDelayTest ‑ testCustomTimestampPolicyWithLimitedDelay
org.apache.beam.sdk.io.kafka.KafkaCommitOffsetTest ‑ testCommitOffsetDoFn
org.apache.beam.sdk.io.kafka.KafkaCommitOffsetTest ‑ testCommitOffsetError
org.apache.beam.sdk.io.kafka.KafkaDlqTest ‑ testKafkaErrorFnFailure
org.apache.beam.sdk.io.kafka.KafkaDlqTest ‑ testKafkaErrorFnSuccess
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaRead
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaReadWithoutMetadata
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaWrite
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testKafkaRecordToExternalKafkaRecord
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testKafkaRecordToExternalKafkaRecordWithNullKeyAndValue
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaIOExternalRoundtripWithMetadataAndNullKeysAndValues
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaIOReadsAndWritesCorrectlyInBatch
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaViaSchemaTransformAvro
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaViaSchemaTransformJson
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testKafkaIOReadPropertiesEnumValuePresence
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testPrimitiveKafkaIOReadPropertiesDefaultValueExistence
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithBothImplementationBoundProperties
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithLegacyImplementationBoundProperty
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithSdfImplementationBoundProperty
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testDeserializationWithHeaders
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testExactlyOnceSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testExactlyOnceSinkWithSendException
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testKafkaWriteHeaders
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testReadAvroGenericRecordsWithConfluentSchemaRegistry
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testReadAvroSpecificRecordsWithConfluentSchemaRegistry
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testRecordsSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testResolveDefaultApiTimeout
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testRiskyConfigurationWarnsProperly
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkMetrics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkProducerRecordsWithCustomPartition
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkProducerRecordsWithCustomTS
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkToMultipleTopics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkWithSendErrors
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceWithExplicitPartitionsDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceWithPatternDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedReaderLogsCommitFailure
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSource
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCheckpointMark
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCheckpointMarkWithEmptyPartitions
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCreateTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCustomTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceLogAppendTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceMetrics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceSplits
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceStartReadTime
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceStartReadTimeException
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithExceptionInKafkaFetch
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithExplicitPartitions
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithPartiallyMatchedPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithSingleTopic
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithUnmatchedPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithWrongTopic
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithoutBoundedWrapper
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnreachableKafkaBrokers
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testValuesSink
org.apache.beam.sdk.io.kafka.KafkaIOUtilsTest ‑ testOffsetConsumerConfigOverrides
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithAvroSchema
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithJsonSchema
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testFindTransformAndMakeItWork
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testValidConfigurations
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testCoderIsSerializableWithWellKnownCoderType
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testKafkaRecordSerializableWithHeaders
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testKafkaRecordSerializableWithoutHeaders
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testKafkaErrorFnSuccess
org.apache.beam.sdk.io.kafka.LocalDeserializerProviderTest ‑ testInferKeyCoder
org.apache.beam.sdk.io.kafka.LocalDeserializerProviderTest ‑ testInferKeyCoderFailure
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testCoderIsSerializableWithWellKnownCoderType
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithHeaders
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithPartition
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithTimestamp
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutHeaders
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutPartition
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutTimestamp
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordStructuralValueWithHeadersApi
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordStructuralValueWithoutHeadersApi
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testBounded
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStartOffset
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStartTime
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStopOffset
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStopTime
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWithConsumerPosition
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWithException
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElement
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWhenTopicPartitionIsRemoved
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWhenTopicPartitionIsStopped
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithEmptyPoll
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithException
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testUnbounded
org.apache.beam.sdk.io.kafka.TopicPartitionCoderTest ‑ testEncodeDecodeRoundTrip
org.apache.beam.sdk.io.kafka.TopicPartitionCoderTest ‑ testToString
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitions
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitionsWithGivenPattern
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitionsWithGivenTopics
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testPartitionGrowth
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testPartitionSingle

View more details on GitHub Actions