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 38 tests pass in 6s

38 tests   38 ✅  6s ⏱️
 4 suites   0 💤
 4 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

38 tests found

There are 38 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.csv.CsvIOWriteDisplayDataTest ‑ csvFormatNotPredefined
org.apache.beam.sdk.io.csv.CsvIOWriteDisplayDataTest ‑ defaultPredefinedCsvFormat
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ headersWithCommentsWrittenFirstOnEachShard
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ headersWrittenFirstOnEachShard
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ nonNullCSVFormatHeaderWritesSelectedSchemaFields
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ nonNullHeaderCommentsRequiresHeaderMarker
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ nullCSVFormatHeaderWritesAllSchemaFields
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ withSkipHeaderRecordOnlyWritesRows
org.apache.beam.sdk.io.csv.CsvIOWriteTest ‑ writesUserDefinedTypes
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ invalidCSVFormatHeader
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ invalidSchema
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withAllowDuplicateHeaderNamesDuplicatesRowFieldOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withAllowMissingColumnNamesSettingThrowsException
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withAutoFlushThrowsException
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withCommentMarkerDoesNotEffectConversion
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withDelimiterDrivesCellBorders
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withEscapeDrivesOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withHeaderCommentsDoesNotEffectConversion
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withHeaderDrivesFieldOrderSubsetOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withIgnoreEmptyLinesDoesNotEffectOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withIgnoreHeaderCaseThrowsException
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withIgnoreSurroundingSpacesThrowsException
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withNullStringReplacesNullValues
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withQuoteDrivesConversion
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withQuoteModeDrivesCellBoundaries
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withSystemRecordSeparatorDoesNotEffectOutput
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withTrailingDelimiterAppendsToLineEnd
org.apache.beam.sdk.io.csv.RowToCsvCSVFormatTest ‑ withTrimRemovesCellPadding
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ defaultFormat
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ excel
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ informixUnload
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ informixUnloadCsv
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ mySql
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ oracle
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ postgresqlCSV
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ postgresqlText
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ rfc4180
org.apache.beam.sdk.io.csv.RowToCsvPredefinedCSVFormatsTest ‑ tdf