P1 issues report (51)

[Beam Jira Bot <ji...@apache.org>]

This is your daily summary of Beam's current P1 issues, not including flaky tests (https://issues.apache.org/jira/issues/?jql=project%20%3D%20BEAM%20AND%20statusCategory%20!%3D%20Done%20AND%20priority%20%3D%20P1%20AND%20(labels%20is%20EMPTY%20OR%20labels%20!%3D%20flake).

See https://beam.apache.org/contribute/jira-priorities/#p1-critical for the meaning and expectations around P1 issues.

    https://issues.apache.org/jira/browse/BEAM-12843: (Broken Pipe induced) Bricked Dataflow Pipeline  (created 2021-09-06)
    https://issues.apache.org/jira/browse/BEAM-12842: StreamingDataflowWorkerTest.testHotKeyLogging tests are flaky (created 2021-09-03)
    https://issues.apache.org/jira/browse/BEAM-12809: testTwoTimersSettingEachOtherWithCreateAsInputBounded flaky (created 2021-08-26)
    https://issues.apache.org/jira/browse/BEAM-12805: Multiple XVR suites failing due to Java test ValidateRunnerXlangTest.combinePerKeyTest (created 2021-08-26)
    https://issues.apache.org/jira/browse/BEAM-12796: Executing a BQ pipeline without the new BQ read API library results in a TypeError (created 2021-08-24)
    https://issues.apache.org/jira/browse/BEAM-12794: PortableRunnerTestWithExternalEnv.test_pardo_timers flaky (created 2021-08-24)
    https://issues.apache.org/jira/browse/BEAM-12792: Beam worker only installs --extra_package once (created 2021-08-24)
    https://issues.apache.org/jira/browse/BEAM-12781: SDFBoundedSourceReader behaves much slower compared with the original behavior of BoundedSource (created 2021-08-20)
    https://issues.apache.org/jira/browse/BEAM-12766: Already Exists: Dataset apache-beam-testing:python_bq_file_loads_NNN (created 2021-08-16)
    https://issues.apache.org/jira/browse/BEAM-12712: Java Portable VR PostCommits failing - ParDoTest TimerTests.testEventTimeTimerLoop (created 2021-08-02)
    https://issues.apache.org/jira/browse/BEAM-12678: beam_PreCommit_GoPortable_Phrase failing to start the local job server (created 2021-07-29)
    https://issues.apache.org/jira/browse/BEAM-12632: ElasticsearchIO: Enabling both User/Pass auth and SSL overwrites User/Pass (created 2021-07-16)
    https://issues.apache.org/jira/browse/BEAM-12607: Copy Code Snippet copies html tags (created 2021-07-13)
    https://issues.apache.org/jira/browse/BEAM-12603: Flaky: apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithGrpcAndMultiWorkers (created 2021-07-12)
    https://issues.apache.org/jira/browse/BEAM-12540: beam_PostRelease_NightlySnapshot - Task :runners:direct-java:runMobileGamingJavaDirect FAILED (created 2021-06-25)
    https://issues.apache.org/jira/browse/BEAM-12525: SDF BoundedSource seems to execute significantly slower than 'normal' BoundedSource (created 2021-06-22)
    https://issues.apache.org/jira/browse/BEAM-12505: codecov/patch has poor behavior (created 2021-06-17)
    https://issues.apache.org/jira/browse/BEAM-12500: Dataflow SocketException (SSLException) error while trying to send message from Cloud Pub/Sub to BigQuery (created 2021-06-16)
    https://issues.apache.org/jira/browse/BEAM-12484: JdbcIO date conversion is sensitive to OS (created 2021-06-14)
    https://issues.apache.org/jira/browse/BEAM-12467: java.io.InvalidClassException With Flink Kafka (created 2021-06-09)
    https://issues.apache.org/jira/browse/BEAM-12436: [beam_PostCommit_Go_VR_flink| beam_PostCommit_Go_VR_spark] [:sdks:go:test:flinkValidatesRunner] Failure summary (created 2021-06-01)
    https://issues.apache.org/jira/browse/BEAM-12380: Go SDK Kafka IO Transform implemented via XLang (created 2021-05-21)
    https://issues.apache.org/jira/browse/BEAM-12374: Spark postcommit failing ResumeFromCheckpointStreamingTest (created 2021-05-20)
    https://issues.apache.org/jira/browse/BEAM-12310: beam_PostCommit_Java_DataflowV2 failing (created 2021-05-07)
    https://issues.apache.org/jira/browse/BEAM-12279: Implement destination-dependent sharding in FileIO.writeDynamic (created 2021-05-04)
    https://issues.apache.org/jira/browse/BEAM-12256: PubsubIO.readAvroGenericRecord creates SchemaCoder that fails to decode some Avro logical types (created 2021-04-29)
    https://issues.apache.org/jira/browse/BEAM-11959: Python Beam SDK Harness hangs when installing pip packages (created 2021-03-11)
    https://issues.apache.org/jira/browse/BEAM-11906: No trigger early repeatedly for session windows (created 2021-03-01)
    https://issues.apache.org/jira/browse/BEAM-11875: XmlIO.Read does not handle XML encoding per spec (created 2021-02-26)
    https://issues.apache.org/jira/browse/BEAM-11828: JmsIO is not acknowledging messages correctly (created 2021-02-17)
    https://issues.apache.org/jira/browse/BEAM-11755: Cross-language consistency (RequiresStableInputs) is quietly broken (at least on portable flink runner) (created 2021-02-05)
    https://issues.apache.org/jira/browse/BEAM-11578: `dataflow_metrics` (python) fails with TypeError (when int overflowing?) (created 2021-01-06)
    https://issues.apache.org/jira/browse/BEAM-11148: Kafka commitOffsetsInFinalize OOM on Flink (created 2020-10-28)
    https://issues.apache.org/jira/browse/BEAM-11017: Timer with dataflow runner can be set multiple times (dataflow runner) (created 2020-10-05)
    https://issues.apache.org/jira/browse/BEAM-10670: Make non-portable Splittable DoFn the only option when executing Java "Read" transforms (created 2020-08-10)
    https://issues.apache.org/jira/browse/BEAM-10617: python CombineGlobally().with_fanout() cause duplicate combine results for sliding windows (created 2020-07-31)
    https://issues.apache.org/jira/browse/BEAM-10569: SpannerIO tests don't actually assert anything. (created 2020-07-23)
    https://issues.apache.org/jira/browse/BEAM-10529: Kafka XLang fails for ?empty? key/values (created 2020-07-18)
    https://issues.apache.org/jira/browse/BEAM-10288: Quickstart documents are out of date (created 2020-06-19)
    https://issues.apache.org/jira/browse/BEAM-10244: Populate requirements cache fails on poetry-based packages (created 2020-06-11)
    https://issues.apache.org/jira/browse/BEAM-10100: FileIO writeDynamic with AvroIO.sink not writing all data (created 2020-05-27)
    https://issues.apache.org/jira/browse/BEAM-9564: Remove insecure ssl options from MongoDBIO (created 2020-03-20)
    https://issues.apache.org/jira/browse/BEAM-9482: beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated" (created 2020-03-10)
    https://issues.apache.org/jira/browse/BEAM-9455: Environment-sensitive provisioning for Dataflow (created 2020-03-05)
    https://issues.apache.org/jira/browse/BEAM-9293: Python direct runner doesn't emit empty pane when it should (created 2020-02-11)
    https://issues.apache.org/jira/browse/BEAM-8985: SortValues should fail if SecondaryKey coder is not deterministic (created 2019-12-17)
    https://issues.apache.org/jira/browse/BEAM-8407: [SQL] Some Hive tests throw NullPointerException, but get marked as passing (Direct Runner) (created 2019-10-15)
    https://issues.apache.org/jira/browse/BEAM-7716: PubsubIO returns empty message bodies for all messages read (created 2019-07-10)
    https://issues.apache.org/jira/browse/BEAM-7195: BigQuery - 404 errors for 'table not found' when using dynamic destinations - sometimes, new table fails to get created (created 2019-05-01)
    https://issues.apache.org/jira/browse/BEAM-6839: User reports protobuf ClassChangeError running against 2.6.0 or above (created 2019-03-15)
    https://issues.apache.org/jira/browse/BEAM-6466: KafkaIO doesn't commit offsets while being used as bounded source (created 2019-01-18)