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-12056: [2.29.0 cherrypick] DataframeTransfom, BatchRowsAsDataFrame do not preserve field order when schema created with beam.Row (https://issues.apache.org/jira/browse/BEAM-12056) BEAM-12050: ParDoTest TimerTests that use TestStream failing for portable FlinkRunner (https://issues.apache.org/jira/browse/BEAM-12050) BEAM-12000: Support Python 3.9 in Apache Beam (https://issues.apache.org/jira/browse/BEAM-12000) 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-11886: MapState and SetState failing tests on Dataflow streaming (https://issues.apache.org/jira/browse/BEAM-11886) 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-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-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-7064: Conversion of timestamp from BigQuery row to Beam row loses precision (https://issues.apache.org/jira/browse/BEAM-7064) 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) BEAM-5997: EVENT_TIME timer throws exception when side input used (https://issues.apache.org/jira/browse/BEAM-5997) BEAM-5305: Timeout handling in JdbcIO with Oracle java driver (https://issues.apache.org/jira/browse/BEAM-5305)
