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 97 tests pass in 12s

97 tests   97 ✅  12s ⏱️
11 suites   0 💤
11 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

97 tests found

There are 97 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testDataSourceCreatedFromServerName
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testDataSourceCreatedFromServerNameAndPort
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testDataSourceCreatedFromUrl
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperPathToEncryptedKeyAndInvalidPassphrase
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperPathToEncryptedKeyAndNoPassphrase
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperPathToKey
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperPathToKeyAndInvalidKey
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperPathToKeyAndMissingUsername
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperPathToUnencryptedKeyAndPassphrase
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperRawEncryptedKeyWithoutHeaders
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperRawKey
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperRawKeyAndMissingUsername
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperRawUnencryptedKey
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithProperRawUnencryptedKeyWithoutHeaders
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithWrongKey
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingKeyPairAuthWithWrongPathToKey
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingNonAuth
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingOAuth
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingServerNameWithBadSuffix
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringAuthenticator
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringDatabase
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringLoginTimeout
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringPortNumber
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringRole
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringSchema
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringServerName
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringUrl
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingStringWarehouse
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingUrlWithBadPrefix
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingUrlWithBadSuffix
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingUsernamePasswordAuth
org.apache.beam.sdk.io.snowflake.test.unit.DataSourceConfigurationTest ‑ testSettingUsernamePasswordAuthWithMissingUsername
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeColumnTest ‑ testNullColumn
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeColumnTest ‑ testVarcharColumn
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeExceptionTest ‑ testBinaryReachesLimit
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeExceptionTest ‑ testVarcharReachesLimit
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[0]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[10]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[11]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[12]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[13]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[14]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[15]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[16]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[17]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[18]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[19]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[1]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[20]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[21]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[22]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[23]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[24]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[25]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[26]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[2]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[3]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[4]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[5]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[6]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[7]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[8]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeDataTypeValidTest ‑ testSnowflakeDataType[9]
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeTableSchemaTest ‑ testOneColumn
org.apache.beam.sdk.io.snowflake.test.unit.data.SnowflakeTableSchemaTest ‑ testTwoColumns
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testConfigContainsFromQueryAndFromTable
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testConfigIsMissingCoder
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testConfigIsMissingCsvMapper
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testConfigIsMissingDataSourceConfiguration
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testConfigIsMissingFromTableOrFromQuery
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testConfigIsMissingStagingBucketName
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testConfigIsMissingStorageIntegration
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testInvalidQuery
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testReadFromQuery
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testReadFromTable
org.apache.beam.sdk.io.snowflake.test.unit.read.SnowflakeIOReadTest ‑ testTableDoesntExist
org.apache.beam.sdk.io.snowflake.test.unit.write.CreateDispositionTest ‑ writeWithWriteCreateDispositionWithAlreadyCreatedTableSuccess
org.apache.beam.sdk.io.snowflake.test.unit.write.CreateDispositionTest ‑ writeWithWriteCreateDispositionWithCreateNeededFails
org.apache.beam.sdk.io.snowflake.test.unit.write.CreateDispositionTest ‑ writeWithWriteCreateDispositionWithCreateNeverSuccess
org.apache.beam.sdk.io.snowflake.test.unit.write.CreateDispositionTest ‑ writeWithWriteCreateDispositionWithCreatedTableWithSchemaSuccess
org.apache.beam.sdk.io.snowflake.test.unit.write.CreateDispositionTest ‑ writeWithWriteCreateDispositionWithCreatedTableWithoutSchemaFails
org.apache.beam.sdk.io.snowflake.test.unit.write.QueryDispositionLocationTest ‑ writeWithWriteEmptyDispositionWithEmptyTableSuccess
org.apache.beam.sdk.io.snowflake.test.unit.write.QueryDispositionLocationTest ‑ writeWithWriteEmptyDispositionWithNotEmptyTableFails
org.apache.beam.sdk.io.snowflake.test.unit.write.QueryDispositionLocationTest ‑ writeWithWriteTruncateDispositionSuccess
org.apache.beam.sdk.io.snowflake.test.unit.write.SchemaDispositionTest ‑ writeWithCreatedTableWithDatetimeSchemaSuccess
org.apache.beam.sdk.io.snowflake.test.unit.write.SchemaDispositionTest ‑ writeWithCreatedTableWithNullValuesInSchemaSuccess
org.apache.beam.sdk.io.snowflake.test.unit.write.SchemaDispositionTest ‑ writeWithCreatedTableWithStructuredDataSchemaSuccess
org.apache.beam.sdk.io.snowflake.test.unit.write.SnowflakeIOWriteTest ‑ writeToExternalWithBlankQuotation
org.apache.beam.sdk.io.snowflake.test.unit.write.SnowflakeIOWriteTest ‑ writeToExternalWithDoubleQuotation
org.apache.beam.sdk.io.snowflake.test.unit.write.SnowflakeIOWriteTest ‑ writeWithIntegrationTest
org.apache.beam.sdk.io.snowflake.test.unit.write.SnowflakeIOWriteTest ‑ writeWithKVInputTest
org.apache.beam.sdk.io.snowflake.test.unit.write.SnowflakeIOWriteTest ‑ writeWithMapperTest
org.apache.beam.sdk.io.snowflake.test.unit.write.SnowflakeIOWriteTest ‑ writeWithTransformationTest
org.apache.beam.sdk.io.snowflake.test.unit.write.StreamingWriteTest ‑ streamWriteWithDoubleQuotation
org.apache.beam.sdk.io.snowflake.test.unit.write.StreamingWriteTest ‑ streamWriteWithKey
org.apache.beam.sdk.io.snowflake.test.unit.write.StreamingWriteTest ‑ streamWriteWithOAuthFails
org.apache.beam.sdk.io.snowflake.test.unit.write.StreamingWriteTest ‑ streamWriteWithUserPasswordFails