issues  

Messages by Date

• 2023/04/13 [jira] [Updated] (BEAM-7967) Execute portable Flink application jar Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6480) Add AvroIO.sink for IndexedRecord (FileIO compatible) Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8183) Optionally bundle multiple pipelines into a single Flink jar Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7880) Upgrade Jackson databind to version 2.9.9.3 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7045) Element counters in the Web UI graph representations for transforms for Python streaming jobs in Google Cloud Dataflow Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8363) Nexmark regression in direct runner in streaming mode Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7616) urlopen calls could get stuck without a timeout Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8609) Add HllCount to Java transform catalog Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8098) BigQueryIO needs documentation on how data types in BigQuery and in Beam SDK correspond Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6896) Beam Dependency Update Request: PyYAML Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8111) SchemaCoder broken on DataflowRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7866) Python MongoDB IO performance and correctness issues Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7450) Support unbounded reads with HCatalogIO Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6114) SQL join selection should be done in planner, not in expansion to PTransform Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7728) Support ParquetTable Source in SQL Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-3645) Support multi-process execution on the FnApiRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5967) ProtoCoder doesn't support DynamicMessage Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8324) Pre/Postcommit Dataflow IT tests fail: _create_function() takes from 2 to 6 positional arguments but 7 were given Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7980) External environment with containerized worker pool Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7986) Increase minimum grpcio required version Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7667) report GCS throttling time to Dataflow autoscaler Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8368) [Python] libprotobuf-generated exception when importing apache_beam Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7561) HdfsFileSystem is unable to match a directory Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7465) Upgrade Jackson to version 2.9.9 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-562) DoFn Reuse: Add new DoFn setup and teardown to python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6674) The JdbcIO source should produce schemas Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7194) [SQL] EXCEPT DISTINCT behavior when right set contains a value is incorrect Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7144) Job re-scale fails on Flink >= 1.6 with certain values of maxParallelism Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7263) Deprecate set/getClientConfiguration in JdbcIO Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6730) Enable configuration of Java transforms (specifically IO) through other SDKs Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6872) Add hook for user-defined JVM initialization in workers Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7265) Update Spark runner to use spark version 2.4.3 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7305) Add first version of Hazelcast Jet Runner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6693) ApproximateUnique transform for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7021) ToString transform for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6620) Do not relocate guava Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7043) Add DynamoDBIO Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7348) Option to expire SDK worker environments Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6673) BigQueryIO.Read should automatically produce schemas Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7600) Spark portable runner: reuse SDK harness Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7907) Support customized container Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7894) Upgrade "com.amazonaws:amazon-kinesis-producer" to version 0.13.1 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7060) Design Py3-compatible typehints annotation support in Beam 3. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7742) BigQuery File Loads to work well with load job size limits Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7833) warn user when --region flag is not explicitly set Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6611) A Python Sink for BigQuery with File Loads in Streaming Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7513) [SQL] Row Estimation for BigQueryTable Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7761) Support transform_name_mapping option in python sdk Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7927) Add ability to get the list of submitted jobs from gRPC JobService Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7741) Add SetState in Python sdk Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6675) The JdbcIO sink should accept schemas Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5191) Add support for writing to BigQuery clustered tables Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7603) Support for ValueProvider-given GCS Location for WriteToBigQuery w File Loads Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7443) BoundedSource->SDF needs a wrapper in Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7268) Make external sorter Hadoop free Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6952) concatenated compressed files bug with python sdk Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6695) Latest transform for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6769) BigQuery IO does not support bytes in Python 3 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7019) Reify transform for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7442) Bounded Reads for Flink Runner fails with OOM Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7286) RedisIO support for INCRBY/DECRBY operations Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5865) Auto sharding of streaming sinks in FlinkRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7023) WithKeys transform for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5148) Implement MongoDB IO for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-1251) Python 3 Support Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8371) Sunset Beam Python 2 support in new releases in 2020. Anonymous (Jira)
• 2023/03/28 [jira] [Updated] (BEAM-10261) [FileIO] Unexpected exception thrown when retrieving a GCS file with a space inside path Anonymous (Jira)
• 2023/03/18 [jira] [Updated] (BEAM-4010) Add a C# SDK for .NET core Anonymous (Jira)
• 2023/03/18 [jira] [Updated] (BEAM-4010) Add a C# SDK for .NET core Anonymous (Jira)
• 2023/03/18 [jira] [Updated] (BEAM-4010) Add a C# SDK for .NET core Anonymous (Jira)
• 2023/03/18 [jira] [Updated] (BEAM-4010) Add a C# SDK for .NET core Anonymous (Jira)
• 2023/03/16 [jira] [Updated] (BEAM-12636) Windowing transform not working for sdk-go on Dataflow? Anonymous (Jira)
• 2023/03/16 [jira] [Updated] (BEAM-12636) Windowing transform not working for sdk-go on Dataflow? Anonymous (Jira)
• 2023/02/13 [jira] [Updated] (BEAM-7556) Enable to upgrade proxy generation independently of beam for java support Anonymous (Jira)
• 2023/02/08 [jira] [Updated] (BEAM-9363) BeamSQL windowing as TVF Anonymous (Jira)
• 2023/02/03 [jira] [Updated] (BEAM-13088) Load BigQuery temp tables into different dataset Anonymous (Jira)
• 2023/02/01 [jira] [Updated] (BEAM-10261) [FileIO] Unexpected exception thrown when retrieving a GCS file with a space inside path Anonymous (Jira)
• 2023/02/01 [jira] [Work started] (BEAM-4010) Add a C# SDK for .NET core Anonymous (Jira)
• 2023/01/07 [jira] [Updated] (BEAM-123) Skip header row from csv Anonymous (Jira)
• 2023/01/03 [jira] [Work stopped] (BEAM-12871) Support for Confluent Schema Registry Anonymous (Jira)
• 2023/01/03 [jira] [Work started] (BEAM-12871) Support for Confluent Schema Registry Anonymous (Jira)
• 2022/12/12 [jira] [Updated] (BEAM-2896) Portability milestone: wordcount runs everywhere Anonymous (Jira)
• 2022/12/12 [jira] [Updated] (BEAM-5284) Enable Java Portable Flink PostCommit Tests to Jenkins Anonymous (Jira)
• 2022/12/12 [jira] [Updated] (BEAM-5187) Create a ProcessJobBundleFactory for non-dockerized SDK harness Anonymous (Jira)
• 2022/12/12 [jira] [Updated] (BEAM-5187) Create a ProcessJobBundleFactory for non-dockerized SDK harness Anonymous (Jira)
• 2022/12/12 [jira] [Updated] (BEAM-5284) Enable Java Portable Flink PostCommit Tests to Jenkins Anonymous (Jira)
• 2022/12/12 [jira] [Updated] (BEAM-4404) Fix docker run arguments Anonymous (Jira)
• 2022/11/28 [jira] [Updated] (BEAM-12730) Add custom delimiters to Python TextIO reads Anonymous (Jira)
• 2022/11/27 [jira] [Updated] (BEAM-14446) Update documentation to point to GitHub issues instead of Jira Anonymous (Jira)
• 2022/11/19 [jira] [Updated] (BEAM-13391) The Apache Avro library failed to parse the header with the following error: EOF reached Anonymous (Jira)
• 2022/11/12 [jira] [Updated] (BEAM-6202) Gracefully handle exceptions when waiting for Dataflow job completion. Anonymous (Jira)
• 2022/11/07 [jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint Anonymous (Jira)
• 2022/10/13 [jira] [Updated] (BEAM-1857) Add Neo4jIO Anonymous (Jira)
• 2022/10/12 [jira] [Updated] (BEAM-11275) Support GCS files for extra_requirements argument in Python Beam portable runners Anonymous (Jira)
• 2022/10/04 [jira] [Updated] (BEAM-14419) Remove invalid mod type from DataChangeRecord Thiago Nunes (Jira)
• 2022/09/15 [jira] [Updated] (BEAM-13261) JDBC IO: expose max pool connections as a setting Anonymous (Jira)
• 2022/09/08 [jira] [Updated] (BEAM-14364) 404s in BigQueryIO don't get output to Failed Inserts PCollection Anonymous (Jira)
• 2022/09/08 [jira] [Updated] (BEAM-14364) 404s in BigQueryIO don't get output to Failed Inserts PCollection Anonymous (Jira)
• 2022/08/22 [jira] [Updated] (BEAM-12534) Support the XDG Base Directory Specification Ignacio Taranto (Jira)
• 2022/08/14 [jira] [Updated] (BEAM-7702) Colab examples for element-wise transforms (Java) Anonymous (Jira)
• 2022/08/14 [jira] [Updated] (BEAM-7702) Colab examples for element-wise transforms (Java) Anonymous (Jira)
• 2022/07/25 [jira] [Updated] (BEAM-8651) Python 3 portable pipelines sometimes fail with errors in StockUnpickler.find_class() Anonymous (Jira)
• 2022/07/25 [jira] [Updated] (BEAM-10769) Fix Avro IO documentation: when fastavro is used, do not pass schema parsed by avro-python3. Anonymous (Jira)
• 2022/07/25 [jira] [Work started] (BEAM-6158) Using --save_main_session fails on Python 3 when main module has invocations of superclass method using 'super' . Anonymous (Jira)
• 2022/07/25 [jira] [Updated] (BEAM-6158) Using --save_main_session fails on Python 3 when main module has invocations of superclass method using 'super' . Anonymous (Jira)
• 2022/07/25 [jira] [Updated] (BEAM-9829) Restructure test infrastructure for Python SDK Anonymous (Jira)
• 2022/07/25 [jira] [Work stopped] (BEAM-9829) Restructure test infrastructure for Python SDK Anonymous (Jira)
• 2022/07/06 [jira] [Updated] (BEAM-13956) Serialize/deserialize StsClient when serializing/deserializing StsAssumeRoleCredentialsProvider Anonymous (Jira)
• 2022/07/06 [jira] [Updated] (BEAM-13956) Serialize/deserialize StsClient when serializing/deserializing StsAssumeRoleCredentialsProvider Anonymous (Jira)
• 2022/07/03 [jira] [Updated] (BEAM-3165) Mongo document read with non hex objectid Anonymous (Jira)
• 2022/07/03 [jira] [Updated] (BEAM-3165) Mongo document read with non hex objectid Anonymous (Jira)
• 2022/06/30 [jira] [Updated] (BEAM-7703) Colab examples for aggregation transforms (Java) Anonymous (Jira)
• 2022/06/23 [jira] [Work started] (BEAM-7471) DirectRunner GameStats fails, ValueError: PCollection of size 2 with more than one element accessed as a singleton view. First two elements encountered are "181.611538462", "9.1". [while running 'CalculateSpammyUsers/ProcessAndFilter'] Anonymous (Jira)
• 2022/06/15 [jira] [Work started] (BEAM-13594) Support for locked buckets in Beam Ahmed Abualsaud (Jira)
• 2022/06/14 [jira] [Updated] (BEAM-14376) Typo in method description doc Oskar Firlej (Jira)
• 2022/06/14 [jira] [Updated] (BEAM-14376) Typo in method description doc Oskar Firlej (Jira)
• 2022/06/13 [jira] [Work stopped] (BEAM-10160) Add Apache Iceberg IO connector Anonymous (Jira)
• 2022/06/13 [jira] [Work started] (BEAM-10160) Add Apache Iceberg IO connector Anonymous (Jira)
• 2022/06/08 [jira] [Work started] (BEAM-13516) [Playground] Perma-link generation for a sample created by a user Anonymous (Jira)
• 2022/06/07 [jira] [Work started] (BEAM-10785) Support for coder argument in WriteToBigQuery Anonymous (Jira)
• 2022/06/07 [jira] [Work stopped] (BEAM-10785) Support for coder argument in WriteToBigQuery Anonymous (Jira)
• 2022/06/07 [jira] [Work started] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder Alexey Romanenko (Jira)
• 2022/06/06 [jira] [Work started] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio. Anonymous (Jira)
• 2022/06/06 [jira] [Work stopped] (BEAM-14198) [CdapIO] Implement CDAP IO interface for batch plugins: Read Elizaveta Lomteva (Jira)
• 2022/06/06 [jira] [Work started] (BEAM-14198) [CdapIO] Implement CDAP IO interface for batch plugins: Read Elizaveta Lomteva (Jira)
• 2022/06/06 [jira] [Updated] (BEAM-14527) Implement "Beam Summit 2022" banner Alexander Zhuravlev (Jira)
• 2022/06/05 [jira] [Work logged] (BEAM-13647) Go SDK FnApi environment version 9 should be compatible with Runner v2 artifact service ASF GitHub Bot (Jira)
• 2022/06/04 [jira] [Work logged] (BEAM-10785) Support for coder argument in WriteToBigQuery ASF GitHub Bot (Jira)
• 2022/06/04 [jira] [Updated] (BEAM-13827) upload to s3 fails if last chunk in finish happens to be of 0 length Johan Sternby (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14558) Data missing when using CassandraIO.Read Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14364) 404s in BigQueryIO don't get output to Failed Inserts PCollection Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14269) PulsarIOTest.testReadFromSimpleTopic is very flaky Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14265) Flink should hold the watermark at the output timestamp for processing time timers Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14543) beam_PostCommit_Java_ValidatesRunner_Samza Failing Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14146) Python Streaming job failing to drain with BigQueryIO write errors Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14263) beam_PostCommit_Java_DataflowV2, testBigQueryStorageWrite30MProto failing consistently Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14390) Java license check is broken Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14349) GroupByKeyTest BasicTests testLargeKeys100MB flake (on ULR) Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14275) SpannerWriteIT failing in beam PostCommit Java V1 Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14367) Flaky timeout in github Python unit test action StatefulDoFnOnDirectRunnerTest.test_dynamic_timer_clear_then_set_timer Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14239) Changing the output timestamp of a timer does not clear the previously set timer Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14252) beam_PostCommit_Java_DataflowV1 failing with a variety of flakes and errors Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14459) Docker Snapshots failing to be published since April 14th Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14277) SpannerChangeStreamIT test failing Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14253) pubsublite.ReadWriteIT failing in beam_PostCommit_Java_DataflowV1 and V2 Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14434) beam_LoadTests_Python_GBK_reiterate_Dataflow_Streaming failure Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14276) beam_PostCommit_Java_DataflowV2 failures parent bug Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14421) --dataflowServiceOptions=use_runner_v2 is broken Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14174) Flink Tests failure : java.lang.NoClassDefFoundError: Could not initialize class org.apache.beam.runners.core.construction.SerializablePipelineOptions Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14135) BigQuery Storage API insert with writeResult retry and write to error table Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14291) DataflowPipelineResult does not raise exception for unsuccessful states. Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14551) Exception from ElasticSearch Write Module in DataFlow Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio. Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14534) Add an interface to allow users to compress values being written to shuffle Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14102) [CdapIO] Adopt CDAP IO for bath plugins: Read PoC using wrappers Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14198) [CdapIO] Implement CDAP IO interface for batch plugins: Read Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14529) Beam BQIO not accepting integer values for BQ table fields of type Float64 Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14446) Update documentation to point to GitHub issues instead of Jira Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14553) Dataflow portable job submission translate FileResultCoder only with window coder Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14441) Migrate from Jira to GitHub Issues Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14443) Migrate existing Jiras to GitHub Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14116) Fix Pub/Sub Lite IO and SDF performance issues with shuffles Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14557) Migrate exclusively to the v1 progress/metrics API Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14516) Add context support for Python callables Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14532) Add integration test for Go FhirIO Read transform Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14406) Integration testing of Pipeline drain in Go SDK Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14554) Create BigtableIO setting to report external system throttle time to Dataflow Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14422) ReadFromBigQuery with query requires exception handling tests. So does File Loads Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14552) Extraneous warning message: "Make sure that locally built Python SDK docker image has Python X.Y interpreter" Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14237) Golang Beam ParDo job not working as expected on Apple M1 chip Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14378) [CdapIO] Design and implement SparkReceiverViaSDF component Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14464) Optimize precombining table. Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14315) Update fileio.MatchContinuously to allow reading already read files with a new timestamp Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14547) Bug in type inference for Python 3.10 Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14544) Unable to drain pipelines due to seemingly irrelevant timestamp shift validation Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14542) TPC-DS: Add user documentation on website Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14510) LocalFileSystem requires exception handling tests Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14297) Enable null key and value for metadata kafka xlang Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14524) Add return_row option to RunInference transform Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14513) Add Read transform and initial HealthcareClient in Go SDK Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14545) Optimize copies in dataflow v1 shuffle reader Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14411) TypeCodersTest is never executed Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14377) Make it easier to run seed job against open PRs Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14540) Native implementation for serialized Rows to/from Arrow Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14541) Timestamp value conversion in Cloud Datastore connector is wrong Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14431) Handle nulls using SnowflakeIO Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14481) ScopedState can not be re-entered (regression caused by Batched DoFn worker changes) Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14408) batch-consuming DoFns should estimate byte size Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14293) Add @DoFn.yields_batches and @DoFn.yields_elements decorators to override defaults Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14339) More verbose errors when BatchConverter fails to match Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14420) Mongo DB Upgrade to 5.0 having compatibitlity issue with Apache Beam included mongo-java-driver. Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14527) Implement "Beam Summit 2022" banner Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14214) beam_PostCommit_XVR_GoUsingJava_Dataflow fails on some test transforms Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14340) Consider providing a dynamic API for declaring batch input type Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14537) Create a cross-language registrar for SchemaTransform Danny McCormick (Jira)
• 2022/06/04 [jira] [Commented] (BEAM-14352) Add a TimestampedBatch analogue for TimestampedValue Danny McCormick (Jira)

• Earlier messages
• Later messages