[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

[jira] [Updated] (BEAM-8285) Upgrade to ZetaSQL 2019.09.1

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

[jira] [Updated] (BEAM-8014) Use OffsetRange as restriction for OffsetRestrictionTracker

[ https://issues.apache.org/jira/browse/BEAM-8014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8014: Status: Triage Needed (was: Resolved) > Use OffsetRange as restriction for OffsetRestrictionTrac

[jira] [Updated] (BEAM-8312) Flink portable pipeline jars do not need to stage artifacts remotely

[ https://issues.apache.org/jira/browse/BEAM-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8312: Status: Triage Needed (was: Resolved) > Flink portable pipeline jars do not need to stage artifa

[jira] [Updated] (BEAM-8299) Upgrade Jackson to version 2.9.10

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

[jira] [Updated] (BEAM-8355) Make BooleanCoder a standard coder

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

[jira] [Updated] (BEAM-8303) Filesystems not properly registered using FileIO.write() on FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-8303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8303: Status: Triage Needed (was: Resolved) > Filesystems not properly registered using FileIO.write()

[jira] [Updated] (BEAM-8861) Disallow self-signed certificates by default in ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8861: Status: Triage Needed (was: Resolved) > Disallow self-signed certificates by default in Elasticsearc

[jira] [Updated] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster.

[ https://issues.apache.org/jira/browse/BEAM-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8372: Status: Triage Needed (was: Resolved) > Allow submission of Flink UberJar directly to flink clus

[jira] [Work started] (BEAM-5895) Beam Dependency Update Request: com.rabbitmq:amqp-client

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

[jira] [Updated] (BEAM-7990) Add ability to read parquet files into PCollection

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

[jira] [Updated] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9

[ https://issues.apache.org/jira/browse/BEAM-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7730: Status: Triage Needed (was: Resolved) > Add Flink 1.9 build target and Make FlinkRunner compatible w

[jira] [Updated] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Updated] (BEAM-8088) PCollection boundedness should be tracked and propagated in python sdk

[ https://issues.apache.org/jira/browse/BEAM-8088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8088: Status: Triage Needed (was: Resolved) > PCollection boundedness should be tracked and propagated in pyt

[jira] [Updated] (BEAM-8410) JdbcIO should support setConnectionInitSqls in its DataSource

[ https://issues.apache.org/jira/browse/BEAM-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8410: Status: Triage Needed (was: Resolved) > JdbcIO should support setConnectionInitSqls in its DataSou

[jira] [Work started] (BEAM-8363) Nexmark regression in direct runner in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-8363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-8363 started by null. -- > Nexmark regression in direct runner in streaming m

[jira] [Updated] (BEAM-8161) Upgrade to joda time 2.10.3 to get updated TZDB

[ https://issues.apache.org/jira/browse/BEAM-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8161: Status: Triage Needed (was: Resolved) > Upgrade to joda time 2.10.3 to get updated T

[jira] [Updated] (BEAM-8015) Get logs for SDK worker Docker containers

[ https://issues.apache.org/jira/browse/BEAM-8015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8015: Status: Triage Needed (was: Resolved) > Get logs for SDK worker Docker contain

[jira] [Updated] (BEAM-7588) Python BigQuery sink should be able to handle 15TB load job quota

[ https://issues.apache.org/jira/browse/BEAM-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7588: Status: Triage Needed (was: Resolved) > Python BigQuery sink should be able to handle 15TB load job qu

[jira] [Updated] (BEAM-7966) Write portable Beam application jar

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

[jira] [Updated] (BEAM-8396) Default to LOOPBACK mode for local flink (spark, ...) runner.

[ https://issues.apache.org/jira/browse/BEAM-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8396: Status: Triage Needed (was: Resolved) > Default to LOOPBACK mode for local flink (spark, ...) run

[jira] [Updated] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8306: Status: Triage Needed (was: Resolved) > improve estimation of data byte size reading from source

[jira] [Updated] (BEAM-8183) Optionally bundle multiple pipelines into a single Flink jar

[ https://issues.apache.org/jira/browse/BEAM-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8183: Status: Triage Needed (was: Resolved) > Optionally bundle multiple pipelines into a single Flink

[jira] [Updated] (BEAM-6480) Add AvroIO.sink for IndexedRecord (FileIO compatible)

[ https://issues.apache.org/jira/browse/BEAM-6480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6480: Status: Triage Needed (was: Resolved) > Add AvroIO.sink for IndexedRecord (FileIO compati

[jira] [Updated] (BEAM-7967) Execute portable Flink application jar

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

[jira] [Updated] (BEAM-8471) Flink native job submission for portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-8471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8471: Status: Triage Needed (was: Resolved) > Flink native job submission for portable pipeli

[jira] [Updated] (BEAM-7920) AvroTableProvider

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

[jira] [Updated] (BEAM-7820) Add hot key detection to Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7820: Status: Triage Needed (was: Resolved) > Add hot key detection to Dataflow Run

[jira] [Updated] (BEAM-7635) Migrate SnsIO to AWS SDK for Java 2

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

[jira] [Updated] (BEAM-8609) Add HllCount to Java transform catalog

[ https://issues.apache.org/jira/browse/BEAM-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8609: Status: Triage Needed (was: Resolved) > Add HllCount to Java transform cata

[jira] [Updated] (BEAM-7616) urlopen calls could get stuck without a timeout

[ https://issues.apache.org/jira/browse/BEAM-7616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7616: Status: Triage Needed (was: Resolved) > urlopen calls could get stuck without a time

[jira] [Updated] (BEAM-8363) Nexmark regression in direct runner in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-8363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8363: Status: Triage Needed (was: In Progress) > Nexmark regression in direct runner in streaming m

[jira] [Updated] (BEAM-7045) Element counters in the Web UI graph representations for transforms for Python streaming jobs in Google Cloud Dataflow

[ https://issues.apache.org/jira/browse/BEAM-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7045: Status: Triage Needed (was: Resolved) > Element counters in the Web UI graph representations

[jira] [Updated] (BEAM-7880) Upgrade Jackson databind to version 2.9.9.3

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

[jira] [Updated] (BEAM-8098) BigQueryIO needs documentation on how data types in BigQuery and in Beam SDK correspond

[ https://issues.apache.org/jira/browse/BEAM-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8098: Status: Triage Needed (was: Resolved) > BigQueryIO needs documentation on how data types in BigQuery

[jira] [Updated] (BEAM-7866) Python MongoDB IO performance and correctness issues

[ https://issues.apache.org/jira/browse/BEAM-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7866: Status: Triage Needed (was: Resolved) > Python MongoDB IO performance and correctness iss

[jira] [Updated] (BEAM-8111) SchemaCoder broken on DataflowRunner

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

[jira] [Updated] (BEAM-6896) Beam Dependency Update Request: PyYAML

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

[jira] [Updated] (BEAM-6114) SQL join selection should be done in planner, not in expansion to PTransform

[ https://issues.apache.org/jira/browse/BEAM-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6114: Status: Triage Needed (was: Resolved) > SQL join selection should be done in planner, not in expansion

[jira] [Updated] (BEAM-7450) Support unbounded reads with HCatalogIO

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

[jira] [Updated] (BEAM-5967) ProtoCoder doesn't support DynamicMessage

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

[jira] [Updated] (BEAM-3645) Support multi-process execution on the FnApiRunner

[ https://issues.apache.org/jira/browse/BEAM-3645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-3645: Status: Triage Needed (was: Resolved) > Support multi-process execution on the FnApiRun

[jira] [Updated] (BEAM-7728) Support ParquetTable Source in SQL

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

[jira] [Updated] (BEAM-7667) report GCS throttling time to Dataflow autoscaler

[ https://issues.apache.org/jira/browse/BEAM-7667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7667: Status: Triage Needed (was: Resolved) > report GCS throttling time to Dataflow autosca

[jira] [Updated] (BEAM-7986) Increase minimum grpcio required version

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

[jira] [Updated] (BEAM-7980) External environment with containerized worker pool

[ https://issues.apache.org/jira/browse/BEAM-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7980: Status: Triage Needed (was: Resolved) > External environment with containerized worker p

[jira] [Updated] (BEAM-8324) Pre/Postcommit Dataflow IT tests fail: _create_function() takes from 2 to 6 positional arguments but 7 were given

[ https://issues.apache.org/jira/browse/BEAM-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8324: Status: Triage Needed (was: Resolved) > Pre/Postcommit Dataflow IT tests fail: _create_function() ta

[jira] [Updated] (BEAM-7465) Upgrade Jackson to version 2.9.9

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

[jira] [Updated] (BEAM-7561) HdfsFileSystem is unable to match a directory

[ https://issues.apache.org/jira/browse/BEAM-7561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7561: Status: Triage Needed (was: Resolved) > HdfsFileSystem is unable to match a direct

[jira] [Updated] (BEAM-8368) [Python] libprotobuf-generated exception when importing apache_beam

[ https://issues.apache.org/jira/browse/BEAM-8368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8368: Status: Triage Needed (was: Resolved) > [Python] libprotobuf-generated exception when import

[jira] [Updated] (BEAM-562) DoFn Reuse: Add new DoFn setup and teardown to python SDK

[ https://issues.apache.org/jira/browse/BEAM-562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-562: --- Status: Triage Needed (was: Resolved) > DoFn Reuse: Add new DoFn setup and teardown to python

[jira] [Updated] (BEAM-7194) [SQL] EXCEPT DISTINCT behavior when right set contains a value is incorrect

[ https://issues.apache.org/jira/browse/BEAM-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7194: Status: Triage Needed (was: Resolved) > [SQL] EXCEPT DISTINCT behavior when right set contains a value

[jira] [Updated] (BEAM-6674) The JdbcIO source should produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6674: Status: Triage Needed (was: Resolved) > The JdbcIO source should produce sche

[jira] [Updated] (BEAM-7144) Job re-scale fails on Flink >= 1.6 with certain values of maxParallelism

[ https://issues.apache.org/jira/browse/BEAM-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7144: Status: Triage Needed (was: Resolved) > Job re-scale fails on Flink >= 1.6 with certain val

[jira] [Updated] (BEAM-7265) Update Spark runner to use spark version 2.4.3

[ https://issues.apache.org/jira/browse/BEAM-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7265: Status: Triage Needed (was: Resolved) > Update Spark runner to use spark version 2.

[jira] [Updated] (BEAM-6872) Add hook for user-defined JVM initialization in workers

[ https://issues.apache.org/jira/browse/BEAM-6872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6872: Status: Triage Needed (was: Resolved) > Add hook for user-defined JVM initialization in work

[jira] [Updated] (BEAM-6730) Enable configuration of Java transforms (specifically IO) through other SDKs

[ https://issues.apache.org/jira/browse/BEAM-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6730: Status: Triage Needed (was: Resolved) > Enable configuration of Java transforms (specifically IO) thro

[jira] [Updated] (BEAM-7263) Deprecate set/getClientConfiguration in JdbcIO

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

[jira] [Updated] (BEAM-7305) Add first version of Hazelcast Jet Runner

[ https://issues.apache.org/jira/browse/BEAM-7305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7305: Status: Triage Needed (was: Resolved) > Add first version of Hazelcast Jet Run

[jira] [Updated] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Updated] (BEAM-7021) ToString transform for Python SDK

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

[jira] [Updated] (BEAM-7043) Add DynamoDBIO

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

[jira] [Updated] (BEAM-6620) Do not relocate guava

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

[jira] [Updated] (BEAM-7348) Option to expire SDK worker environments

[ https://issues.apache.org/jira/browse/BEAM-7348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7348: Status: Triage Needed (was: Resolved) > Option to expire SDK worker environme

[jira] [Updated] (BEAM-6673) BigQueryIO.Read should automatically produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6673: Status: Triage Needed (was: Resolved) > BigQueryIO.Read should automatically produce sche

[jira] [Work started] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub

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

[jira] [Updated] (BEAM-7742) BigQuery File Loads to work well with load job size limits

[ https://issues.apache.org/jira/browse/BEAM-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7742: Status: Triage Needed (was: Resolved) > BigQuery File Loads to work well with load job size lim

[jira] [Updated] (BEAM-7060) Design Py3-compatible typehints annotation support in Beam 3.

[ https://issues.apache.org/jira/browse/BEAM-7060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7060: Status: Triage Needed (was: Resolved) > Design Py3-compatible typehints annotation support in Bea

[jira] [Updated] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub

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

[jira] [Updated] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation

[ https://issues.apache.org/jira/browse/BEAM-7013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7013: Status: Triage Needed (was: Resolved) > A new count distinct transform based on BigQuery compati

[jira] [Updated] (BEAM-7894) Upgrade "com.amazonaws:amazon-kinesis-producer" to version 0.13.1

[ https://issues.apache.org/jira/browse/BEAM-7894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7894: Status: Triage Needed (was: Resolved) > Upgrade "com.amazonaws:amazon-kinesis-producer" to v

[jira] [Updated] (BEAM-7907) Support customized container

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

[jira] [Updated] (BEAM-7600) Spark portable runner: reuse SDK harness

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

[jira] [Updated] (BEAM-7741) Add SetState in Python sdk

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

[jira] [Updated] (BEAM-7927) Add ability to get the list of submitted jobs from gRPC JobService

[ https://issues.apache.org/jira/browse/BEAM-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7927: Status: Triage Needed (was: Resolved) > Add ability to get the list of submitted jobs from gRPC JobServ

[jira] [Updated] (BEAM-7761) Support transform_name_mapping option in python sdk

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

[jira] [Updated] (BEAM-7513) [SQL] Row Estimation for BigQueryTable

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

[jira] [Updated] (BEAM-6611) A Python Sink for BigQuery with File Loads in Streaming

[ https://issues.apache.org/jira/browse/BEAM-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6611: Status: Triage Needed (was: Resolved) > A Python Sink for BigQuery with File Loads in Stream

[jira] [Updated] (BEAM-7833) warn user when --region flag is not explicitly set

[ https://issues.apache.org/jira/browse/BEAM-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7833: Status: Triage Needed (was: Resolved) > warn user when --region flag is not explicitly

[jira] [Updated] (BEAM-7603) Support for ValueProvider-given GCS Location for WriteToBigQuery w File Loads

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

[jira] [Updated] (BEAM-5191) Add support for writing to BigQuery clustered tables

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

[jira] [Updated] (BEAM-6675) The JdbcIO sink should accept schemas

[ https://issues.apache.org/jira/browse/BEAM-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6675: Status: Triage Needed (was: Resolved) > The JdbcIO sink should accept sche

[jira] [Updated] (BEAM-6695) Latest transform for Python SDK

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

[jira] [Updated] (BEAM-6952) concatenated compressed files bug with python sdk

[ https://issues.apache.org/jira/browse/BEAM-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6952: Status: Triage Needed (was: Resolved) > concatenated compressed files bug with python

[jira] [Updated] (BEAM-7268) Make external sorter Hadoop free

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

[jira] [Updated] (BEAM-7443) BoundedSource->SDF needs a wrapper in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7443: Status: Triage Needed (was: Resolved) > BoundedSource->SDF needs a wrapper in Pyth

[jira] [Updated] (BEAM-7019) Reify transform for Python SDK

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

[jira] [Updated] (BEAM-6769) BigQuery IO does not support bytes in Python 3

[ https://issues.apache.org/jira/browse/BEAM-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6769: Status: Triage Needed (was: Resolved) > BigQuery IO does not support bytes in Pytho

[jira] [Updated] (BEAM-7023) WithKeys transform for Python SDK

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

[jira] [Updated] (BEAM-5865) Auto sharding of streaming sinks in FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-5865: Status: Triage Needed (was: Resolved) > Auto sharding of streaming sinks in FlinkRun

[jira] [Updated] (BEAM-7286) RedisIO support for INCRBY/DECRBY operations

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

[jira] [Updated] (BEAM-7442) Bounded Reads for Flink Runner fails with OOM

[ https://issues.apache.org/jira/browse/BEAM-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7442: Status: Triage Needed (was: Resolved) > Bounded Reads for Flink Runner fails with

[jira] [Updated] (BEAM-5148) Implement MongoDB IO for Python SDK

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

[jira] [Updated] (BEAM-1251) Python 3 Support

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

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