issues  

Messages by Date

• 2023/04/13 [jira] [Updated] (BEAM-10670) Make non-portable Splittable DoFn the only option when executing Java "Read" transforms Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9850) Key should be available in @OnTimer methods (Spark Runner) Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10137) Add cross-language wrapper for Java's KinesisIO Read Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10417) Shared - Library to simplify managing shared large memory objects Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10601) DICOM API Beam IO connector Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9999) Remove support for EOLed runners (Apex and Gearpump) Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9747) Deprecate RedisIO.readAll() and add RedisIO.readKeyPatterns() as a replacement Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-10417) Shared - Library to simplify managing shared large memory objects Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10136) Add cross-language wrapper for Java's JdbcIO Write Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9430) Migrate from ProcessContext#updateWatermark to WatermarkEstimators Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10383) Update Snowflake JDBC dependency Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6696) GroupIntoBatches transform for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9860) Make job_endpoint required for PortableRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9716) Alias zone to worker_zone and warn Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8596) Add SplunkIO transform to write messages to Splunk Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10135) Add cross-language wrapper for Java's JdbcIO Read Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9443) support direct_num_workers=0 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9529) Remove googledatastore package Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9964) Setting workerCacheMb to make its way to the WindmillStateCache Constructor Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7304) Twister2 Beam runner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9723) [Java] PTransform that connects to Cloud DLP deidentification service Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9279) Make HBase.ReadAll based on Reads instead of HBaseQuery Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors Anonymous (Jira)
• 2023/04/13 [jira] [Work stopped] (BEAM-6696) GroupIntoBatches transform for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8494) Python 3.8 Support Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9044) BIP-1: Convert protobuf options to Schema options Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10343) Add dispositions for SnowflakeIO.write Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9704) BIP-1: Deprecate and remove FieldType metadata Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8603) Add Python SqlTransform MVP Anonymous (Jira)
• 2023/04/13 [jira] [Work stopped] (BEAM-9704) BIP-1: Deprecate and remove FieldType metadata Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9916) Update IOs documentation links Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10335) Add STS Assume role credentials provider to AwsModule Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9199) Make --region a required flag for DataflowRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9136) Add LICENSES and NOTICES to docker images Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-10220) Add support for implicit nulls in de/serializing JSON Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-1589) Add OnWindowExpiration method to Stateful DoFn Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9646) [Java] PTransform that integrates Cloud Vision functionality Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9147) [Java] PTransform that integrates Video Intelligence functionality Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9569) Coder inference should be disabled for Row types Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8019) Support cross-language transforms for DataflowRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9634) [Java] PTransform that integrates Cloud Natural Language functionality Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9218) Template staging broken on Beam 2.18.0 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8716) Beam Dependency Update Request: org.apache.commons:commons-csv Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8962) FlinkMetricContainer causes churn in the JobManager and lets the web frontend malfunction Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8749) Beam Dependency Update Request: com.datastax.cassandra:cassandra-driver-mapping Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9055) Unify the config names of Fn Data API across languages Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8999) PGBKCVOperation does not respect timestamp combiners Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8717) Beam Dependency Update Request: org.apache.commons:commons-lang3 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9053) Improve error message when unable to get the correct filesystem for specified path in Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8624) Implement FnService for status api in Dataflow runner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8953) Extend ParquetIO.Read/ReadFiles.Builder to support Avro GenericData model Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8949) Add Spanner IO Integration Test for Python Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8801) PubsubMessageToRow should not check useFlatSchema() in processElement Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8296) Containerize the Spark job server Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8746) Allow the local job service to work from inside docker Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8745) More fine-grained controls for the size of a BigQuery Load job Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8935) Fail fast if sdk harness startup failed Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8701) Beam Dependency Update Request: commons-io:commons-io Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9019) Improve Spark Encoders (wrappers of beam coders) Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-8717) Beam Dependency Update Request: org.apache.commons:commons-lang3 Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-8749) Beam Dependency Update Request: com.datastax.cassandra:cassandra-driver-mapping Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-5546) Beam Dependency Update Request: commons-codec:commons-codec Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8816) Load balance bundle processing w/ multiple SDK workers Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8978) Report saved data size from HadoopFormatIOIT Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-8701) Beam Dependency Update Request: commons-io:commons-io Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9023) Upgrade to ZetaSQL 2019.12.1 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8993) [SQL] MongoDb should use predicate push-down Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8844) [SQL] Create performance tests for BigQueryTable Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9035) BIP-1: Typed options for Row Schema and Fields Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8696) Beam Dependency Update Request: com.google.protobuf:protobuf-java Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8943) SDK harness servers don't shut down properly when SDK harness environment cleanup fails Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8577) FileSystems may have not be initialized during ResourceId deserialization Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8995) apache_beam.io.gcp.bigquery_read_it_test failing on Py3.5 PC with: TypeError: the JSON object must be str, not 'bytes' Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8139) Execute portable Spark application jar Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8623) Add additional message field to Provision API response for passing status endpoint Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5546) Beam Dependency Update Request: commons-codec:commons-codec Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8837) PCollectionVisualizationTest: possible bug Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8946) Report collection size from MongoDBIOIT Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9050) Beam pickler doesn't pickle classes that have __module__ set to None. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8025) Cassandra IO classMethod test is flaky Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7949) Add time-based cache threshold support in the data service of the Python SDK harness Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-2572) Implement an S3 filesystem for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6008) Improve error reporting in Java/Python PortableRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5495) PipelineResources algorithm is not working in most environments Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5690) Issue with GroupByKey in BeamSql using SparkRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8582) Python SDK emits duplicate records for Default and AfterWatermark triggers Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8402) Create a class hierarchy to represent environments Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8884) Python MongoDBIO TypeError when splitting Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9228) _SDFBoundedSourceWrapper doesn't distribute data to multiple workers Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-1833) Restructure Python pipeline construction to better follow the Runner API Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9248) [Python] PTransform that integrates Cloud Natural Language functionality Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8841) Add ability to perform BigQuery file loads using avro Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7310) Confluent Schema Registry support in KafkaIO Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5192) Support Elasticsearch 7.x Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-9445) Preoptimize causes error with environment setup Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8882) Allow Dataflow to automatically choose portability or not. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8616) ParquetIO should have Hadoop dependencies as provided Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9277) Beam 2.19 raises exception in IPython notebook Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9247) [Python] PTransform that integrates Cloud Vision functionality Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-9579) ApproximateQuantilesCombineFn uses deprecated '-' operator Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6857) Support dynamic timers Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7246) Add Google Spanner IO on Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9258) [Python] PTransform that connects to Cloud DLP deidentification service Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9445) Preoptimize causes error with environment setup Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-7246) Add Google Spanner IO on Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-9322) Python SDK ignores manually set PCollection tags Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9146) [Python] PTransform that integrates Video Intelligence functionality Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9225) Flink uber jar job server hangs Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9310) Make SpannerAccessor in Java package-private to reduce API surface Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9725) Perfomance regression in reshuffle Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9503) SyntaxError in process worker startup Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9305) Support ValueProvider for BigQuerySource query string Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9063) Migrate docker images to apache namespace. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8836) ExternalTransform is not providing a unique name Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8561) Add ThriftIO to Support IO for Thrift Files Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8399) Python HDFS implementation should support filenames of the format "hdfs://namenodehost/parent/child" Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8550) @RequiresTimeSortedInput DoFn annotation Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9579) ApproximateQuantilesCombineFn uses deprecated '-' operator Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9042) AvroUtils.schemaCoder(schema) produces a not serializable SchemaCoder Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9322) Python SDK ignores manually set PCollection tags Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-3453) Allow usage of public Google PubSub topics in Python DirectRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9123) HadoopResourceId returns wrong directory name Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9144) Beam's own Avro TimeConversion class in beam-sdk-java-core Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9041) SchemaCoder equals should not rely on from/toRowFunction equality Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-9065) Spark runner accumulates metrics (incorrectly) between runs Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8480) Explicitly set restriction coder for bounded reader wrapper SDF. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7981) ParDo function wrapper doesn't support Iterable output types Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8802) Timestamp combiner not respected across bundles in streaming mode. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8470) Create a new Spark runner based on Spark Structured streaming framework Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8365) Add project push-down capability to IO APIs Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8657) Not doing Combiner lifting for data-driven triggers Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8540) Fix CSVSink example in FileIO docs Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8427) [SQL] Add support for MongoDB source Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6756) Support lazy iterables in schemas Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8658) Optionally set artifact staging port in FlinkUberJarJobServer Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7078) Beam Dependency Update Request: com.amazonaws:amazon-kinesis-client Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8456) Add pipeline option to control truncate of BigQuery data processed by Beam SQL Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8468) Add predicate/filter push-down capability to IO APIs Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8579) Strip UTF-8 BOM bytes (if present) in TextSource. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8835) Artifact retrieval fails with FlinkUberJarJobServer Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8825) OOM when writing large numbers of 'narrow' rows Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8515) Ensure that ValueProvider types have equals/hashCode implemented for comparison reasons Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-6303) Add .parquet extension to files in ParquetIO Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7636) Migrate SqsIO to AWS SDK for Java 2 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8660) Override returned artifact staging endpoint Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8822) Upgrade Hadoop dependencies to version 2.8 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8663) BundleBasedRunner Stacked Bundles don't respect PaneInfo Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8352) Reading records in background may lead to OOM errors Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8667) Data channel should to avoid unlimited buffering in Python SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8252) (Python SDK) Add worker_region and worker_zone options Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8016) Render Beam Pipeline as DOT with Interactive Beam Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8343) Add means for IO APIs to support predicate and/or project push-down when running SQL pipelines Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8814) --no_auth flag is boolean type and is misleading Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8379) Cache Eviction for Interactive Beam Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7760) Interactive Beam Caching PCollections bound to user defined vars in notebook Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8508) [SQL] Support predicate push-down without project push-down Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-4777) Python PortableRunner should support metrics Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7917) Python datastore v1new fails on retry Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8254) (Java SDK) Add workerRegion and workerZone options Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8146) SchemaCoder/RowCoder have no equals() function Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8989) Backwards incompatible change in ParDo.getSideInputs (caught by failure when running Apache Nemo quickstart) Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-4776) Java PortableRunner should support metrics Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8394) Add withDataSourceConfiguration() method in JdbcIO.ReadRows class Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7473) Update RestrictionTracker within Python to not be required to be thread safe Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8351) Support passing in arbitrary KV pairs to sdk worker via external environment config Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8285) Upgrade to ZetaSQL 2019.09.1 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8100) Add exception handling to Json transforms in Java SDK Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8392) Update pyarrow version bounds Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7962) Drop support for Flink 1.5 and 1.6 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8312) Flink portable pipeline jars do not need to stage artifacts remotely Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8014) Use OffsetRange as restriction for OffsetRestrictionTracker Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8861) Disallow self-signed certificates by default in ElasticsearchIO Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8303) Filesystems not properly registered using FileIO.write() on FlinkRunner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8355) Make BooleanCoder a standard coder Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8299) Upgrade Jackson to version 2.9.10 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7990) Add ability to read parquet files into PCollection<pyarrow.Table> Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-5895) Beam Dependency Update Request: com.rabbitmq:amqp-client Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-5428) Implement cross-bundle state caching. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8088) PCollection boundedness should be tracked and propagated in python sdk Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8015) Get logs for SDK worker Docker containers Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8161) Upgrade to joda time 2.10.3 to get updated TZDB Anonymous (Jira)
• 2023/04/13 [jira] [Work started] (BEAM-8363) Nexmark regression in direct runner in streaming mode Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8410) JdbcIO should support setConnectionInitSqls in its DataSource Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7966) Write portable Beam application jar Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7588) Python BigQuery sink should be able to handle 15TB load job quota Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8396) Default to LOOPBACK mode for local flink (spark, ...) runner. Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7635) Migrate SnsIO to AWS SDK for Java 2 Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7820) Add hot key detection to Dataflow Runner Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-7920) AvroTableProvider Anonymous (Jira)
• 2023/04/13 [jira] [Updated] (BEAM-8471) Flink native job submission for portable pipelines Anonymous (Jira)

• Earlier messages
• Later messages