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

14 tests   14 ✅  12s ⏱️
 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

14 tests found

There are 14 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testReadFilesBinaryProtocol
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testReadWriteBinaryProtocol
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testReadWriteCompactProtocol
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testReadWriteJsonProtocol
org.apache.beam.sdk.io.thrift.ThriftIOTest ‑ testThriftCoder
org.apache.beam.sdk.io.thrift.ThriftPayloadSerializerProviderTest ‑ deserialize
org.apache.beam.sdk.io.thrift.ThriftPayloadSerializerProviderTest ‑ invalidArgs
org.apache.beam.sdk.io.thrift.ThriftPayloadSerializerProviderTest ‑ serialize
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testInnerStructSchemaWithSimpleTypedefs
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testMainStructSchemaWithContainerTypedefRegistered
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testMainStructSchemaWithoutTypedefRegistration
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testSchemaUsage
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testThriftSchemaOnlyAllowsThriftClasses
org.apache.beam.sdk.io.thrift.ThriftSchemaTest ‑ testUnionSchema