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-12060: beam_PostCommit_Go_VR_Flink and beam_PostCommit_Go_VR_Spark failing since Mar 23, 2021 6:00:00 AM (https://issues.apache.org/jira/browse/BEAM-12060) BEAM-12050: ParDoTest TimerTests that use TestStream failing for portable FlinkRunner (https://issues.apache.org/jira/browse/BEAM-12050) BEAM-11965: testSplitQueryFnWithLargeDataset timeout failures (https://issues.apache.org/jira/browse/BEAM-11965) BEAM-11961: InfluxDBIOIT failing with unauthorized error (https://issues.apache.org/jira/browse/BEAM-11961) BEAM-11959: Python Beam SDK Harness hangs when installing pip packages (https://issues.apache.org/jira/browse/BEAM-11959) BEAM-11922: org.apache.beam.examples.cookbook.MapClassIntegrationIT.testDataflowMapState has been failing in master (https://issues.apache.org/jira/browse/BEAM-11922) 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-11863: Java Quick Start is not working on MAC M1 (https://issues.apache.org/jira/browse/BEAM-11863) BEAM-11828: JmsIO is not acknowledging messages correctly (https://issues.apache.org/jira/browse/BEAM-11828) BEAM-11772: GCP BigQuery sink (file loads) uses runner determined sharding for unbounded data (https://issues.apache.org/jira/browse/BEAM-11772) 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-10883: XmlIO parsing of multibyte characters (https://issues.apache.org/jira/browse/BEAM-10883) BEAM-10861: Adds URNs and payloads to PubSub transforms (https://issues.apache.org/jira/browse/BEAM-10861) BEAM-10663: CrossLanguageKafkaIOTest broken on Flink Runner (https://issues.apache.org/jira/browse/BEAM-10663) 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-9917: BigQueryBatchFileLoads dynamic destination (https://issues.apache.org/jira/browse/BEAM-9917) 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-9154: Move Chicago Taxi Example to Python 3 (https://issues.apache.org/jira/browse/BEAM-9154) 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)
