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 50 tests pass in 1m 17s

50 tests   50 ✅  1m 17s ⏱️
10 suites   0 💤
10 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

50 tests found

There are 50 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.iceberg.IcebergIOIT ‑ testRead
org.apache.beam.sdk.io.iceberg.IcebergIOIT ‑ testWrite
org.apache.beam.sdk.io.iceberg.IcebergIOReadTest ‑ testSimpleScan
org.apache.beam.sdk.io.iceberg.IcebergIOWriteTest ‑ testDynamicDestinationsWithSpillover
org.apache.beam.sdk.io.iceberg.IcebergIOWriteTest ‑ testDynamicDestinationsWithoutSpillover
org.apache.beam.sdk.io.iceberg.IcebergIOWriteTest ‑ testIdempotentCommit
org.apache.beam.sdk.io.iceberg.IcebergIOWriteTest ‑ testSimpleAppend
org.apache.beam.sdk.io.iceberg.IcebergReadSchemaTransformProviderTest ‑ testBuildTransformWithRow
org.apache.beam.sdk.io.iceberg.IcebergReadSchemaTransformProviderTest ‑ testReadUsingManagedTransform
org.apache.beam.sdk.io.iceberg.IcebergReadSchemaTransformProviderTest ‑ testSimpleScan
org.apache.beam.sdk.io.iceberg.IcebergSchemaTransformTranslationTest ‑ testReCreateReadTransformFromRow
org.apache.beam.sdk.io.iceberg.IcebergSchemaTransformTranslationTest ‑ testReCreateWriteTransformFromRow
org.apache.beam.sdk.io.iceberg.IcebergSchemaTransformTranslationTest ‑ testReadTransformProtoTranslation
org.apache.beam.sdk.io.iceberg.IcebergSchemaTransformTranslationTest ‑ testWriteTransformProtoTranslation
org.apache.beam.sdk.io.iceberg.IcebergWriteSchemaTransformProviderTest ‑ testBuildTransformWithRow
org.apache.beam.sdk.io.iceberg.IcebergWriteSchemaTransformProviderTest ‑ testSimpleAppend
org.apache.beam.sdk.io.iceberg.IcebergWriteSchemaTransformProviderTest ‑ testWriteUsingManagedTransform
org.apache.beam.sdk.io.iceberg.ScanSourceTest ‑ testDoubleInitialSplitting
org.apache.beam.sdk.io.iceberg.ScanSourceTest ‑ testInitialSplitting
org.apache.beam.sdk.io.iceberg.ScanSourceTest ‑ testUnstartedReaderReadsSamesItsSource
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testBinary
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testBoolean
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testDate
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testDecimal
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testDouble
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testFixed
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testFloat
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testInteger
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testList
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testLong
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testMap
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testStruct
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testTime
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RecordToRowTests ‑ testTimestamp
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testBinary
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testBoolean
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testDate
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testDecimal
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testDouble
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testFixed
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testFloat
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testInteger
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testList
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testLong
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testMap
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testStruct
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testTime
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$RowToRecordTests ‑ testTimestamp
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$SchemaTests ‑ testBeamSchemaToIcebergSchema
org.apache.beam.sdk.io.iceberg.SchemaAndRowConversionsTest$SchemaTests ‑ testIcebergSchemaToBeamSchema