P1 issues report (79)
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-14495: validatesCrossLanguageRunnerGoUsingJava is failing for beam_PostCommit_XVR_Direct (created 2022-05-20) https://issues.apache.org/jira/browse/BEAM-14483: Add Java cross-language transforms for invoking Python Map and FlatMap (created 2022-05-17) https://issues.apache.org/jira/browse/BEAM-14481: OOM regression caused by Batched DoFn worker changes (created 2022-05-17) 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-14431: Handle nulls using SnowflakeIO (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-14411: TypeCodersTest is never executed (created 2022-05-04) 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-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 l
P1 issues report (79)
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-14483: Add Java cross-language transforms for invoking Python Map and FlatMap (created 2022-05-17) https://issues.apache.org/jira/browse/BEAM-14481: OOM regression caused by Batched DoFn worker changes (created 2022-05-17) 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-14431: Handle nulls using SnowflakeIO (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-14411: TypeCodersTest is never executed (created 2022-05-04) 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-14356: Java PostCommits: BigQueryIO.Read needs a GCS temp location (created 2022-04-22) https://issues.apache.org/jira/browse/BEAM-14298: Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde (created 2022-04-12) 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-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-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
P1 issues report (79)
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-14447: BigQueryWriteIntegrationTests.test_big_query_write_insert_errors_reporting failing in Python PostCommit (created 2022-05-09) 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-14429: SyntheticUnboundedSource(with SDF) produce duplicate records when split with DEFAULT_DESIRED_NUM_SPLITS (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-14416: ParDo LoadTest performance regression on java streaming dataflow runner v2 (created 2022-05-04) https://issues.apache.org/jira/browse/BEAM-14412: Block release on impersonation FR (created 2022-05-04) https://issues.apache.org/jira/browse/BEAM-14411: TypeCodersTest is never executed (created 2022-05-04) 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-14356: Java PostCommits: BigQueryIO.Read needs a GCS temp location (created 2022-04-22) https://issues.apache.org/jira/browse/BEAM-14298: Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde (created 2022-04-12) 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-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-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:/
P1 issues report (79)
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-14421: --dataflowServiceOptions=use_runner_v2 is broken (created 2022-05-05) https://issues.apache.org/jira/browse/BEAM-14416: ParDo LoadTest performance regression on java streaming dataflow runner v2 (created 2022-05-04) https://issues.apache.org/jira/browse/BEAM-14412: Block release on impersonation FR (created 2022-05-04) https://issues.apache.org/jira/browse/BEAM-14411: TypeCodersTest is never executed (created 2022-05-04) https://issues.apache.org/jira/browse/BEAM-14403: Allow Prime to be used with Legacy workers (created 2022-05-03) https://issues.apache.org/jira/browse/BEAM-14399: org.apache.beam.sdk.io.gcp.spanner.SpannerWriteIT.testReportFailures is failing in Dataflow Java Runner V1 postcommits. (created 2022-05-03) 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-14356: Java PostCommits: BigQueryIO.Read needs a GCS temp location (created 2022-04-22) https://issues.apache.org/jira/browse/BEAM-14298: Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde (created 2022-04-12) 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-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:
P1 issues report (79)
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-14421: --dataflowServiceOptions=use_runner_v2 is broken (created 2022-05-05) https://issues.apache.org/jira/browse/BEAM-14412: Block release on impersonation FR (created 2022-05-04) https://issues.apache.org/jira/browse/BEAM-14411: TypeCodersTest is never executed (created 2022-05-04) https://issues.apache.org/jira/browse/BEAM-14403: Allow Prime to be used with Legacy workers (created 2022-05-03) https://issues.apache.org/jira/browse/BEAM-14399: org.apache.beam.sdk.io.gcp.spanner.SpannerWriteIT.testReportFailures is failing in Dataflow Java Runner V1 postcommits. (created 2022-05-03) 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-14356: Java PostCommits: BigQueryIO.Read needs a GCS temp location (created 2022-04-22) https://issues.apache.org/jira/browse/BEAM-14298: Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde (created 2022-04-12) 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-14173: beam_LoadTests_Go_CoGBK_Flink_batch, beam_LoadTests_Go_Combine_Flink_batch, etc: Encountered unsupported logical type URN: int org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException (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-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 variab
P1 issues report (79)
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-14390: Java license check is broken (created 2022-05-02) https://issues.apache.org/jira/browse/BEAM-14389: Beam seed job doesn't run (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-14356: Java PostCommits: BigQueryIO.Read needs a GCS temp location (created 2022-04-22) https://issues.apache.org/jira/browse/BEAM-14344: Opencensus 0.28.0 bug with Distributed Tracing (created 2022-04-21) https://issues.apache.org/jira/browse/BEAM-14326: Pipelines using BigQueryIO connector with one of the Storage Write API methods don't exit the launch process (created 2022-04-19) https://issues.apache.org/jira/browse/BEAM-14298: Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde (created 2022-04-12) 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-14230: Python JDBC API don't recognize "statement" parameter (created 2022-04-01) 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-14173: beam_LoadTests_Go_CoGBK_Flink_batch, beam_LoadTests_Go_Combine_Flink_batch, etc: Encountered unsupported logical type URN: int org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException (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-14064: ElasticSearchIO#Write buffering and outputting across windows (created 2022-03-07) 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-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 bet
P1 issues report (79)
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-14346: ret2() function checks incorrect index for error case (created 2022-04-21) https://issues.apache.org/jira/browse/BEAM-14344: Opencensus 0.28.0 bug with Distributed Tracing (created 2022-04-21) https://issues.apache.org/jira/browse/BEAM-14342: testPairWithIndexWindowedTimestamped* failing on URL (created 2022-04-20) https://issues.apache.org/jira/browse/BEAM-14326: Pipelines using BigQueryIO connector with one of the Storage Write API methods don't exit the launch process (created 2022-04-19) https://issues.apache.org/jira/browse/BEAM-14321: Aggregates should return null if all inputs are null (created 2022-04-18) https://issues.apache.org/jira/browse/BEAM-14313: [IT Tests] Message not acknowledged using Direct Runner (created 2022-04-15) https://issues.apache.org/jira/browse/BEAM-14298: Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde (created 2022-04-12) 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-14253: pubsublite.ReadWriteIT failing in beam_PostCommit_Java_DataflowV1 and V2 (created 2022-04-05) https://issues.apache.org/jira/browse/BEAM-14230: Python JDBC API don't recognize "statement" parameter (created 2022-04-01) 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-14064: ElasticSearchIO#Write buffering and outputting across windows (created 2022-03-07) https://issues.apache.org/jira/browse/BEAM-14017: beam_PreCommit_CommunityMetrics_Cron is failing. (created 2022-03-01) https://issues.apache.org/jira/browse/BEAM-13953: Document BigQueryIO Storage Write API methods (created 2022-02-15) 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-13798: Upgrade Kubernetes Clusters (created 2022-02-01) 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-13657: Sunset Python 3.6 support in Beam (created 2022-01-13) 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)
P1 issues report (79)
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-14321: Aggregates should return null if all inputs are null (created 2022-04-18) https://issues.apache.org/jira/browse/BEAM-14313: [IT Tests] Message not acknowledged using Direct Runner (created 2022-04-15) https://issues.apache.org/jira/browse/BEAM-14298: Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde (created 2022-04-12) 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-14288: Python PreCommit flaking in test_pformat_namedtuple_with_unnamed_fields (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-14254: beam_PostCommit_Java_PVR_Flink_Streaming failing due to new AfterSynchronizedProcessingTime test (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-14230: Python JDBC API don't recognize "statement" parameter (created 2022-04-01) https://issues.apache.org/jira/browse/BEAM-14191: CrossLanguageJdbcIOTest broken with "Cannot load JDBC driver class 'com.mysql.cj.jdbc.Driver'" (created 2022-03-28) 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-14138: Python PostCommit BQ test failures due to NOT_FOUND for Dataset (created 2022-03-21) 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-14126: Python 3.10 Support (created 2022-03-18) https://issues.apache.org/jira/browse/BEAM-14064: ElasticSearchIO#Write buffering and outputting across windows (created 2022-03-07) https://issues.apache.org/jira/browse/BEAM-14017: beam_PreCommit_CommunityMetrics_Cron is failing. (created 2022-03-01) https://issues.apache.org/jira/browse/BEAM-13953: Document BigQueryIO Storage Write API methods (created 2022-02-15) 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-13798: Upgrade Kubernetes Clusters (created 2022-02-01) 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-13657: Sunset Python 3.6 support in Beam (created 2022-01-13) https://issues.apache.org/jira/browse/BEAM-13582: Beam website precommit mentions broken links, but passes. (created 2021-12-30) 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 googl
