Skip to content

[Bug]: FlinkRunner does not emit watermark with empty source #1801

[Bug]: FlinkRunner does not emit watermark with empty source

[Bug]: FlinkRunner does not emit watermark with empty source #1801

GitHub Actions / Test Results succeeded May 26, 2024 in 0s

All 112 tests pass in 3m 17s

112 tests   112 ✅  3m 17s ⏱️
 19 suites    0 💤
 19 files      0 ❌

Results for commit 836e77e.

Annotations

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

112 tests found

There are 112 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.aws.coders.AwsCodersTest ‑ testResponseMetadataDecodeEncodeEquals
org.apache.beam.sdk.io.aws.coders.AwsCodersTest ‑ testSdkHttpMetadataDecodeEncodeEquals
org.apache.beam.sdk.io.aws.coders.AwsCodersTest ‑ testSdkHttpMetadataWithoutHeadersDecodeEncodeEquals
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForBooleanType
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForByteArray
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForListOfString
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForListType
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForMapType
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForNullType
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForNumberType
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForOneListOfByteArray
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForOneListOfNumber
org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderTest ‑ shouldPassForStringType
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOIT ‑ testWriteThenRead
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOReadTest ‑ testReadInvalidTotalSegments
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOReadTest ‑ testReadMissingAwsClientsProvider
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOReadTest ‑ testReadMissingScanRequestFn
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOReadTest ‑ testReadMissingTotalSegments
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOReadTest ‑ testReadOneSegment
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOReadTest ‑ testReadThreeSegments
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOReadTest ‑ testReadWithCustomLimit
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOReadTest ‑ testReadWithStartKey
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOWriteTest ‑ testWriteDeleteItems
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOWriteTest ‑ testWriteDeleteItemsWithDuplicates
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOWriteTest ‑ testWritePutItems
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOWriteTest ‑ testWritePutItemsWithDuplicates
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOWriteTest ‑ testWritePutItemsWithDuplicatesByKey
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOWriteTest ‑ testWritePutItemsWithPartialSuccess
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOWriteTest ‑ testWritePutItemsWithRetryFailure
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIOWriteTest ‑ testWritePutItemsWithRetrySuccess
org.apache.beam.sdk.io.aws.options.AwsHttpClientConfigurationTest ‑ testAwsHttpClientConfigurationValues
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testAWSStaticCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testAwsHttpClientConfigurationSerializationDeserialization
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testAwsHttpClientConfigurationSerializationDeserializationProto
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testClasspathPropertiesFileCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testClientConfigurationSerializationDeserialization
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testObjectMapperIsAbleToFindModule
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testPropertiesFileCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testSSEAwsKeyManagementParamsSerializationDeserialization
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testSSECustomerKeySerializationDeserialization
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testSTSAssumeRoleSessionCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.aws.options.AwsModuleTest ‑ testSingletonAWSCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.aws.s3.S3FileSystemIT ‑ testWriteThenRead
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ deleteThousandsOfObjectsInMultipleBuckets
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ deleteThousandsOfObjectsInMultipleBucketsWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchGlob
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchGlobWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchGlobWithSlashes
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchGlobWithSlashesWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlob
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobForbidden
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobForbiddenWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobNotFound
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobNotFoundWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobNotReadSeekEfficient
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobNotReadSeekEfficientWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobNullContentEncoding
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobNullContentEncodingWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchNonGlobWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchVariousInvokeThreadPool
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ matchVariousInvokeThreadPoolWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testAtomicCopy
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testAtomicCopyWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testCopy
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testCopyWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testGetPathStyleAccessEnabled
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testGetPathStyleAccessEnabledWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testGetScheme
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testGetSchemeWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testMultipartCopy
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testMultipartCopyWithS3Options
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testWriteAndRead
org.apache.beam.sdk.io.aws.s3.S3FileSystemTest ‑ testWriteAndReadWithS3Options
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testBucketParsing
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testEquals
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testGetCurrentDirectory
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testGetFilename
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testGetScheme
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testInvalidBucket
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testInvalidPathNoBucket
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testInvalidPathNoBucketAndSlash
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testIsDirectory
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testParentRelationship
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testResolve
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testResolveInvalidInputs
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testResolveInvalidNotDirectory
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testResolveParentToFile
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testResourceIdTester
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testS3ResolveWithFileBase
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testS3ResourceIdToString
org.apache.beam.sdk.io.aws.s3.S3ResourceIdTest ‑ testSerialization
org.apache.beam.sdk.io.aws.s3.S3WritableByteChannelTest ‑ testAtMostOne
org.apache.beam.sdk.io.aws.s3.S3WritableByteChannelTest ‑ write
org.apache.beam.sdk.io.aws.s3.S3WritableByteChannelTest ‑ writeWithS3Options
org.apache.beam.sdk.io.aws.sns.PublishResultCodersTest ‑ testDefaultPublishResultDecodeEncodeEquals
org.apache.beam.sdk.io.aws.sns.PublishResultCodersTest ‑ testFullPublishResultIncludingHeadersDecodeEncodeEquals
org.apache.beam.sdk.io.aws.sns.PublishResultCodersTest ‑ testFullPublishResultWithoutHeadersDecodeEncodeEquals
org.apache.beam.sdk.io.aws.sns.SnsIOIT ‑ testWriteThenRead
org.apache.beam.sdk.io.aws.sns.SnsIOTest ‑ testCustomCoder
org.apache.beam.sdk.io.aws.sns.SnsIOTest ‑ testDataWritesToSNS
org.apache.beam.sdk.io.aws.sns.SnsIOTest ‑ testRetries
org.apache.beam.sdk.io.aws.sqs.SqsIOIT ‑ testWriteThenRead
org.apache.beam.sdk.io.aws.sqs.SqsIOTest ‑ testWrite
org.apache.beam.sdk.io.aws.sqs.SqsMessageCoderTest ‑ testConsistentWithEquals
org.apache.beam.sdk.io.aws.sqs.SqsMessageCoderTest ‑ testMessageDecodeEncodeEquals
org.apache.beam.sdk.io.aws.sqs.SqsMessageCoderTest ‑ testVerifyDeterministic
org.apache.beam.sdk.io.aws.sqs.SqsUnboundedReaderTest ‑ testCloseWithActiveCheckpoints
org.apache.beam.sdk.io.aws.sqs.SqsUnboundedReaderTest ‑ testMultipleReaders
org.apache.beam.sdk.io.aws.sqs.SqsUnboundedReaderTest ‑ testReadMany
org.apache.beam.sdk.io.aws.sqs.SqsUnboundedReaderTest ‑ testReadOneMessage
org.apache.beam.sdk.io.aws.sqs.SqsUnboundedReaderTest ‑ testTimeoutAckAndRereadOneMessage
org.apache.beam.sdk.io.aws.sqs.SqsUnboundedSourceTest ‑ testCheckpointCoderIsSane