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-14558: Data missing when using CassandraIO.Read (created 2022-06-03) https://issues.apache.org/jira/browse/BEAM-14543: beam_PostCommit_Java_ValidatesRunner_Samza Failing (created 2022-06-01) https://issues.apache.org/jira/browse/BEAM-14459: Docker Snapshots failing to be published since April 14th (created 2022-05-11) https://issues.apache.org/jira/browse/BEAM-14434: beam_LoadTests_Python_GBK_reiterate_Dataflow_Streaming failure (created 2022-05-06) https://issues.apache.org/jira/browse/BEAM-14421: --dataflowServiceOptions=use_runner_v2 is broken (created 2022-05-05) https://issues.apache.org/jira/browse/BEAM-14390: Java license check is broken (created 2022-05-02) https://issues.apache.org/jira/browse/BEAM-14364: 404s in BigQueryIO don't get output to Failed Inserts PCollection (created 2022-04-25) https://issues.apache.org/jira/browse/BEAM-14291: DataflowPipelineResult does not raise exception for unsuccessful states. (created 2022-04-11) https://issues.apache.org/jira/browse/BEAM-14276: beam_PostCommit_Java_DataflowV2 failures parent bug (created 2022-04-07) https://issues.apache.org/jira/browse/BEAM-14275: SpannerWriteIT failing in beam PostCommit Java V1 (created 2022-04-07) https://issues.apache.org/jira/browse/BEAM-14265: Flink should hold the watermark at the output timestamp for processing time timers (created 2022-04-06) https://issues.apache.org/jira/browse/BEAM-14263: beam_PostCommit_Java_DataflowV2, testBigQueryStorageWrite30MProto failing consistently (created 2022-04-05) https://issues.apache.org/jira/browse/BEAM-14253: pubsublite.ReadWriteIT failing in beam_PostCommit_Java_DataflowV1 and V2 (created 2022-04-05) https://issues.apache.org/jira/browse/BEAM-14239: Changing the output timestamp of a timer does not clear the previously set timer (created 2022-04-04) https://issues.apache.org/jira/browse/BEAM-14174: Flink Tests failure : java.lang.NoClassDefFoundError: Could not initialize class org.apache.beam.runners.core.construction.SerializablePipelineOptions (created 2022-03-24) https://issues.apache.org/jira/browse/BEAM-14146: Python Streaming job failing to drain with BigQueryIO write errors (created 2022-03-22) https://issues.apache.org/jira/browse/BEAM-14135: BigQuery Storage API insert with writeResult retry and write to error table (created 2022-03-20) https://issues.apache.org/jira/browse/BEAM-13952: Dataflow streaming tests failing new AfterSynchronizedProcessingTime test (created 2022-02-15) https://issues.apache.org/jira/browse/BEAM-13950: PVR_Spark2_Streaming perma-red (created 2022-02-15) https://issues.apache.org/jira/browse/BEAM-13920: Beam x-lang Dataflow tests failing due to _InactiveRpcError (created 2022-02-10) https://issues.apache.org/jira/browse/BEAM-13852: KafkaIO.read.withDynamicRead() doesn't pick up new TopicPartitions (created 2022-02-08) https://issues.apache.org/jira/browse/BEAM-13850: beam_PostCommit_Python_Examples_Dataflow failing (created 2022-02-08) https://issues.apache.org/jira/browse/BEAM-13822: GBK and CoGBK streaming Java load tests failing (created 2022-02-03) https://issues.apache.org/jira/browse/BEAM-13805: Simplify version override for Dev versions of the Go SDK. (created 2022-02-02) https://issues.apache.org/jira/browse/BEAM-13747: Add integration testing for BQ Storage API write modes (created 2022-01-26) https://issues.apache.org/jira/browse/BEAM-13715: Kafka commit offset drop data on failure for runners that have non-checkpointing shuffle (created 2022-01-21) https://issues.apache.org/jira/browse/BEAM-13669: Install Python wheel and dependencies to local venv in SDK harness (created 2022-01-17) https://issues.apache.org/jira/browse/BEAM-13487: WriteToBigQuery Dynamic table destinations returns wrong tableId (created 2021-12-17) https://issues.apache.org/jira/browse/BEAM-13393: GroupIntoBatchesTest is failing (created 2021-12-07) https://issues.apache.org/jira/browse/BEAM-13164: Race between member variable being accessed due to leaking uninitialized state via OutboundObserverFactory (created 2021-11-01) https://issues.apache.org/jira/browse/BEAM-13132: WriteToBigQuery submits a duplicate BQ load job if a 503 error code is returned from googleapi (created 2021-10-27) https://issues.apache.org/jira/browse/BEAM-13087: apache_beam.runners.portability.fn_api_runner.translations_test.TranslationsTest.test_run_packable_combine_globally 'apache_beam.coders.coder_impl._AbstractIterable' object is not reversible (created 2021-10-20) https://issues.apache.org/jira/browse/BEAM-13078: Python DirectRunner does not emit data at GC time (created 2021-10-18) https://issues.apache.org/jira/browse/BEAM-13076: Python AfterAny, AfterAll do not follow spec (created 2021-10-18) https://issues.apache.org/jira/browse/BEAM-13010: Delete orphaned files (created 2021-10-06) https://issues.apache.org/jira/browse/BEAM-12995: Consumer group with random prefix (created 2021-10-04) https://issues.apache.org/jira/browse/BEAM-12959: Dataflow error in CombinePerKey operation (created 2021-09-26) https://issues.apache.org/jira/browse/BEAM-12867: Either Create or DirectRunner fails to produce all elements to the following transform (created 2021-09-09) 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-12807: Java creates an incorrect pipeline proto when core-construction-java jar is not in the CLASSPATH (created 2021-08-26) https://issues.apache.org/jira/browse/BEAM-12799: "Java IO IT Tests" - missing data in grafana (created 2021-08-25) https://issues.apache.org/jira/browse/BEAM-12792: Multiple jobs running on Flink session cluster reuse the persistent Python environment. (created 2021-08-24) https://issues.apache.org/jira/browse/BEAM-12598: Migrate to the next version of Python `requests` when released (created 2021-07-11) https://issues.apache.org/jira/browse/BEAM-12554: WriteToFiles destination no changing condition (created 2021-06-29) 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-12256: PubsubIO.readAvroGenericRecord creates SchemaCoder that fails to decode some Avro logical types (created 2021-04-29) https://issues.apache.org/jira/browse/BEAM-11998: Portable runners should be able to issue checkpoints to Splittable DoFn (created 2021-03-16) 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-11212: Beam metrics should be displayed in Flink UI "Metrics" tab (created 2020-11-09) 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-10785: Support for coder argument in WriteToBigQuery (created 2020-08-21) 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-10295: FileBasedSink: allow setting temp directory provider per dynamic destination (created 2020-06-22) 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-9152: Hadoop Downloader Range not correct (created 2020-01-20) 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-7996: Add support for remaining data types in python RowCoder (created 2019-08-16) 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-7554: datetime and decimal should be logical types (created 2019-06-13) 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)
