[jira] [Updated] (BEAM-13434) Bump up Apache log4j2 to 2.16.0 due to the vulnerability

[ https://issues.apache.org/jira/browse/BEAM-13434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-13434: - Status: Triage Needed (was: Resolved) > Bump up Apache log4j2 to 2.16.0 due to the vulnerabil

[jira] [Updated] (BEAM-12474) Configure PubsubIO with dead-letter topic

[ https://issues.apache.org/jira/browse/BEAM-12474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12474: - Status: Triage Needed (was: In Progress) > Configure PubsubIO with dead-letter to

[jira] [Updated] (BEAM-12730) Add custom delimiters to Python TextIO reads

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

[jira] [Updated] (BEAM-12522) @InitialRestriction and @SplitRestriction should be able to access sideinputs as @ProcessElement

[ https://issues.apache.org/jira/browse/BEAM-12522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12522: - Status: Triage Needed (was: Resolved) > @InitialRestriction and @SplitRestriction should be able

[jira] [Updated] (BEAM-12913) Enable configuring query priority in Python ReadFromBigQuery

[ https://issues.apache.org/jira/browse/BEAM-12913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12913: - Status: Triage Needed (was: Resolved) > Enable configuring query priority in Python ReadFromBigQu

[jira] [Updated] (BEAM-12070) Make ParquetIO splittable by default

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

[jira] [Updated] (BEAM-12945) DataFrame API fails to import with pandas 1.0.x

[ https://issues.apache.org/jira/browse/BEAM-12945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12945: - Status: Triage Needed (was: Resolved) > DataFrame API fails to import with pandas 1.

[jira] [Updated] (BEAM-12479) UnsupportedOperationException when reading from BigQuery tables and converting TableRows to Beam Rows

[ https://issues.apache.org/jira/browse/BEAM-12479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12479: - Status: Triage Needed (was: Resolved) > UnsupportedOperationException when reading from BigQuery tab

[jira] [Updated] (BEAM-6516) Failed to advance source: org.apache.beam.sdk.io.rabbitmq.RabbitMqIO

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

[jira] [Updated] (BEAM-12781) SDFBoundedSourceReader behaves much slower compared with the original behavior of BoundedSource

[ https://issues.apache.org/jira/browse/BEAM-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12781: - Status: Triage Needed (was: Resolved) > SDFBoundedSourceReader behaves much slower compared with

[jira] [Updated] (BEAM-12701) Converting two deferred dataframes to csv in the same pipeline causes a PCollection label collision

[ https://issues.apache.org/jira/browse/BEAM-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12701: - Status: Triage Needed (was: Resolved) > Converting two deferred dataframes to csv in the same pipel

[jira] [Work started] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)

[ https://issues.apache.org/jira/browse/BEAM-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9547 started by null. -- > Implement all pandas operations (or raise WontImplementEr

[jira] [Updated] (BEAM-12628) AvroCoder changed underlying String class for SpecificRecords

[ https://issues.apache.org/jira/browse/BEAM-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12628: - Status: Triage Needed (was: Resolved) > AvroCoder changed underlying String class for SpecificReco

[jira] [Updated] (BEAM-10955) testSavepointRestoreLegacy flake: Could not find Flink job (FlinkJobNotFoundException)

[ https://issues.apache.org/jira/browse/BEAM-10955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-10955: - Status: Triage Needed (was: Resolved) > testSavepointRestoreLegacy flake: Could not find Flink

[jira] [Updated] (BEAM-12715) SnowflakeWrite fails in batch mode when the number of shards is > 1000

[ https://issues.apache.org/jira/browse/BEAM-12715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12715: - Status: Triage Needed (was: Resolved) > SnowflakeWrite fails in batch mode when the number of shards

[jira] [Work started] (BEAM-12474) Configure PubsubIO with dead-letter topic

[ https://issues.apache.org/jira/browse/BEAM-12474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-12474 started by null. --- > Configure PubsubIO with dead-letter to

[jira] [Work started] (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 ] Work on BEAM-10917 started by null. --- > Implement a BigQuery bounded source using the BigQuery storage

[jira] [Updated] (BEAM-12362) BigQuery sink swallows HttpErrors when performing streaming inserts preventing retries

[ https://issues.apache.org/jira/browse/BEAM-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12362: - Status: Triage Needed (was: Resolved) > BigQuery sink swallows HttpErrors when performing stream

[jira] [Updated] (BEAM-12028) DataFrame API error messages should be more helpful

[ https://issues.apache.org/jira/browse/BEAM-12028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12028: - Status: Triage Needed (was: Resolved) > DataFrame API error messages should be more help

[jira] [Updated] (BEAM-12260) Java - Backport FirestoreIO connector's ramp-up to DatastoreIO connector

[ https://issues.apache.org/jira/browse/BEAM-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12260: - Status: Triage Needed (was: Resolved) > Java - Backport FirestoreIO connector's ramp-up to Dat

[jira] [Updated] (BEAM-12339) Support CREATE FUNCTION statement in Calcite dialect.

[ https://issues.apache.org/jira/browse/BEAM-12339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12339: - Status: Triage Needed (was: Resolved) > Support CREATE FUNCTION statement in Calcite dial

[jira] [Updated] (BEAM-12281) Drop support for Flink 1.10

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

[jira] [Updated] (BEAM-11227) Upgrade beam-vendor-grpc-1_26_0-0.3 to fix CVE-2020-27216

[ https://issues.apache.org/jira/browse/BEAM-11227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11227: - Status: Triage Needed (was: Resolved) > Upgrade beam-vendor-grpc-1_26_0-0.3 to fix CVE-2020-27

[jira] [Updated] (BEAM-12198) Support Dataflow update when schemas are used

[ https://issues.apache.org/jira/browse/BEAM-12198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12198: - Status: Triage Needed (was: Resolved) > Support Dataflow update when schemas are u

[jira] [Updated] (BEAM-9487) GBKs on unbounded pcolls with global windows and no triggers should fail

[ https://issues.apache.org/jira/browse/BEAM-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9487: Status: Triage Needed (was: Resolved) > GBKs on unbounded pcolls with global windows and no trigg

[jira] [Updated] (BEAM-7372) Clean up Python 2 codepaths once Beam no longer supports Python 2.

[ https://issues.apache.org/jira/browse/BEAM-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7372: Status: Triage Needed (was: Resolved) > Clean up Python 2 codepaths once Beam no longer supports Pytho

[jira] [Updated] (BEAM-12216) Remove MqttIO.create() with clientId constructor as it was deprecated since Beam 2.13.0

[ https://issues.apache.org/jira/browse/BEAM-12216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12216: - Status: Triage Needed (was: Resolved) > Remove MqttIO.create() with clientId constructor as it

[jira] [Updated] (BEAM-7819) PubsubMessage message parsing is lacking non-attribute fields

[ https://issues.apache.org/jira/browse/BEAM-7819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-7819: Status: Triage Needed (was: Resolved) > PubsubMessage message parsing is lacking non-attribute fie

[jira] [Updated] (BEAM-12217) MongoDbIO: remove Read.withFilter() and Read.withProjection()

[ https://issues.apache.org/jira/browse/BEAM-12217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12217: - Status: Triage Needed (was: Resolved) > MongoDbIO: remove Read.withFilter() and Read.withProject

[jira] [Updated] (BEAM-12220) ZipFiles.zipDirectory leaks native JVM memory

[ https://issues.apache.org/jira/browse/BEAM-12220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12220: - Status: Triage Needed (was: Resolved) > ZipFiles.zipDirectory leaks native JVM mem

[jira] [Updated] (BEAM-12514) BigQueryIO - ReadFromBigQuery can not get table reference from RuntimeValueProvider

[ https://issues.apache.org/jira/browse/BEAM-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12514: - Status: Triage Needed (was: Resolved) > BigQueryIO - ReadFromBigQuery can not get table reference f

[jira] [Updated] (BEAM-12214) Remove RedisIO.readAll() as it was deprecated since Beam 2.13.0

[ https://issues.apache.org/jira/browse/BEAM-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12214: - Status: Triage Needed (was: Resolved) > Remove RedisIO.readAll() as it was deprecated since Beam 2.1

[jira] [Updated] (BEAM-2085) Transforms could give hints to runners on resource requirements

[ https://issues.apache.org/jira/browse/BEAM-2085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-2085: Status: Triage Needed (was: In Progress) > Transforms could give hints to runners on resource requireme

[jira] [Work started] (BEAM-2085) Transforms could give hints to runners on resource requirements

[ https://issues.apache.org/jira/browse/BEAM-2085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-2085 started by null. -- > Transforms could give hints to runners on resource requireme

[jira] [Updated] (BEAM-12361) Reshuffle.withNumBuckets creates (N*2)-1 buckets

[ https://issues.apache.org/jira/browse/BEAM-12361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12361: - Status: Triage Needed (was: Resolved) > Reshuffle.withNumBuckets creates (N*2)-1 buck

[jira] [Updated] (BEAM-12277) Add flink 1.13 build target

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

[jira] [Updated] (BEAM-12272) Python - Backport FirestoreIO connector's ramp-up to DatastoreIO connector

[ https://issues.apache.org/jira/browse/BEAM-12272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12272: - Status: Triage Needed (was: Resolved) > Python - Backport FirestoreIO connector's ra

[jira] [Updated] (BEAM-12024) Add well-documented DataFrame example pipelines

[ https://issues.apache.org/jira/browse/BEAM-12024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12024: - Status: Triage Needed (was: Resolved) > Add well-documented DataFrame example pipeli

[jira] [Updated] (BEAM-8344) Refactor ParquetTableProvider

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

[jira] [Updated] (BEAM-11762) Upgrade Beam base image to use Tensorflow 2.4.1

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

[jira] [Updated] (BEAM-11677) Expose commit_offset_in_finalize and timestamp_policy to ReadFromKafka

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

[jira] [Updated] (BEAM-11624) Hash functions in ZetaSQL

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

[jira] [Updated] (BEAM-8202) Support ParquetTable Writer

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

[jira] [Updated] (BEAM-11205) Beam Dependency Update Request: com.google.cloud:libraries-bom

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

[jira] [Updated] (BEAM-11526) Add Beam schema support to ParquetIO

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

[jira] [Updated] (BEAM-10029) Add Spanner IO Performance Tests for Python SDK

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

[jira] [Updated] (BEAM-11277) WriteToBigQuery with batch file loads does not respect schema update options when there are multiple load jobs

[ https://issues.apache.org/jira/browse/BEAM-11277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11277: - Status: Triage Needed (was: Resolved) > WriteToBigQuery with batch file loads does not respect sch

[jira] [Updated] (BEAM-11799) S3 options does not provided to boto3 client while using FlinkRunner and Beam worker pool container

[ https://issues.apache.org/jira/browse/BEAM-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11799: - Status: Triage Needed (was: Resolved) > S3 options does not provided to boto3 client while us

[jira] [Updated] (BEAM-11855) ib.collect should accept DeferredDataFrame instances

[ https://issues.apache.org/jira/browse/BEAM-11855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11855: - Status: Triage Needed (was: Resolved) > ib.collect should accept DeferredDataFrame instan

[jira] [Updated] (BEAM-11571) Support Conversion to GenericRecords in Convert.to transform

[ https://issues.apache.org/jira/browse/BEAM-11571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11571: - Status: Triage Needed (was: Resolved) > Support Conversion to GenericRecords in Convert.to transf

[jira] [Updated] (BEAM-11018) Use metric for Python BigQuery streaming insert API latency logging

[ https://issues.apache.org/jira/browse/BEAM-11018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11018: - Status: Triage Needed (was: Resolved) > Use metric for Python BigQuery streaming insert API late

[jira] [Updated] (BEAM-11527) Support user configurable Hadoop Configuration flags for ParquetIO

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

[jira] [Work started] (BEAM-11205) Beam Dependency Update Request: com.google.cloud:libraries-bom

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

[jira] [Updated] (BEAM-12212) Add sdkContainerImage flag to (eventually) replace workerHarnessContainerImage

[ https://issues.apache.org/jira/browse/BEAM-12212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12212: - Status: Triage Needed (was: Resolved) > Add sdkContainerImage flag to (eventually) repl

[jira] [Work started] (BEAM-10029) Add Spanner IO Performance Tests for Python SDK

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

[jira] [Updated] (BEAM-10324) Create ApproximateDistinct using HLL Impl

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

[jira] [Updated] (BEAM-11533) PubSub support types: TIMESTAMP, DATE, TIME, DATETIME

[ https://issues.apache.org/jira/browse/BEAM-11533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11533: - Status: Triage Needed (was: Resolved) > PubSub support types: TIMESTAMP, DATE, TIME, DATET

[jira] [Updated] (BEAM-11697) Upgrade Flink runner to Flink versions 1.12.1 and 1.11.3

[ https://issues.apache.org/jira/browse/BEAM-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11697: - Status: Triage Needed (was: Resolved) > Upgrade Flink runner to Flink versions 1.12.1 and 1.1

[jira] [Updated] (BEAM-11538) Add a Deque Encoder

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

[jira] [Updated] (BEAM-11665) Create Beam GCP BOM

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

[jira] [Updated] (BEAM-11482) Thrift support for KafkaTableProvider

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

[jira] [Updated] (BEAM-11329) HDFS not deduplicating identical configuration paths.

[ https://issues.apache.org/jira/browse/BEAM-11329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11329: - Status: Triage Needed (was: Resolved) > HDFS not deduplicating identical configuration pa

[jira] [Updated] (BEAM-11643) SpannerIO does not support using BigDecimal for Numeric fields

[ https://issues.apache.org/jira/browse/BEAM-11643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11643: - Status: Triage Needed (was: Resolved) > SpannerIO does not support using BigDecimal for Numeric fie

[jira] [Updated] (BEAM-11457) Enable skip key-value clone for HadoopFormatIO

[ https://issues.apache.org/jira/browse/BEAM-11457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11457: - Status: Triage Needed (was: Resolved) > Enable skip key-value clone for HadoopForma

[jira] [Updated] (BEAM-11460) Support reading Parquet files with unknown schema

[ https://issues.apache.org/jira/browse/BEAM-11460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11460: - Status: Triage Needed (was: Resolved) > Support reading Parquet files with unknown sch

[jira] [Updated] (BEAM-11032) Use metric for Java BigQuery streaming insert API latency logging

[ https://issues.apache.org/jira/browse/BEAM-11032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11032: - Status: Triage Needed (was: Resolved) > Use metric for Java BigQuery streaming insert API late

[jira] [Updated] (BEAM-11408) GCP BigQuery sink (streaming inserts) uses runner determined sharding

[ https://issues.apache.org/jira/browse/BEAM-11408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11408: - Status: Triage Needed (was: Resolved) > GCP BigQuery sink (streaming inserts) uses runner determi

[jira] [Updated] (BEAM-10074) Hash Functions in BeamSQL

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

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

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

[jira] [Updated] (BEAM-11941) Upgrade Flink runner to Flink version 1.12.2

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

[jira] [Updated] (BEAM-12071) DataFrame IO sinks do not correctly partition by window

[ https://issues.apache.org/jira/browse/BEAM-12071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-12071: - Status: Triage Needed (was: Resolved) > DataFrame IO sinks do not correctly partition by win

[jira] [Updated] (BEAM-11850) Support DDL in SQL Transform

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

[jira] [Updated] (BEAM-11338) Beam schema for thrift data

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

[jira] [Updated] (BEAM-11929) DataframeTransfom, BatchRowsAsDataFrame do not preserve field order when schema created with beam.Row

[ https://issues.apache.org/jira/browse/BEAM-11929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11929: - Status: Triage Needed (was: Resolved) > DataframeTransfom, BatchRowsAsDataFrame do not preserve fi

[jira] [Updated] (BEAM-11913) Add support for Hadoop configuration on ParquetIO

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

[jira] [Updated] (BEAM-11772) GCP BigQuery sink (file loads) uses runner determined sharding for unbounded data

[ https://issues.apache.org/jira/browse/BEAM-11772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11772: - Status: Triage Needed (was: Resolved) > GCP BigQuery sink (file loads) uses runner determined shard

[jira] [Updated] (BEAM-6103) Allow setting a HTTP write timeout to requests to BigQuery

[ https://issues.apache.org/jira/browse/BEAM-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-6103: Status: Triage Needed (was: Resolved) > Allow setting a HTTP write timeout to requests to BigQu

[jira] [Updated] (BEAM-11719) Enforce deterministic coding for GroupByKey and Stateful DoFns

[ https://issues.apache.org/jira/browse/BEAM-11719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11719: - Status: Triage Needed (was: Resolved) > Enforce deterministic coding for GroupByKey and Stateful Do

[jira] [Updated] (BEAM-7637) Migrate S3FileSystem to AWS SDK for Java 2

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

[jira] [Work started] (BEAM-9650) Add consistent slowly changing side inputs support

[ https://issues.apache.org/jira/browse/BEAM-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9650 started by null. -- > Add consistent slowly changing side inputs supp

[jira] [Updated] (BEAM-11948) Drop support for Flink 1.8 and 1.9

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

[jira] [Updated] (BEAM-11531) pandas 1.2.0 breaks Python precommit

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

[jira] [Updated] (BEAM-11373) Add write support to Bigtable Table for BeamSQL

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

[jira] [Updated] (BEAM-11266) Cannot use Python MongoDB connector with Atlas MongoDB

[ https://issues.apache.org/jira/browse/BEAM-11266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11266: - Status: Triage Needed (was: Resolved) > Cannot use Python MongoDB connector with Atlas Mong

[jira] [Updated] (BEAM-8106) Publish Java 11 SDK Harness docker image

[ https://issues.apache.org/jira/browse/BEAM-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-8106: Status: Triage Needed (was: Resolved) > Publish Java 11 SDK Harness docker im

[jira] [Updated] (BEAM-5504) PubsubAvroTable

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

[jira] [Updated] (BEAM-10893) Add JSON suport to Kafka Table Provider

[ https://issues.apache.org/jira/browse/BEAM-10893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-10893: - Status: Triage Needed (was: Resolved) > Add JSON suport to Kafka Table Provi

[jira] [Updated] (BEAM-11806) KafkaIO - Partition Recognition in WriteRecords

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

[jira] [Updated] (BEAM-11173) Create Bigtable table provider

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

[jira] [Updated] (BEAM-7093) Support Spark 3 in Spark runner

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

[jira] [Updated] (BEAM-11065) Apache Beam Template to ingest from Apache Kafka to Google Pub/Sub

[ https://issues.apache.org/jira/browse/BEAM-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11065: - Status: Triage Needed (was: Resolved) > Apache Beam Template to ingest from Apache Kafka to Google

[jira] [Updated] (BEAM-9650) Add consistent slowly changing side inputs support

[ https://issues.apache.org/jira/browse/BEAM-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9650: Status: Triage Needed (was: In Progress) > Add consistent slowly changing side inputs supp

[jira] [Updated] (BEAM-11628) Implement GroupBy.apply

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

[jira] [Updated] (BEAM-8569) Support Hadoop 3 on Beam

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

[jira] [Updated] (BEAM-3736) Add SetUp() and TearDown() for CombineFns

[ https://issues.apache.org/jira/browse/BEAM-3736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-3736: Status: Triage Needed (was: In Progress) > Add SetUp() and TearDown() for Combine

[jira] [Updated] (BEAM-11146) Add option to disable copying between Flink runner

[ https://issues.apache.org/jira/browse/BEAM-11146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11146: - Status: Triage Needed (was: Resolved) > Add option to disable copying between Flink run

[jira] [Updated] (BEAM-10641) Add Combiner Packing to Dataflow

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

[jira] [Updated] (BEAM-9278) Make HBase client a provided dependency in HBaseIO

[ https://issues.apache.org/jira/browse/BEAM-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-9278: Status: Triage Needed (was: Resolved) > Make HBase client a provided dependency in HBas

[jira] [Updated] (BEAM-11444) MongoDB Python connector shows password in display_data

[ https://issues.apache.org/jira/browse/BEAM-11444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anonymous updated BEAM-11444: - Status: Triage Needed (was: Resolved) > MongoDB Python connector shows password in display_d

[jira] [Work started] (BEAM-3736) Add SetUp() and TearDown() for CombineFns

[ https://issues.apache.org/jira/browse/BEAM-3736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-3736 started by null. -- > Add SetUp() and TearDown() for Combine

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