[jira] [Updated] (BEAM-4783) Add bundleSize parameter to control splitting of Spark sources (useful for Dynamic Allocation)

[ https://issues.apache.org/jira/browse/BEAM-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-4783: Status: Triage Needed (was: Resolved) > Add bundleSize parameter to control splitting of Spark sour

[jira] [Updated] (BEAM-14489) Make all TextIO SDF.

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

[jira] [Updated] (BEAM-14386) [Flink] Support for scala 2.12

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

[jira] [Updated] (BEAM-14160) Java expansion service does not recognize filesToStage argument

[ https://issues.apache.org/jira/browse/BEAM-14160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14160: - Status: Triage Needed (was: In Progress) > Java expansion service does not recognize filesToSt

[jira] [Updated] (BEAM-8218) Implement Apache PulsarIO

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

[jira] [Work started] (BEAM-11167) Beam Dependency Update Request: dill

[ https://issues.apache.org/jira/browse/BEAM-11167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-11167 started by null. --- > Beam Dependency Update Request: d

[jira] [Updated] (BEAM-13829) Expose status api from Go SDK Harness

[ https://issues.apache.org/jira/browse/BEAM-13829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13829: - Status: Triage Needed (was: Resolved) > Expose status api from Go SDK Harn

[jira] [Work started] (BEAM-14000) Elastic search IO doesnot work when both username/password and keystore are used

[ https://issues.apache.org/jira/browse/BEAM-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-14000 started by null. --- > Elastic search IO doesnot work when both username/password and keystore are >

[jira] [Updated] (BEAM-14000) Elastic search IO doesnot work when both username/password and keystore are used

[ https://issues.apache.org/jira/browse/BEAM-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14000: - Status: Triage Needed (was: In Progress) > Elastic search IO doesnot work when both username/passw

[jira] [Updated] (BEAM-14405) Java Spanner IO NPE when ProjectID not specified in template executions

[ https://issues.apache.org/jira/browse/BEAM-14405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14405: - Status: Triage Needed (was: Resolved) > Java Spanner IO NPE when ProjectID not specified in templ

[jira] [Updated] (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

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

[jira] [Updated] (BEAM-14112) ReadFromBigQuery cannot be used with the interactive runner

[ https://issues.apache.org/jira/browse/BEAM-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14112: - Status: Triage Needed (was: Resolved) > ReadFromBigQuery cannot be used with the interactive run

[jira] [Updated] (BEAM-13587) Use AwsRegionProvider to load region in AwsOptions if available

[ https://issues.apache.org/jira/browse/BEAM-13587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13587: - Status: Triage Needed (was: Resolved) > Use AwsRegionProvider to load region in AwsOptions if availa

[jira] [Updated] (BEAM-11106) [Go SDK] Truncating SDFs during drain

[ https://issues.apache.org/jira/browse/BEAM-11106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11106: - Status: Triage Needed (was: Resolved) > [Go SDK] Truncating SDFs during dr

[jira] [Updated] (BEAM-13948) Implement DataFrame.unstack() and Series.unstack() for DataFrame API

[ https://issues.apache.org/jira/browse/BEAM-13948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13948: - Status: Triage Needed (was: Resolved) > Implement DataFrame.unstack() and Series.unstack()

[jira] [Updated] (BEAM-13739) [Go SDK] Remove deprecated shallow copy functions

[ https://issues.apache.org/jira/browse/BEAM-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13739: - Status: Triage Needed (was: Resolved) > [Go SDK] Remove deprecated shallow copy functi

[jira] [Updated] (BEAM-1857) Add Neo4jIO

[ https://issues.apache.org/jira/browse/BEAM-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-1857: Status: Open (was: Triage Needed) > Add Neo4jIO > --- > > Ke

[jira] [Updated] (BEAM-14133) Fix potential NPE in BigQueryServicesImpl.getErrorInfo

[ https://issues.apache.org/jira/browse/BEAM-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14133: - Status: Triage Needed (was: Resolved) > Fix potential NPE in BigQueryServicesImpl.getErrorI

[jira] [Updated] (BEAM-14143) ExternalPythonTransform API for easily invoking Python transforms from Java

[ https://issues.apache.org/jira/browse/BEAM-14143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14143: - Status: Triage Needed (was: Resolved) > ExternalPythonTransform API for easily invoking Pyt

[jira] [Updated] (BEAM-14351) Example 'JsonCoder' object has no attribute 'to_type_hint'

[ https://issues.apache.org/jira/browse/BEAM-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14351: - Status: Triage Needed (was: Resolved) > Example 'JsonCoder' object has no attribute

[jira] [Updated] (BEAM-13657) Sunset Python 3.6 support in Beam

[ https://issues.apache.org/jira/browse/BEAM-13657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13657: - Status: Triage Needed (was: Resolved) > Sunset Python 3.6 support in B

[jira] [Updated] (BEAM-14139) Drop support for Flink 1.11

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

[jira] [Updated] (BEAM-14128) Quadratic behavior in go pipeline rewriting.

[ https://issues.apache.org/jira/browse/BEAM-14128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14128: - Status: Triage Needed (was: Resolved) > Quadratic behavior in go pipeline rewrit

[jira] [Updated] (BEAM-13563) Generalize AWS client provider to be independent of client type

[ https://issues.apache.org/jira/browse/BEAM-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13563: - Status: Triage Needed (was: Resolved) > Generalize AWS client provider to be independent of client t

[jira] [Updated] (BEAM-14235) parquetio module does not parse PEP-440 compliant Pyarrow version

[ https://issues.apache.org/jira/browse/BEAM-14235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14235: - Status: Triage Needed (was: Resolved) > parquetio module does not parse PEP-440 compliant Pyar

[jira] [Updated] (BEAM-13966) Implement DataFrame.pivot() for DataFrame API

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

[jira] [Updated] (BEAM-14104) Shard aware Kinesis record aggregation (AWS Sdk v2)

[ https://issues.apache.org/jira/browse/BEAM-14104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14104: - Status: Triage Needed (was: Resolved) > Shard aware Kinesis record aggregation (AWS Sdk

[jira] [Updated] (BEAM-14130) Implement Jupyterlab extension for managing Dataproc clusters

[ https://issues.apache.org/jira/browse/BEAM-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14130: - Status: Triage Needed (was: Resolved) > Implement Jupyterlab extension for managing Dataproc clust

[jira] [Updated] (BEAM-14314) Add last_updated field in filesystem.FileMetaData

[ https://issues.apache.org/jira/browse/BEAM-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14314: - Status: Triage Needed (was: Resolved) > Add last_updated field in filesystem.FileMetaD

[jira] [Updated] (BEAM-14011) AWS SDK2 S3FileSystem MultiPart Copy sets incorrect request parameters

[ https://issues.apache.org/jira/browse/BEAM-14011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14011: - Status: Triage Needed (was: Resolved) > AWS SDK2 S3FileSystem MultiPart Copy sets incorrect requ

[jira] [Updated] (BEAM-14283) Reduce number of threads spawned by BigqueryIO StreamingInserts

[ https://issues.apache.org/jira/browse/BEAM-14283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-14283: - Status: Triage Needed (was: Resolved) > Reduce number of threads spawned by BigqueryIO StreamingInse

[jira] [Updated] (BEAM-13860) ParDo.infer_output_type expects DoFn.infer_output_type to return Iterable of element_type

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

[jira] [Updated] (BEAM-4032) Support staging binary distributions of dependency packages.

[ https://issues.apache.org/jira/browse/BEAM-4032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-4032: Status: Triage Needed (was: Resolved) > Support staging binary distributions of dependency packa

[jira] [Updated] (BEAM-13441) Use quiet mode for batch deletes in AWS S3FileSystem

[ https://issues.apache.org/jira/browse/BEAM-13441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13441: - Status: Triage Needed (was: Resolved) > Use quiet mode for batch deletes in AWS S3FileSys

[jira] [Updated] (BEAM-14014) Support impersonation credentials in Dataflow runner.

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

[jira] [Updated] (BEAM-13246) Add support for S3 Bucket Key at the object level (AWS SDK v2)

[ https://issues.apache.org/jira/browse/BEAM-13246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13246: - Status: Triage Needed (was: Resolved) > Add support for S3 Bucket Key at the object level (AWS SDK

[jira] [Updated] (BEAM-13663) Fix AWS client configuration in AwsModule

[ https://issues.apache.org/jira/browse/BEAM-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13663: - Status: Triage Needed (was: Resolved) > Fix AWS client configuration in AwsMod

[jira] [Updated] (BEAM-13631) SQS read IO requires deterministic coder for SQS message to work in batch mode mode.

[ https://issues.apache.org/jira/browse/BEAM-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13631: - Status: Triage Needed (was: Resolved) > SQS read IO requires deterministic coder for SQS message

[jira] [Updated] (BEAM-13245) Generalize S3FileSystem to support multiple URI schemes (AWS SDK v2)

[ https://issues.apache.org/jira/browse/BEAM-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13245: - Status: Triage Needed (was: Resolved) > Generalize S3FileSystem to support multiple URI schemes (

[jira] [Work stopped] (BEAM-13174) Deprecate amazon-web-services & kinesis module (SDK v1)

[ https://issues.apache.org/jira/browse/BEAM-13174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-13174 stopped by null. --- > Deprecate amazon-web-services & kinesis module

[jira] [Updated] (BEAM-14071) Enabling Flink on Dataproc for Interactive Beam

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

[jira] [Updated] (BEAM-13174) Deprecate amazon-web-services & kinesis module (SDK v1)

[ https://issues.apache.org/jira/browse/BEAM-13174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13174: - Status: Triage Needed (was: Open) > Deprecate amazon-web-services & kinesis module

[jira] [Updated] (BEAM-13106) Add support for Flink 1.14

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

[jira] [Updated] (BEAM-13510) SQS reader retries on invalid (expired) receipt handles (AWS SDK v2)

[ https://issues.apache.org/jira/browse/BEAM-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13510: - Status: Triage Needed (was: Resolved) > SQS reader retries on invalid (expired) receipt handles (

[jira] [Updated] (BEAM-14348) Upgrade to ZetaSQL 2022.04.1

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

[jira] [Updated] (BEAM-13209) DynamoDBIO silently drops unprocessed items

[ https://issues.apache.org/jira/browse/BEAM-13209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13209: - Status: Triage Needed (was: Resolved) > DynamoDBIO silently drops unprocessed it

[jira] [Updated] (BEAM-14003) Add support for Elasticsearch 8.x

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

[jira] [Updated] (BEAM-13445) Fix chunked encoding for S3WritableButeChannel

[ https://issues.apache.org/jira/browse/BEAM-13445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13445: - Status: Triage Needed (was: Resolved) > Fix chunked encoding for S3WritableButeChan

[jira] [Updated] (BEAM-13175) Implement missing KinesisIO.Write for aws2

[ https://issues.apache.org/jira/browse/BEAM-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13175: - Status: Triage Needed (was: Resolved) > Implement missing KinesisIO.Write for a

[jira] [Updated] (BEAM-12976) Projection pushdown in Beam Java

[ https://issues.apache.org/jira/browse/BEAM-12976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12976: - Status: Triage Needed (was: Resolved) > Projection pushdown in Beam J

[jira] [Updated] (BEAM-11703) Support apache-beam python install on ARM64

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

[jira] [Updated] (BEAM-13421) Python DeferredDataFrame.xs differs from Pandas

[ https://issues.apache.org/jira/browse/BEAM-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13421: - Status: Triage Needed (was: Resolved) > Python DeferredDataFrame.xs differs from Pan

[jira] [Updated] (BEAM-13821) [Go SDK] Add automated expansion service start-up to KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13821: - Status: Triage Needed (was: Resolved) > [Go SDK] Add automated expansion service start-up to Kafk

[jira] [Work started] (BEAM-13695) Provide more accurate size estimates for cache objects in Java 17

[ https://issues.apache.org/jira/browse/BEAM-13695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-13695 started by Kiley Sok. > Provide more accurate size estimates for cache objects in Java

[jira] [Updated] (BEAM-12865) Allow customising batch duration when streaming with WriteToBigQuery

[ https://issues.apache.org/jira/browse/BEAM-12865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12865: - Status: Triage Needed (was: Resolved) > Allow customising batch duration when streaming w

[jira] [Updated] (BEAM-13757) Pane observation in user DoFN

[ https://issues.apache.org/jira/browse/BEAM-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13757: - Status: Triage Needed (was: Resolved) > Pane observation in user D

[jira] [Updated] (BEAM-13732) [Cross-Language] Implement Go SDK wrapper for xlang BigQuery IO

[ https://issues.apache.org/jira/browse/BEAM-13732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13732: - Status: Triage Needed (was: Resolved) > [Cross-Language] Implement Go SDK wrapper for xlang BigQuery

[jira] [Updated] (BEAM-13683) Implement cross-language SQL in the Go SDK

[ https://issues.apache.org/jira/browse/BEAM-13683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13683: - Status: Triage Needed (was: Resolved) > Implement cross-language SQL in the Go

[jira] [Updated] (BEAM-13293) Go SDK JDBC IO XLang Transform

[ https://issues.apache.org/jira/browse/BEAM-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13293: - Status: Triage Needed (was: Resolved) > Go SDK JDBC IO XLang Transf

[jira] [Updated] (BEAM-13761) Xlang Debezium IO wrapper for Go SDK

[ https://issues.apache.org/jira/browse/BEAM-13761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13761: - Status: Triage Needed (was: Resolved) > Xlang Debezium IO wrapper for Go

[jira] [Updated] (BEAM-13605) Support pandas 1.4.0 in the DataFrame API

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

[jira] [Updated] (BEAM-8123) Support CloudPickle as pickler for Apache Beam.

[ https://issues.apache.org/jira/browse/BEAM-8123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8123: Status: Triage Needed (was: Resolved) > Support CloudPickle as pickler for Apache B

[jira] [Updated] (BEAM-13864) Add Dataflow v1 Python 3.9 tests, once the runner supports it.

[ https://issues.apache.org/jira/browse/BEAM-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13864: - Status: Triage Needed (was: Resolved) > Add Dataflow v1 Python 3.9 tests, once the runner supports

[jira] [Updated] (BEAM-3293) Add lazy map side input form

[ https://issues.apache.org/jira/browse/BEAM-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-3293: Status: Triage Needed (was: Resolved) > Add lazy map side input f

[jira] [Updated] (BEAM-12931) Timer.setOutputTimestamp doesn't take into account for DoFn#getAllowedTimestampSkew()

[ https://issues.apache.org/jira/browse/BEAM-12931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12931: - Status: Triage Needed (was: Resolved) > Timer.setOutputTimestamp doesn't take into account for

[jira] [Updated] (BEAM-5378) Ensure all Go SDK examples run successfully

[ https://issues.apache.org/jira/browse/BEAM-5378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-5378: Status: Triage Needed (was: Resolved) > Ensure all Go SDK examples run successfu

[jira] [Updated] (BEAM-13980) S3 Client broken: missing get_object_metadata()

[ https://issues.apache.org/jira/browse/BEAM-13980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13980: - Status: Triage Needed (was: Resolved) > S3 Client broken: missing get_object_metad

[jira] [Updated] (BEAM-13695) Provide more accurate size estimates for cache objects in Java 17

[ https://issues.apache.org/jira/browse/BEAM-13695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13695: - Status: Triage Needed (was: In Progress) > Provide more accurate size estimates for cache objects

[jira] [Updated] (BEAM-12000) Support Python 3.9 in Apache Beam

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

[jira] [Updated] (BEAM-13459) Dataflow python runner should cache uploaded artifacts across job runs

[ https://issues.apache.org/jira/browse/BEAM-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13459: - Status: Triage Needed (was: Resolved) > Dataflow python runner should cache uploaded artifacts acr

[jira] [Work started] (BEAM-12092) Beam Dependency Update Request: redis.clients:jedis

[ https://issues.apache.org/jira/browse/BEAM-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-12092 started by null. --- > Beam Dependency Update Request: redis.clients:je

[jira] [Updated] (BEAM-12240) Make Beam compatible with next Java LTS version (Java 17)

[ https://issues.apache.org/jira/browse/BEAM-12240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12240: - Status: Triage Needed (was: Resolved) > Make Beam compatible with next Java LTS version (Java

[jira] [Updated] (BEAM-13638) SqsMessage class have package private access for getters

[ https://issues.apache.org/jira/browse/BEAM-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13638: - Status: Triage Needed (was: Resolved) > SqsMessage class have package private access for gett

[jira] [Updated] (BEAM-13171) Support for stopReadTime on KafkaIO SDF

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

[jira] [Updated] (BEAM-12092) Beam Dependency Update Request: redis.clients:jedis

[ https://issues.apache.org/jira/browse/BEAM-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12092: - Status: Triage Needed (was: In Progress) > Beam Dependency Update Request: redis.clients:je

[jira] [Updated] (BEAM-12906) Track DataFrame pandas requirement separately

[ https://issues.apache.org/jira/browse/BEAM-12906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12906: - Status: Triage Needed (was: Resolved) > Track DataFrame pandas requirement separat

[jira] [Updated] (BEAM-12601) Support append-only indices in ES output

[ https://issues.apache.org/jira/browse/BEAM-12601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12601: - Status: Triage Needed (was: Resolved) > Support append-only indices in ES out

[jira] [Updated] (BEAM-13189) Add escapechar to Python TextIO reads

[ https://issues.apache.org/jira/browse/BEAM-13189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13189: - Status: Triage Needed (was: Resolved) > Add escapechar to Python TextIO re

[jira] [Updated] (BEAM-13001) DoFn Execution time metrics (msecs) for Go SDK

[ https://issues.apache.org/jira/browse/BEAM-13001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13001: - Status: Triage Needed (was: Resolved) > DoFn Execution time metrics (msecs) for Go

[jira] [Updated] (BEAM-12946) [Go SDK] SmallestPerKey transform is broken, needs testing

[ https://issues.apache.org/jira/browse/BEAM-12946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12946: - Status: Triage Needed (was: Resolved) > [Go SDK] SmallestPerKey transform is broken, needs test

[jira] [Updated] (BEAM-12950) Missing events when using Python WriteToFiles in streaming pipeline

[ https://issues.apache.org/jira/browse/BEAM-12950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12950: - Status: Triage Needed (was: Resolved) > Missing events when using Python WriteToFiles in stream

[jira] [Updated] (BEAM-13099) Upgrade vendored Calcite to 1.28.0

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

[jira] [Updated] (BEAM-11275) Support GCS files for extra_requirements argument in Python Beam portable runners

[ https://issues.apache.org/jira/browse/BEAM-11275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11275: - Status: Triage Needed (was: Open) > Support GCS files for extra_requirements argument in Python B

[jira] [Updated] (BEAM-5505) Disable Row flattening in Apache Calcite

[ https://issues.apache.org/jira/browse/BEAM-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-5505: Status: Triage Needed (was: Resolved) > Disable Row flattening in Apache Calc

[jira] [Updated] (BEAM-13499) beam-sdks-java-io-hcatalog and beam-sdks-java-extensions-sql-hcatalog are vulnerable to CVE-2021-44228

[ https://issues.apache.org/jira/browse/BEAM-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13499: - Status: Triage Needed (was: In Progress) > beam-sdks-java-io-hcatalog and beam-sdks-java-extensions-

[jira] [Work started] (BEAM-13499) beam-sdks-java-io-hcatalog and beam-sdks-java-extensions-sql-hcatalog are vulnerable to CVE-2021-44228

[ https://issues.apache.org/jira/browse/BEAM-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-13499 started by null. --- > beam-sdks-java-io-hcatalog and beam-sdks-java-extensions-sql-hcatalog are > vulnerable

[jira] [Updated] (BEAM-9379) Upgrade to Calcite 1.26.0

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

[jira] [Updated] (BEAM-12047) Create a URN convention for cross-language transforms

[ https://issues.apache.org/jira/browse/BEAM-12047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12047: - Status: Triage Needed (was: Resolved) > Create a URN convention for cross-language transfo

[jira] [Updated] (BEAM-9918) Cross-language transforms support for Go SDK

[ https://issues.apache.org/jira/browse/BEAM-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9918: Status: Triage Needed (was: Resolved) > Cross-language transforms support for Go

[jira] [Updated] (BEAM-11087) [Go SDK] Validate Side Input behavior WRT windows

[ https://issues.apache.org/jira/browse/BEAM-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11087: - Status: Triage Needed (was: Resolved) > [Go SDK] Validate Side Input behavior WRT wind

[jira] [Updated] (BEAM-12456) Querying table in parallel  in JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12456: - Status: Triage Needed (was: Resolved) > Querying table in parallel  in Jdb

[jira] [Updated] (BEAM-12435) Generalize S3FileSystem

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

[jira] [Updated] (BEAM-12225) Replace AWS API used to list shards from DescribeStream to ListShards

[ https://issues.apache.org/jira/browse/BEAM-12225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12225: - Status: Triage Needed (was: Resolved) > Replace AWS API used to list shards from DescribeStream

[jira] [Updated] (BEAM-12759) ORDER BY column not in SELECT crashes

[ https://issues.apache.org/jira/browse/BEAM-12759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12759: - Status: Triage Needed (was: Resolved) > ORDER BY column not in SELECT cras

[jira] [Updated] (BEAM-12385) AvroUtils exception when converting JDBC Row to GenericRecord

[ https://issues.apache.org/jira/browse/BEAM-12385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12385: - Status: Triage Needed (was: Resolved) > AvroUtils exception when converting JDBC Row to GenericRec

[jira] [Updated] (BEAM-12609) Projection pushdown in SchemaIO

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

[jira] [Updated] (BEAM-12511) JdbcIO.Write.withResults work without statement

[ https://issues.apache.org/jira/browse/BEAM-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12511: - Status: Triage Needed (was: Resolved) > JdbcIO.Write.withResults work without statem

[jira] [Updated] (BEAM-13009) DynamoDBIO misses writing items if `withDeduplicateKeys` is not set

[ https://issues.apache.org/jira/browse/BEAM-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13009: - Status: Triage Needed (was: Resolved) > DynamoDBIO misses writing items if `withDeduplicateKeys` is

[jira] [Updated] (BEAM-10917) Implement a BigQuery bounded source using the BigQuery storage API

[ https://issues.apache.org/jira/browse/BEAM-10917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-10917: - Status: Triage Needed (was: In Progress) > Implement a BigQuery bounded source using the BigQu

[jira] [Updated] (BEAM-13149) JdbcIO.readWithPartitions supports only int ranges

[ https://issues.apache.org/jira/browse/BEAM-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13149: - Status: Triage Needed (was: Resolved) > JdbcIO.readWithPartitions supports only int ran

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