[jira] [Updated] (BEAM-8139) Execute portable Spark application jar

[ https://issues.apache.org/jira/browse/BEAM-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8139: Status: Triage Needed (was: Resolved) > Execute portable Spark application

[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'

[ https://issues.apache.org/jira/browse/BEAM-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8995: Status: Triage Needed (was: Resolved) > apache_beam.io.gcp.bigquery_read_it_test failing on Py3.5 PC w

[jira] [Updated] (BEAM-8577) FileSystems may have not be initialized during ResourceId deserialization

[ https://issues.apache.org/jira/browse/BEAM-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8577: Status: Triage Needed (was: Resolved) > FileSystems may have not be initialized during Resourc

[jira] [Updated] (BEAM-5495) PipelineResources algorithm is not working in most environments

[ https://issues.apache.org/jira/browse/BEAM-5495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-5495: Status: Triage Needed (was: Resolved) > PipelineResources algorithm is not working in most environme

[jira] [Updated] (BEAM-6008) Improve error reporting in Java/Python PortableRunner

[ https://issues.apache.org/jira/browse/BEAM-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6008: Status: Triage Needed (was: Resolved) > Improve error reporting in Java/Python PortableRun

[jira] [Updated] (BEAM-2572) Implement an S3 filesystem for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-2572: Status: Triage Needed (was: Resolved) > Implement an S3 filesystem for Python

[jira] [Updated] (BEAM-7949) Add time-based cache threshold support in the data service of the Python SDK harness

[ https://issues.apache.org/jira/browse/BEAM-7949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7949: Status: Triage Needed (was: Resolved) > Add time-based cache threshold support in the data service of

[jira] [Updated] (BEAM-8025) Cassandra IO classMethod test is flaky

[ https://issues.apache.org/jira/browse/BEAM-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8025: Status: Triage Needed (was: Resolved) > Cassandra IO classMethod test is fl

[jira] [Updated] (BEAM-9050) Beam pickler doesn't pickle classes that have __module__ set to None.

[ https://issues.apache.org/jira/browse/BEAM-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9050: Status: Triage Needed (was: Resolved) > Beam pickler doesn't pickle classes that have __module_

[jira] [Updated] (BEAM-8946) Report collection size from MongoDBIOIT

[ https://issues.apache.org/jira/browse/BEAM-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8946: Status: Triage Needed (was: Resolved) > Report collection size from MongoDBI

[jira] [Updated] (BEAM-8582) Python SDK emits duplicate records for Default and AfterWatermark triggers

[ https://issues.apache.org/jira/browse/BEAM-8582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8582: Status: Triage Needed (was: Resolved) > Python SDK emits duplicate records for Default and AfterWaterm

[jira] [Updated] (BEAM-5690) Issue with GroupByKey in BeamSql using SparkRunner

[ https://issues.apache.org/jira/browse/BEAM-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-5690: Status: Triage Needed (was: Resolved) > Issue with GroupByKey in BeamSql using SparkRun

[jira] [Updated] (BEAM-8402) Create a class hierarchy to represent environments

[ https://issues.apache.org/jira/browse/BEAM-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8402: Status: Triage Needed (was: Resolved) > Create a class hierarchy to represent environme

[jira] [Updated] (BEAM-8884) Python MongoDBIO TypeError when splitting

[ https://issues.apache.org/jira/browse/BEAM-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8884: Status: Triage Needed (was: Resolved) > Python MongoDBIO TypeError when splitt

[jira] [Updated] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-1440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-1440: Status: Triage Needed (was: Resolved) > Create a BigQuery source (that implements iobase.BoundedSou

[jira] [Updated] (BEAM-9228) _SDFBoundedSourceWrapper doesn't distribute data to multiple workers

[ https://issues.apache.org/jira/browse/BEAM-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9228: Status: Triage Needed (was: Resolved) > _SDFBoundedSourceWrapper doesn't distribute data to

[jira] [Updated] (BEAM-1833) Restructure Python pipeline construction to better follow the Runner API

[ https://issues.apache.org/jira/browse/BEAM-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-1833: Status: Triage Needed (was: Resolved) > Restructure Python pipeline construction to better follow

[jira] [Updated] (BEAM-9248) [Python] PTransform that integrates Cloud Natural Language functionality

[ https://issues.apache.org/jira/browse/BEAM-9248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9248: Status: Triage Needed (was: Resolved) > [Python] PTransform that integrates Cloud Natural Langu

[jira] [Work started] (BEAM-9445) Preoptimize causes error with environment setup

[ https://issues.apache.org/jira/browse/BEAM-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9445 started by null. -- > Preoptimize causes error with environment se

[jira] [Updated] (BEAM-5192) Support Elasticsearch 7.x

[ https://issues.apache.org/jira/browse/BEAM-5192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-5192: Status: Triage Needed (was: Resolved) > Support Elasticsearch

[jira] [Updated] (BEAM-7310) Confluent Schema Registry support in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7310: Status: Triage Needed (was: Resolved) > Confluent Schema Registry support in Kafk

[jira] [Updated] (BEAM-8841) Add ability to perform BigQuery file loads using avro

[ https://issues.apache.org/jira/browse/BEAM-8841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8841: Status: Triage Needed (was: Resolved) > Add ability to perform BigQuery file loads using a

[jira] [Updated] (BEAM-9247) [Python] PTransform that integrates Cloud Vision functionality

[ https://issues.apache.org/jira/browse/BEAM-9247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9247: Status: Triage Needed (was: Resolved) > [Python] PTransform that integrates Cloud Vision functional

[jira] [Updated] (BEAM-9277) Beam 2.19 raises exception in IPython notebook

[ https://issues.apache.org/jira/browse/BEAM-9277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9277: Status: Triage Needed (was: Resolved) > Beam 2.19 raises exception in IPython noteb

[jira] [Updated] (BEAM-8616) ParquetIO should have Hadoop dependencies as provided

[ https://issues.apache.org/jira/browse/BEAM-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8616: Status: Triage Needed (was: Resolved) > ParquetIO should have Hadoop dependencies as provi

[jira] [Updated] (BEAM-8882) Allow Dataflow to automatically choose portability or not.

[ https://issues.apache.org/jira/browse/BEAM-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8882: Status: Triage Needed (was: Resolved) > Allow Dataflow to automatically choose portability or

[jira] [Updated] (BEAM-6857) Support dynamic timers

[ https://issues.apache.org/jira/browse/BEAM-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6857: Status: Triage Needed (was: Resolved) > Support dynamic tim

[jira] [Work started] (BEAM-9579) ApproximateQuantilesCombineFn uses deprecated '-' operator

[ https://issues.apache.org/jira/browse/BEAM-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9579 started by null. -- > ApproximateQuantilesCombineFn uses deprecated '-&#

[jira] [Work started] (BEAM-9322) Python SDK ignores manually set PCollection tags

[ https://issues.apache.org/jira/browse/BEAM-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9322 started by null. -- > Python SDK ignores manually set PCollection t

[jira] [Work started] (BEAM-7246) Add Google Spanner IO on Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-7246 started by null. -- > Add Google Spanner IO on Python

[jira] [Updated] (BEAM-9445) Preoptimize causes error with environment setup

[ https://issues.apache.org/jira/browse/BEAM-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9445: Status: Triage Needed (was: In Progress) > Preoptimize causes error with environment se

[jira] [Updated] (BEAM-9258) [Python] PTransform that connects to Cloud DLP deidentification service

[ https://issues.apache.org/jira/browse/BEAM-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9258: Status: Triage Needed (was: Resolved) > [Python] PTransform that connects to Cloud DLP deidentificat

[jira] [Updated] (BEAM-7246) Add Google Spanner IO on Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7246: Status: Triage Needed (was: In Progress) > Add Google Spanner IO on Python

[jira] [Updated] (BEAM-9146) [Python] PTransform that integrates Video Intelligence functionality

[ https://issues.apache.org/jira/browse/BEAM-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9146: Status: Triage Needed (was: Resolved) > [Python] PTransform that integrates Video Intellige

[jira] [Updated] (BEAM-9503) SyntaxError in process worker startup

[ https://issues.apache.org/jira/browse/BEAM-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9503: Status: Triage Needed (was: Resolved) > SyntaxError in process worker star

[jira] [Updated] (BEAM-9725) Perfomance regression in reshuffle

[ https://issues.apache.org/jira/browse/BEAM-9725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9725: Status: Triage Needed (was: Resolved) > Perfomance regression in reshuf

[jira] [Updated] (BEAM-9310) Make SpannerAccessor in Java package-private to reduce API surface

[ https://issues.apache.org/jira/browse/BEAM-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9310: Status: Triage Needed (was: Resolved) > Make SpannerAccessor in Java package-private to reduce API surf

[jira] [Updated] (BEAM-9225) Flink uber jar job server hangs

[ https://issues.apache.org/jira/browse/BEAM-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9225: Status: Triage Needed (was: Resolved) > Flink uber jar job server ha

[jira] [Updated] (BEAM-8550) @RequiresTimeSortedInput DoFn annotation

[ https://issues.apache.org/jira/browse/BEAM-8550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8550: Status: Triage Needed (was: Resolved) > @RequiresTimeSortedInput DoFn annotat

[jira] [Updated] (BEAM-8399) Python HDFS implementation should support filenames of the format "hdfs://namenodehost/parent/child"

[ https://issues.apache.org/jira/browse/BEAM-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8399: Status: Triage Needed (was: Resolved) > Python HDFS implementation should support filenames of the for

[jira] [Updated] (BEAM-8561) Add ThriftIO to Support IO for Thrift Files

[ https://issues.apache.org/jira/browse/BEAM-8561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8561: Status: Triage Needed (was: Resolved) > Add ThriftIO to Support IO for Thrift Fi

[jira] [Updated] (BEAM-8836) ExternalTransform is not providing a unique name

[ https://issues.apache.org/jira/browse/BEAM-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8836: Status: Triage Needed (was: Resolved) > ExternalTransform is not providing a unique n

[jira] [Updated] (BEAM-9063) Migrate docker images to apache namespace.

[ https://issues.apache.org/jira/browse/BEAM-9063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9063: Status: Triage Needed (was: Resolved) > Migrate docker images to apache namesp

[jira] [Updated] (BEAM-9305) Support ValueProvider for BigQuerySource query string

[ https://issues.apache.org/jira/browse/BEAM-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9305: Status: Triage Needed (was: Resolved) > Support ValueProvider for BigQuerySource query str

[jira] [Updated] (BEAM-9322) Python SDK ignores manually set PCollection tags

[ https://issues.apache.org/jira/browse/BEAM-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9322: Status: Triage Needed (was: In Progress) > Python SDK ignores manually set PCollection t

[jira] [Updated] (BEAM-9042) AvroUtils.schemaCoder(schema) produces a not serializable SchemaCoder

[ https://issues.apache.org/jira/browse/BEAM-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9042: Status: Triage Needed (was: Resolved) > AvroUtils.schemaCoder(schema) produces a not serializa

[jira] [Updated] (BEAM-9579) ApproximateQuantilesCombineFn uses deprecated '-' operator

[ https://issues.apache.org/jira/browse/BEAM-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9579: Status: Triage Needed (was: In Progress) > ApproximateQuantilesCombineFn uses deprecated '-&#

[jira] [Updated] (BEAM-9123) HadoopResourceId returns wrong directory name

[ https://issues.apache.org/jira/browse/BEAM-9123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9123: Status: Triage Needed (was: Resolved) > HadoopResourceId returns wrong directory n

[jira] [Updated] (BEAM-3453) Allow usage of public Google PubSub topics in Python DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-3453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-3453: Status: Triage Needed (was: Resolved) > Allow usage of public Google PubSub topics in Python DirectRun

[jira] [Updated] (BEAM-9144) Beam's own Avro TimeConversion class in beam-sdk-java-core

[ https://issues.apache.org/jira/browse/BEAM-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9144: Status: Triage Needed (was: Resolved) > Beam's own Avro TimeConversion class in beam-sdk-j

[jira] [Updated] (BEAM-9065) Spark runner accumulates metrics (incorrectly) between runs

[ https://issues.apache.org/jira/browse/BEAM-9065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9065: Status: Triage Needed (was: Resolved) > Spark runner accumulates metrics (incorrectly) between r

[jira] [Updated] (BEAM-9041) SchemaCoder equals should not rely on from/toRowFunction equality

[ https://issues.apache.org/jira/browse/BEAM-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9041: Status: Triage Needed (was: Resolved) > SchemaCoder equals should not rely on from/toRowFunction equal

[jira] [Updated] (BEAM-8480) Explicitly set restriction coder for bounded reader wrapper SDF.

[ https://issues.apache.org/jira/browse/BEAM-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8480: Status: Triage Needed (was: Resolved) > Explicitly set restriction coder for bounded reader wrapper

[jira] [Updated] (BEAM-8470) Create a new Spark runner based on Spark Structured streaming framework

[ https://issues.apache.org/jira/browse/BEAM-8470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8470: Status: Triage Needed (was: Resolved) > Create a new Spark runner based on Spark Structured stream

[jira] [Updated] (BEAM-8802) Timestamp combiner not respected across bundles in streaming mode.

[ https://issues.apache.org/jira/browse/BEAM-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8802: Status: Triage Needed (was: Resolved) > Timestamp combiner not respected across bundles in streaming m

[jira] [Updated] (BEAM-7981) ParDo function wrapper doesn't support Iterable output types

[ https://issues.apache.org/jira/browse/BEAM-7981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7981: Status: Triage Needed (was: Resolved) > ParDo function wrapper doesn't support Iterable outp

[jira] [Updated] (BEAM-8365) Add project push-down capability to IO APIs

[ https://issues.apache.org/jira/browse/BEAM-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8365: Status: Triage Needed (was: Resolved) > Add project push-down capability to IO A

[jira] [Updated] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

[ https://issues.apache.org/jira/browse/BEAM-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8803: Status: Triage Needed (was: Resolved) > Default behaviour for Python BQ Streaming inserts sink should

[jira] [Updated] (BEAM-8540) Fix CSVSink example in FileIO docs

[ https://issues.apache.org/jira/browse/BEAM-8540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8540: Status: Triage Needed (was: Resolved) > Fix CSVSink example in FileIO d

[jira] [Updated] (BEAM-8657) Not doing Combiner lifting for data-driven triggers

[ https://issues.apache.org/jira/browse/BEAM-8657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8657: Status: Triage Needed (was: Resolved) > Not doing Combiner lifting for data-driven trigg

[jira] [Updated] (BEAM-8427) [SQL] Add support for MongoDB source

[ https://issues.apache.org/jira/browse/BEAM-8427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8427: Status: Triage Needed (was: Resolved) > [SQL] Add support for MongoDB sou

[jira] [Updated] (BEAM-8658) Optionally set artifact staging port in FlinkUberJarJobServer

[ https://issues.apache.org/jira/browse/BEAM-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8658: Status: Triage Needed (was: Resolved) > Optionally set artifact staging port in FlinkUberJarJobSer

[jira] [Updated] (BEAM-6756) Support lazy iterables in schemas

[ https://issues.apache.org/jira/browse/BEAM-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6756: Status: Triage Needed (was: Resolved) > Support lazy iterables in sche

[jira] [Updated] (BEAM-8579) Strip UTF-8 BOM bytes (if present) in TextSource.

[ https://issues.apache.org/jira/browse/BEAM-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8579: Status: Triage Needed (was: Resolved) > Strip UTF-8 BOM bytes (if present) in TextSou

[jira] [Updated] (BEAM-8468) Add predicate/filter push-down capability to IO APIs

[ https://issues.apache.org/jira/browse/BEAM-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8468: Status: Triage Needed (was: Resolved) > Add predicate/filter push-down capability to IO A

[jira] [Updated] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange

[ https://issues.apache.org/jira/browse/BEAM-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8513: Status: Triage Needed (was: Resolved) > RabbitMqIO: Allow reads from exchange-bound queue with

[jira] [Updated] (BEAM-8456) Add pipeline option to control truncate of BigQuery data processed by Beam SQL

[ https://issues.apache.org/jira/browse/BEAM-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8456: Status: Triage Needed (was: Resolved) > Add pipeline option to control truncate of BigQuery data proces

[jira] [Updated] (BEAM-7078) Beam Dependency Update Request: com.amazonaws:amazon-kinesis-client

[ https://issues.apache.org/jira/browse/BEAM-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7078: Status: Triage Needed (was: Resolved) > Beam Dependency Update Request: com.amazonaws:amazon-kine

[jira] [Updated] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in

[ https://issues.apache.org/jira/browse/BEAM-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8347: Status: Triage Needed (was: Resolved) > UnboundedRabbitMqReader can fail to advance watermark if no

[jira] [Updated] (BEAM-8825) OOM when writing large numbers of 'narrow' rows

[ https://issues.apache.org/jira/browse/BEAM-8825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8825: Status: Triage Needed (was: Resolved) > OOM when writing large numbers of 'narr

[jira] [Updated] (BEAM-8835) Artifact retrieval fails with FlinkUberJarJobServer

[ https://issues.apache.org/jira/browse/BEAM-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8835: Status: Triage Needed (was: Resolved) > Artifact retrieval fails with FlinkUberJarJobSer

[jira] [Updated] (BEAM-8515) Ensure that ValueProvider types have equals/hashCode implemented for comparison reasons

[ https://issues.apache.org/jira/browse/BEAM-8515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8515: Status: Triage Needed (was: Resolved) > Ensure that ValueProvider types have equals/hashCode implemen

[jira] [Updated] (BEAM-8822) Upgrade Hadoop dependencies to version 2.8

[ https://issues.apache.org/jira/browse/BEAM-8822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8822: Status: Triage Needed (was: Resolved) > Upgrade Hadoop dependencies to version

[jira] [Updated] (BEAM-8660) Override returned artifact staging endpoint

[ https://issues.apache.org/jira/browse/BEAM-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8660: Status: Triage Needed (was: Resolved) > Override returned artifact staging endpo

[jira] [Updated] (BEAM-7636) Migrate SqsIO to AWS SDK for Java 2

[ https://issues.apache.org/jira/browse/BEAM-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7636: Status: Triage Needed (was: Resolved) > Migrate SqsIO to AWS SDK for Jav

[jira] [Updated] (BEAM-6303) Add .parquet extension to files in ParquetIO

[ https://issues.apache.org/jira/browse/BEAM-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6303: Status: Triage Needed (was: Resolved) > Add .parquet extension to files in Parque

[jira] [Updated] (BEAM-8814) --no_auth flag is boolean type and is misleading

[ https://issues.apache.org/jira/browse/BEAM-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8814: Status: Triage Needed (was: Resolved) > --no_auth flag is boolean type and is mislead

[jira] [Updated] (BEAM-8343) Add means for IO APIs to support predicate and/or project push-down when running SQL pipelines

[ https://issues.apache.org/jira/browse/BEAM-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8343: Status: Triage Needed (was: Resolved) > Add means for IO APIs to support predicate and/or project p

[jira] [Updated] (BEAM-8016) Render Beam Pipeline as DOT with Interactive Beam

[ https://issues.apache.org/jira/browse/BEAM-8016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8016: Status: Triage Needed (was: Resolved) > Render Beam Pipeline as DOT with Interactive B

[jira] [Updated] (BEAM-8252) (Python SDK) Add worker_region and worker_zone options

[ https://issues.apache.org/jira/browse/BEAM-8252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8252: Status: Triage Needed (was: Resolved) > (Python SDK) Add worker_region and worker_zone opti

[jira] [Updated] (BEAM-8667) Data channel should to avoid unlimited buffering in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8667: Status: Triage Needed (was: Resolved) > Data channel should to avoid unlimited buffering in Python

[jira] [Updated] (BEAM-8352) Reading records in background may lead to OOM errors

[ https://issues.apache.org/jira/browse/BEAM-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8352: Status: Triage Needed (was: Resolved) > Reading records in background may lead to OOM err

[jira] [Updated] (BEAM-8663) BundleBasedRunner Stacked Bundles don't respect PaneInfo

[ https://issues.apache.org/jira/browse/BEAM-8663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8663: Status: Triage Needed (was: Resolved) > BundleBasedRunner Stacked Bundles don't respect

[jira] [Updated] (BEAM-7917) Python datastore v1new fails on retry

[ https://issues.apache.org/jira/browse/BEAM-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7917: Status: Triage Needed (was: Resolved) > Python datastore v1new fails on re

[jira] [Updated] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

[ https://issues.apache.org/jira/browse/BEAM-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-5878: Status: Triage Needed (was: In Progress) > Support DoFns with Keyword-only arguments in Pytho

[jira] [Updated] (BEAM-4777) Python PortableRunner should support metrics

[ https://issues.apache.org/jira/browse/BEAM-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-4777: Status: Triage Needed (was: Resolved) > Python PortableRunner should support metr

[jira] [Updated] (BEAM-8508) [SQL] Support predicate push-down without project push-down

[ https://issues.apache.org/jira/browse/BEAM-8508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8508: Status: Triage Needed (was: Resolved) > [SQL] Support predicate push-down without project push-d

[jira] [Updated] (BEAM-7760) Interactive Beam Caching PCollections bound to user defined vars in notebook

[ https://issues.apache.org/jira/browse/BEAM-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7760: Status: Triage Needed (was: Resolved) > Interactive Beam Caching PCollections bound to user defined v

[jira] [Updated] (BEAM-8379) Cache Eviction for Interactive Beam

[ https://issues.apache.org/jira/browse/BEAM-8379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8379: Status: Triage Needed (was: Resolved) > Cache Eviction for Interactive B

[jira] [Updated] (BEAM-8254) (Java SDK) Add workerRegion and workerZone options

[ https://issues.apache.org/jira/browse/BEAM-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8254: Status: Triage Needed (was: Resolved) > (Java SDK) Add workerRegion and workerZone opti

[jira] [Work started] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

[ https://issues.apache.org/jira/browse/BEAM-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-5878 started by null. -- > Support DoFns with Keyword-only arguments in Pytho

[jira] [Updated] (BEAM-4776) Java PortableRunner should support metrics

[ https://issues.apache.org/jira/browse/BEAM-4776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-4776: Status: Triage Needed (was: Resolved) > Java PortableRunner should support metr

[jira] [Updated] (BEAM-8989) Backwards incompatible change in ParDo.getSideInputs (caught by failure when running Apache Nemo quickstart)

[ https://issues.apache.org/jira/browse/BEAM-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8989: Status: Triage Needed (was: Resolved) > Backwards incompatible change in ParDo.getSideInputs (caught

[jira] [Updated] (BEAM-8146) SchemaCoder/RowCoder have no equals() function

[ https://issues.apache.org/jira/browse/BEAM-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8146: Status: Triage Needed (was: Resolved) > SchemaCoder/RowCoder have no equals() funct

[jira] [Updated] (BEAM-8394) Add withDataSourceConfiguration() method in JdbcIO.ReadRows class

[ https://issues.apache.org/jira/browse/BEAM-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8394: Status: Triage Needed (was: Resolved) > Add withDataSourceConfiguration() method in JdbcIO.ReadRows cl

[jira] [Updated] (BEAM-7473) Update RestrictionTracker within Python to not be required to be thread safe

[ https://issues.apache.org/jira/browse/BEAM-7473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7473: Status: Triage Needed (was: Resolved) > Update RestrictionTracker within Python to not be required to

[jira] [Updated] (BEAM-8351) Support passing in arbitrary KV pairs to sdk worker via external environment config

[ https://issues.apache.org/jira/browse/BEAM-8351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8351: Status: Triage Needed (was: Resolved) > Support passing in arbitrary KV pairs to sdk worker via exter

[jira] [Updated] (BEAM-7962) Drop support for Flink 1.5 and 1.6

[ https://issues.apache.org/jira/browse/BEAM-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7962: Status: Triage Needed (was: Resolved) > Drop support for Flink 1.5 and

[jira] [Updated] (BEAM-8392) Update pyarrow version bounds

[ https://issues.apache.org/jira/browse/BEAM-8392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8392: Status: Triage Needed (was: Resolved) > Update pyarrow version bou

[jira] [Updated] (BEAM-8100) Add exception handling to Json transforms in Java SDK

[ https://issues.apache.org/jira/browse/BEAM-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8100: Status: Triage Needed (was: Resolved) > Add exception handling to Json transforms in Java

<    1   2   3   4   5   6   7   8   9   10   >