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 18 tests pass in 1m 21s

18 tests   18 ✅  1m 21s ⏱️
 3 suites   0 💤
 3 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

18 tests found

There are 18 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testDoesntHaveDB
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testDoesntHaveTable
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testGetTableSchema
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testGetTableSchemaForPartitionedTable
org.apache.beam.sdk.io.hcatalog.HCatalogBeamSchemaTest ‑ testHasDB
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadFailureTableDoesNotExist
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadFailureValidationConfig
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadFailureValidationTable
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadFromSource
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testReadTransformCanBeSerializedMultipleTimes
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testSourceCanBeSerializedMultipleTimes
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testSourceEqualsSplits
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteFailureTableDoesNotExist
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteFailureValidationConfigProp
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteFailureValidationTable
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteThenReadSuccess
org.apache.beam.sdk.io.hcatalog.HCatalogIOTest ‑ testWriteThenUnboundedReadSuccess
org.apache.beam.sdk.io.hcatalog.SchemaUtilsTest ‑ testParameterizedTypesToBeamTypes