This is your daily summary of Beam's current P1 issues, not including flaky tests.
See https://beam.apache.org/contribute/jira-priorities/#p1-critical for the meaning and expectations around P1 issues. BEAM-12205: Dataflow pipelines broken NoSuchMethodError DoFnInvoker.invokeSetup() (https://issues.apache.org/jira/browse/BEAM-12205) BEAM-12195: Flink Runner 1.11 uses old Scala-Version (https://issues.apache.org/jira/browse/BEAM-12195) BEAM-11959: Python Beam SDK Harness hangs when installing pip packages (https://issues.apache.org/jira/browse/BEAM-11959) BEAM-11906: No trigger early repeatedly for session windows (https://issues.apache.org/jira/browse/BEAM-11906) BEAM-11875: XmlIO.Read does not handle XML encoding per spec (https://issues.apache.org/jira/browse/BEAM-11875) BEAM-11828: JmsIO is not acknowledging messages correctly (https://issues.apache.org/jira/browse/BEAM-11828) BEAM-11755: Cross-language consistency (RequiresStableInputs) is quietly broken (at least on portable flink runner) (https://issues.apache.org/jira/browse/BEAM-11755) BEAM-11578: `dataflow_metrics` (python) fails with TypeError (when int overflowing?) (https://issues.apache.org/jira/browse/BEAM-11578) BEAM-11576: Go ValidatesRunner failure: TestFlattenDup on Dataflow Runner (https://issues.apache.org/jira/browse/BEAM-11576) BEAM-11434: Expose Spanner admin/batch clients in Spanner Accessor (https://issues.apache.org/jira/browse/BEAM-11434) BEAM-11227: Upgrade beam-vendor-grpc-1_26_0-0.3 to fix CVE-2020-27216 (https://issues.apache.org/jira/browse/BEAM-11227) BEAM-11148: Kafka commitOffsetsInFinalize OOM on Flink (https://issues.apache.org/jira/browse/BEAM-11148) BEAM-11017: Timer with dataflow runner can be set multiple times (dataflow runner) (https://issues.apache.org/jira/browse/BEAM-11017) BEAM-10861: Adds URNs and payloads to PubSub transforms (https://issues.apache.org/jira/browse/BEAM-10861) BEAM-10617: python CombineGlobally().with_fanout() cause duplicate combine results for sliding windows (https://issues.apache.org/jira/browse/BEAM-10617) BEAM-10573: CSV files are loaded several times if they are too large (https://issues.apache.org/jira/browse/BEAM-10573) BEAM-10569: SpannerIO tests don't actually assert anything. (https://issues.apache.org/jira/browse/BEAM-10569) BEAM-10288: Quickstart documents are out of date (https://issues.apache.org/jira/browse/BEAM-10288) BEAM-10244: Populate requirements cache fails on poetry-based packages (https://issues.apache.org/jira/browse/BEAM-10244) BEAM-10100: FileIO writeDynamic with AvroIO.sink not writing all data (https://issues.apache.org/jira/browse/BEAM-10100) BEAM-9564: Remove insecure ssl options from MongoDBIO (https://issues.apache.org/jira/browse/BEAM-9564) BEAM-9455: Environment-sensitive provisioning for Dataflow (https://issues.apache.org/jira/browse/BEAM-9455) BEAM-9293: Python direct runner doesn't emit empty pane when it should (https://issues.apache.org/jira/browse/BEAM-9293) BEAM-8986: SortValues may not work correct for numerical types (https://issues.apache.org/jira/browse/BEAM-8986) BEAM-8985: SortValues should fail if SecondaryKey coder is not deterministic (https://issues.apache.org/jira/browse/BEAM-8985) BEAM-8407: [SQL] Some Hive tests throw NullPointerException, but get marked as passing (Direct Runner) (https://issues.apache.org/jira/browse/BEAM-8407) BEAM-7717: PubsubIO watermark tracking hovers near start of epoch (https://issues.apache.org/jira/browse/BEAM-7717) BEAM-7716: PubsubIO returns empty message bodies for all messages read (https://issues.apache.org/jira/browse/BEAM-7716) BEAM-7195: BigQuery - 404 errors for 'table not found' when using dynamic destinations - sometimes, new table fails to get created (https://issues.apache.org/jira/browse/BEAM-7195) BEAM-6839: User reports protobuf ClassChangeError running against 2.6.0 or above (https://issues.apache.org/jira/browse/BEAM-6839) BEAM-6466: KafkaIO doesn't commit offsets while being used as bounded source (https://issues.apache.org/jira/browse/BEAM-6466)
